diff options
| author | Tathagata Das <tathagata.das1565@gmail.com> | 2013-02-21 15:22:26 -0800 |
|---|---|---|
| committer | Tathagata Das <tathagata.das1565@gmail.com> | 2013-02-21 15:22:26 -0800 |
| commit | 208edaac1bdb4b0520e5fb204f7bc96079bfa3ed (patch) | |
| tree | c2dbef2fa0f6fe6dd2ae41157f0ad967e49f5e1d /streaming | |
| parent | 972fe7714fb57385d14e4d776f70e0040d3a8f7e (diff) | |
| download | spark-208edaac1bdb4b0520e5fb204f7bc96079bfa3ed.tar.gz spark-208edaac1bdb4b0520e5fb204f7bc96079bfa3ed.tar.bz2 spark-208edaac1bdb4b0520e5fb204f7bc96079bfa3ed.zip | |
Fixed condition in InputDStream isTimeValid.
Diffstat (limited to 'streaming')
| -rw-r--r-- | streaming/src/main/scala/spark/streaming/dstream/InputDStream.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/streaming/src/main/scala/spark/streaming/dstream/InputDStream.scala b/streaming/src/main/scala/spark/streaming/dstream/InputDStream.scala index a4db44a608..3c5d43a609 100644 --- a/streaming/src/main/scala/spark/streaming/dstream/InputDStream.scala +++ b/streaming/src/main/scala/spark/streaming/dstream/InputDStream.scala @@ -29,7 +29,7 @@ abstract class InputDStream[T: ClassManifest] (@transient ssc_ : StreamingContex false // Time not valid } else { // Time is valid, but check it it is more than lastValidTime - if (lastValidTime == null || lastValidTime <= time) { + if (lastValidTime != null && time < lastValidTime) { logWarning("isTimeValid called with " + time + " where as last valid time is " + lastValidTime) } lastValidTime = time |