This is an automated email from the ASF dual-hosted git repository.
huweihua pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new 4f09bbb3923 [FLINK-33126] Fix EventTimeAllWindowCheckpointingITCase
jobName typo
4f09bbb3923 is described below
commit 4f09bbb39239f5523da8ecb7c7cd5ac9fd34c0e5
Author: 马越 <[email protected]>
AuthorDate: Wed Sep 20 20:49:00 2023 +0800
[FLINK-33126] Fix EventTimeAllWindowCheckpointingITCase jobName typo
---
.../test/checkpointing/EventTimeAllWindowCheckpointingITCase.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git
a/flink-tests/src/test/java/org/apache/flink/test/checkpointing/EventTimeAllWindowCheckpointingITCase.java
b/flink-tests/src/test/java/org/apache/flink/test/checkpointing/EventTimeAllWindowCheckpointingITCase.java
index 274603bf9ba..3c3b0d4c5f5 100644
---
a/flink-tests/src/test/java/org/apache/flink/test/checkpointing/EventTimeAllWindowCheckpointingITCase.java
+++
b/flink-tests/src/test/java/org/apache/flink/test/checkpointing/EventTimeAllWindowCheckpointingITCase.java
@@ -298,7 +298,7 @@ public class EventTimeAllWindowCheckpointingITCase extends
TestLogger {
numKeys, numElementsPerKey,
windowSize)))
.setParallelism(1);
- env.execute("Tumbling Window Test");
+ env.execute("PreAggregated Tumbling Window Test");
} catch (Exception e) {
e.printStackTrace();
fail(e.getMessage());
@@ -378,7 +378,7 @@ public class EventTimeAllWindowCheckpointingITCase extends
TestLogger {
numKeys, numElementsPerKey,
windowSlide)))
.setParallelism(1);
- env.execute("Tumbling Window Test");
+ env.execute("PreAggregated Sliding Window Test");
} catch (Exception e) {
e.printStackTrace();
fail(e.getMessage());