[GitHub] spark issue #19824: [SPARK][STREAMING] Invoke onBatchCompletion() only when ...

2017-12-03 Thread victor-wong
Github user victor-wong commented on the issue: https://github.com/apache/spark/pull/19824 @CodingCat Thank you:) --- - To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org For additional commands,

[GitHub] spark issue #19824: [SPARK][STREAMING] Invoke onBatchCompletion() only when ...

2017-12-02 Thread CodingCat
Github user CodingCat commented on the issue: https://github.com/apache/spark/pull/19824 if you just worry about > As I was using the StreamingListenerBatchCompleted to do some metadata checkpointing stuff, which should be done only when the batch succeeded. If

[GitHub] spark issue #19824: [SPARK][STREAMING] Invoke onBatchCompletion() only when ...

2017-12-01 Thread victor-wong
Github user victor-wong commented on the issue: https://github.com/apache/spark/pull/19824 @CodingCat > One thing to note is that mute an event is a behavior change I agree with that, so we should be careful about changing the current behavior. I will close the PR later.

[GitHub] spark issue #19824: [SPARK][STREAMING] Invoke onBatchCompletion() only when ...

2017-12-01 Thread CodingCat
Github user CodingCat commented on the issue: https://github.com/apache/spark/pull/19824 One thing to note is that mute an event is a behavior change, if a user has introduced some customized listener to capture all completed batches and also extract failed job info, he/she will see

[GitHub] spark issue #19824: [SPARK][STREAMING] Invoke onBatchCompletion() only when ...

2017-12-01 Thread CodingCat
Github user CodingCat commented on the issue: https://github.com/apache/spark/pull/19824 #16542 has guaranteed that the failed batch can be re-executed, and I didn’t check if reverting the change in #16542 plus your new change can guarantee the same thing... Suppose it

[GitHub] spark issue #19824: [SPARK][STREAMING] Invoke onBatchCompletion() only when ...

2017-12-01 Thread victor-wong
Github user victor-wong commented on the issue: https://github.com/apache/spark/pull/19824 @CodingCat please checkout the difference between the two PR. ` if (jobSet.hasCompleted) { - jobSets.remove(jobSet.time) -

[GitHub] spark issue #19824: [SPARK][STREAMING] Invoke onBatchCompletion() only when ...

2017-11-30 Thread CodingCat
Github user CodingCat commented on the issue: https://github.com/apache/spark/pull/19824 `What I want to say is that if a Job is failed, we should consider the Batch as not completed.` isn't #16542 doing the same thing? ---

[GitHub] spark issue #19824: [SPARK][STREAMING] Invoke onBatchCompletion() only when ...

2017-11-30 Thread victor-wong
Github user victor-wong commented on the issue: https://github.com/apache/spark/pull/19824 @CodingCat Yes, this PR wants to solve the same issue in https://github.com/apache/spark/pull/16542, but I think this is a better way to solve it. If a Job failed, I think we should not

[GitHub] spark issue #19824: [SPARK][STREAMING] Invoke onBatchCompletion() only when ...

2017-11-30 Thread victor-wong
Github user victor-wong commented on the issue: https://github.com/apache/spark/pull/19824 @viirya Sorry for the misleading title, I have changed it now. --- - To unsubscribe, e-mail: