spark git commit: [SPARK-11740][STREAMING] Fix the race condition of two checkpoints in a batch

2015-11-17 Thread tdas
Repository: spark Updated Branches: refs/heads/master 936bc0bcb -> 928d63162 [SPARK-11740][STREAMING] Fix the race condition of two checkpoints in a batch We will do checkpoint when generating a batch and completing a batch. When the processing time of a batch is greater than the batch interv

spark git commit: [SPARK-11740][STREAMING] Fix the race condition of two checkpoints in a batch

2015-11-17 Thread tdas
Repository: spark Updated Branches: refs/heads/branch-1.6 1a5dfb706 -> fa9d56f9e [SPARK-11740][STREAMING] Fix the race condition of two checkpoints in a batch We will do checkpoint when generating a batch and completing a batch. When the processing time of a batch is greater than the batch in

spark git commit: [SPARK-11740][STREAMING] Fix the race condition of two checkpoints in a batch

2015-11-17 Thread tdas
Repository: spark Updated Branches: refs/heads/branch-1.5 bdcbbdac6 -> e26dc9642 [SPARK-11740][STREAMING] Fix the race condition of two checkpoints in a batch We will do checkpoint when generating a batch and completing a batch. When the processing time of a batch is greater than the batch in