JunRuiLee commented on code in PR #21672:
URL: https://github.com/apache/flink/pull/21672#discussion_r1089662453
##########
flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/JobMasterTest.java:
##########
@@ -1362,7 +1363,8 @@ void testRequestPartitionState() throws Exception {
// finish the producer task
jobMasterGateway
.updateTaskExecutionState(
- new TaskExecutionState(executionAttemptId,
ExecutionState.FINISHED))
+
SchedulerTestingUtils.createFinishedTaskExecutionState(
+ executionAttemptId))
Review Comment:
Because the FLINK-29664 required IOMetrics not null when mark task finished.
And the older constructor will create a finished TaskExecutionState with null
IOMetrics.
--
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]
