[GitHub] spark issue #22424: [SPARK-25303][STREAMING] For checkpointed DStreams, remo...

Github user nikunjb commented on the issue: https://github.com/apache/spark/pull/22424 @dongjoon-hyun @tdas Can you please help review this PR? --- - To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org For

[GitHub] spark issue #22423: [SPARK-25302][STREAMING] Checkpoint the reducedStream in...

Github user nikunjb commented on the issue: https://github.com/apache/spark/pull/22423 @dongjoon-hyun @tdas Can you please help review this PR? --- - To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org For

[GitHub] spark pull request #22424: [SPARK-25303][STREAMING] For checkpointed DStream...

GitHub user nikunjb opened a pull request: https://github.com/apache/spark/pull/22424 [SPARK-25303][STREAMING] For checkpointed DStreams, remove the parent… …RemeberDuration - this will be recalculated to a minimum value ## How was this patch tested

[GitHub] spark pull request #22423: [SPARK-25302][STREAMING] Checkpoint the reducedSt...

GitHub user nikunjb opened a pull request: https://github.com/apache/spark/pull/22423 [SPARK-25302][STREAMING] Checkpoint the reducedStream in ReducedWindo… …wDStream so as to cut the lineage completely to parent ## What changes were proposed in this pull request