Skip to content

Commit ae96dc0

Browse files
committed
[hotfix] Improve comment about Task's state transitions
1 parent dc2627b commit ae96dc0

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -852,8 +852,8 @@ private void doRun() {
852852

853853
/**
854854
* Transition into our final state in case of failure. We should be either in DEPLOYING,
855-
* INITIALIZING, RUNNING, CANCELING, or FAILED loop for multiple retries during concurrent state
856-
* changes via calls to cancel() or to failExternally()
855+
* INITIALIZING, RUNNING, CANCELING, or FAILED. Loop for multiple retries in case of concurrent
856+
* state changes via calls to cancel() or to failExternally()
857857
*/
858858
private void transitionStateOnFailure(
859859
Throwable t, AutoCloseableRegistry postFailureCleanUpRegistry) throws IOException {

0 commit comments

Comments
 (0)