zhuzhurk commented on code in PR #24771:
URL: https://github.com/apache/flink/pull/24771#discussion_r1615668073
##########
flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/adaptivebatch/BatchJobRecoveryTest.java:
##########
@@ -406,16 +405,16 @@ void
testJobVertexUnFinishedAndOperatorCoordinatorNotSupportBatchSnapshot() thro
}
// This case will use job graph with the following topology:
- // Source (p=5) -- POINTWISE --> Middle (p=5) -- ALLTOALL --> Sink (p=2)
+ // Source (p=5) -- POINTWISE --> Middle (p=5) -- ALLTOALL --> Sink (p=-1)
//
// This case will undergo the following stages:
// 1. All source tasks are finished.
// The source vertex contains an operator coordinator that does not
support batch snapshot.
// 2. JM failover.
// 3. After the failover, all source tasks are expected to be recovered to
finished, and their
// produced partitions should also be restored.
- // 4. Trigger all middle task running
- // 5. Trigger the partition consumed by middle task0 to go missing.
+ // 4. Transition all middle task to running
+ // 5. Transition the partition consumed by middle task0 to go missing.
Review Comment:
Mark the partition consumed by middle task0 as missing.
--
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: issues-unsubscr...@flink.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
