[flink] 04/06: [hotfix][runtime][test] Improves assert message

[mapohl]

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 <matth...@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()),