xiongbo-sjtu commented on PR #43194:
URL: https://github.com/apache/spark/pull/43194#issuecomment-1742343900
I've updated the PR to ensure that the following conditions are met, before
`thirdJobFuture` is even constructed.
- [Condition A] firstJobFuture.isCompleted should be(true)
- [Condition B] secondJobFuture.isCompleted should be(true)
- [Condition C] sc.getJobTags.size should be(1)
- [Condition D] sc.statusTracker.getJobIdsForTag("tag1").toSet.size should
be(2)
Conditions A & B tell us that the first 2 future actions are completed
(i.e., no more state transition).
Condition C means that only 1 tag remains (i.e., `tag1` is removed and
`tag2` is kept).
Condition D means that only 2 jobs have been marked with `tag1`.
Given that, we'd expect that the reported issue disappears in the sense that
`sc.statusTracker.getJobIdsForTag("tag1").toSet` won't return a set of 3 items.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
