This is an automated email from the ASF dual-hosted git repository. sjwiesman pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit 3762c3b2fd1e4ea717aeea8fc98810f86793a999 Author: sjwiesman <[email protected]> AuthorDate: Fri Nov 12 16:25:57 2021 -0600 [hotfix][yarn-tests] drop assertion on streaming word count output The modern FileSink keeps output files hidden until a bucket roll; based on time, file size, or checkpoint. This is different from DataStream#writeTextFile which always writes visible files. The rolling behavior makes checking job output flakey, however, that is not really the point of this test so it is dropped. --- .../flink/yarn/YARNSessionCapacitySchedulerITCase.java | 12 ------------ 1 file changed, 12 deletions(-) diff --git a/flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNSessionCapacitySchedulerITCase.java b/flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNSessionCapacitySchedulerITCase.java index d878661..ce71d3b 100644 --- a/flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNSessionCapacitySchedulerITCase.java +++ b/flink-yarn-tests/src/test/java/org/apache/flink/yarn/YARNSessionCapacitySchedulerITCase.java @@ -675,18 +675,6 @@ public class YARNSessionCapacitySchedulerITCase extends YarnTestBase { content += FileUtils.readFileToString(f) + "\n"; } } - // String content = FileUtils.readFileToString(taskmanagerOut); - // check for some of the wordcount outputs. - Assert.assertTrue( - "Expected string 'da 5' or '(all,2)' not found in string '" + content + "'", - content.contains("da 5") - || content.contains("(da,5)") - || content.contains("(all,2)")); - Assert.assertTrue( - "Expected string 'der 29' or '(mind,1)' not found in string'" + content + "'", - content.contains("der 29") - || content.contains("(der,29)") - || content.contains("(mind,1)")); // check if the heap size for the TaskManager was set correctly File jobmanagerLog =
