diff options
| author | uncleGen <hustyugm@gmail.com> | 2017-03-12 08:29:37 +0000 |
|---|---|---|
| committer | Sean Owen <sowen@cloudera.com> | 2017-03-12 08:29:37 +0000 |
| commit | e29a74d5b1fa3f9356b7af5dd7e3fce49bc8eb7d (patch) | |
| tree | f1512df30b47dc27f922d175a9d7dc344c6ac29f /sql | |
| parent | f6fdf92d0dce2cb3340f3e2ff768e09ef69176cd (diff) | |
| download | spark-e29a74d5b1fa3f9356b7af5dd7e3fce49bc8eb7d.tar.gz spark-e29a74d5b1fa3f9356b7af5dd7e3fce49bc8eb7d.tar.bz2 spark-e29a74d5b1fa3f9356b7af5dd7e3fce49bc8eb7d.zip | |
[DOCS][SS] fix structured streaming python example
## What changes were proposed in this pull request?
- SS python example: `TypeError: 'xxx' object is not callable`
- some other doc issue.
## How was this patch tested?
Jenkins.
Author: uncleGen <hustyugm@gmail.com>
Closes #17257 from uncleGen/docs-ss-python.
Diffstat (limited to 'sql')
| -rw-r--r-- | sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/FileStreamSource.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/FileStreamSource.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/FileStreamSource.scala index 411a15ffce..a9e64c6400 100644 --- a/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/FileStreamSource.scala +++ b/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/FileStreamSource.scala @@ -97,7 +97,7 @@ class FileStreamSource( } seenFiles.purge() - logInfo(s"maxFilesPerBatch = $maxFilesPerBatch, maxFileAge = $maxFileAgeMs") + logInfo(s"maxFilesPerBatch = $maxFilesPerBatch, maxFileAgeMs = $maxFileAgeMs") /** * Returns the maximum offset that can be retrieved from the source. |