WencongLiu commented on code in PR #23905:
URL: https://github.com/apache/flink/pull/23905#discussion_r1440106774
##########
flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/operator/CepRuntimeContextTest.java:
##########
@@ -110,38 +111,41 @@ public void testCepRuntimeContext() {
final String taskName = "foobarTask";
final OperatorMetricGroup metricGroup =
UnregisteredMetricsGroup.createOperatorMetricGroup();
- final int numberOfParallelSubtasks = 42;
- final int indexOfSubtask = 43;
+ final int numberOfParallelSubtasks = 43;
+ final int indexOfSubtask = 42;
final int attemptNumber = 1337;
- final String taskNameWithSubtask = "barfoo";
+ final String taskNameWithSubtask = "foobarTask (43/43)#1337";
Review Comment:
These tests are conflicted with the newly added correctness check in the
`TaskInfoImpl`. For example, the subtask ID shouldn't be large than or equal to
the operator parallelism number. I've fixed these errors in the commit
`[hotfix] Fix the logical errors for the tests related to task metadata`.
--
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]
