You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ma...@apache.org on 2022/03/16 18:25:16 UTC
[flink] 04/06: [hotfix][runtime][test] Improves assert message
This is an automated email from the ASF dual-hosted git repository.
mapohl pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 21e16e12cc94ee80f8418ca9d122683bf26e8ccd
Author: Matthias Pohl <ma...@ververica.com>
AuthorDate: Tue Mar 15 20:12:00 2022 +0100
[hotfix][runtime][test] Improves assert message
---
.../org/apache/flink/runtime/dispatcher/DispatcherCleanupITCase.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/DispatcherCleanupITCase.java b/flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/DispatcherCleanupITCase.java
index 60312f1..4b4ce27 100644
--- a/flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/DispatcherCleanupITCase.java
+++ b/flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/DispatcherCleanupITCase.java
@@ -323,7 +323,7 @@ public class DispatcherCleanupITCase extends AbstractDispatcherTest {
haServices.getJobGraphStore().getJobIds(),
equalTo(Collections.singleton(jobId)));
assertThat(
- "The JobResultStore has this job marked as dirty.",
+ "The JobResultStore should have this job marked as dirty.",
haServices.getJobResultStore().getDirtyResults().stream()
.map(JobResult::getJobId)
.collect(Collectors.toSet()),