diff options
| author | Gabriele Nizzoli <mail@nizzoli.net> | 2014-07-08 14:23:38 -0700 |
|---|---|---|
| committer | Tathagata Das <tathagata.das1565@gmail.com> | 2014-07-08 14:23:38 -0700 |
| commit | e6f7bfcfbf6aff7a9f8cd8e0a2166d0bf62b0912 (patch) | |
| tree | 2887a43242dda775a8dd7513f3c9290643946b0a /core | |
| parent | 32516f866a32d51bfaa04685ae77ba216b4202d9 (diff) | |
| download | spark-e6f7bfcfbf6aff7a9f8cd8e0a2166d0bf62b0912.tar.gz spark-e6f7bfcfbf6aff7a9f8cd8e0a2166d0bf62b0912.tar.bz2 spark-e6f7bfcfbf6aff7a9f8cd8e0a2166d0bf62b0912.zip | |
[SPARK-2362] Fix for newFilesOnly logic in file DStream
The newFilesOnly logic should be inverted: the logic should be that if the flag newFilesOnly==true then only start reading files older than current time. As the code is now if newFilesOnly==true then it will start to read files that are older than 0L (that is: every file in the directory).
Author: Gabriele Nizzoli <mail@nizzoli.net>
Closes #1077 from gabrielenizzoli/master and squashes the following commits:
4f1d261 [Gabriele Nizzoli] Fix for newFilesOnly logic in file DStream
Diffstat (limited to 'core')
0 files changed, 0 insertions, 0 deletions