You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by sj...@apache.org on 2021/11/15 21:22:59 UTC
[flink] 02/04: [hotfix][yarn-tests] drop assertion on streaming word count output
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 <sj...@gmail.com>
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 =