WencongLiu commented on code in PR #23905:
URL: https://github.com/apache/flink/pull/23905#discussion_r1440107033
##########
flink-connectors/flink-connector-files/src/test/java/org/apache/flink/connector/file/table/batch/compact/BatchPartitionCommitterSinkTest.java:
##########
@@ -127,7 +127,7 @@ public Long timestamp() {
};
private static RuntimeContext getMockRuntimeContext() {
- return new MockStreamingRuntimeContext(false, 0, 0) {
+ return new MockStreamingRuntimeContext(false, 1, 0) {
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: issues-unsubscr...@flink.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
