Repository: flink Updated Branches: refs/heads/master 3cad56d28 -> b198c33a7
[contrib, tests] Disable sys out logging in operator stats tests Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b198c33a Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/b198c33a Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/b198c33a Branch: refs/heads/master Commit: b198c33a75f0ea50f4da0d3b2b0e3f45529ce2c0 Parents: 3cad56d Author: Ufuk Celebi <u...@apache.org> Authored: Wed Oct 21 20:41:07 2015 +0200 Committer: Ufuk Celebi <u...@apache.org> Committed: Wed Oct 21 20:41:14 2015 +0200 ---------------------------------------------------------------------- .../OperatorStatsAccumulatorTest.java | 20 ++++++++++++-------- 1 file changed, 12 insertions(+), 8 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/b198c33a/flink-contrib/flink-operator-stats/src/test/java/org/apache/flink/contrib/operatorstatistics/OperatorStatsAccumulatorTest.java ---------------------------------------------------------------------- diff --git a/flink-contrib/flink-operator-stats/src/test/java/org/apache/flink/contrib/operatorstatistics/OperatorStatsAccumulatorTest.java b/flink-contrib/flink-operator-stats/src/test/java/org/apache/flink/contrib/operatorstatistics/OperatorStatsAccumulatorTest.java index 887c745..41a036f 100644 --- a/flink-contrib/flink-operator-stats/src/test/java/org/apache/flink/contrib/operatorstatistics/OperatorStatsAccumulatorTest.java +++ b/flink-contrib/flink-operator-stats/src/test/java/org/apache/flink/contrib/operatorstatistics/OperatorStatsAccumulatorTest.java @@ -111,6 +111,7 @@ public class OperatorStatsAccumulatorTest extends AbstractTestBase { String inputFile = createTempFile("datapoints.txt", input); ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment(); + env.getConfig().disableSysoutLogging(); OperatorStatisticsConfig operatorStatisticsConfig = new OperatorStatisticsConfig(OperatorStatisticsConfig.CountDistinctAlgorithm.HYPERLOGLOG, @@ -123,8 +124,8 @@ public class OperatorStatsAccumulatorTest extends AbstractTestBase { JobExecutionResult result = env.execute(); OperatorStatistics globalStats = result.getAccumulatorResult(ACCUMULATOR_NAME); - System.out.println("Global Stats"); - System.out.println(globalStats.toString()); +// System.out.println("Global Stats"); +// System.out.println(globalStats.toString()); OperatorStatistics merged = null; @@ -178,6 +179,7 @@ public class OperatorStatsAccumulatorTest extends AbstractTestBase { String inputFile = createTempFile("datapoints.txt", input); ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment(); + env.getConfig().disableSysoutLogging(); OperatorStatisticsConfig operatorStatisticsConfig = new OperatorStatisticsConfig(false); @@ -191,8 +193,8 @@ public class OperatorStatsAccumulatorTest extends AbstractTestBase { JobExecutionResult result = env.execute(); OperatorStatistics globalStats = result.getAccumulatorResult(ACCUMULATOR_NAME); - System.out.println("Global Stats"); - System.out.println(globalStats.toString()); +// System.out.println("Global Stats"); +// System.out.println(globalStats.toString()); Assert.assertTrue("Min value for accumulator should not be null",globalStats.getMin()!=null); Assert.assertTrue("Max value for accumulator should not be null",globalStats.getMax()!=null); @@ -216,6 +218,7 @@ public class OperatorStatsAccumulatorTest extends AbstractTestBase { String inputFile = createTempFile("datapoints.txt", input); ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment(); + env.getConfig().disableSysoutLogging(); OperatorStatisticsConfig operatorStatisticsConfig = new OperatorStatisticsConfig(false); @@ -230,8 +233,8 @@ public class OperatorStatsAccumulatorTest extends AbstractTestBase { JobExecutionResult result = env.execute(); OperatorStatistics globalStats = result.getAccumulatorResult(ACCUMULATOR_NAME); - System.out.println("Global Stats"); - System.out.println(globalStats.toString()); +// System.out.println("Global Stats"); +// System.out.println(globalStats.toString()); Assert.assertTrue("Count Distinct for accumulator should not be null",globalStats.countDistinct!=null); } @@ -254,6 +257,7 @@ public class OperatorStatsAccumulatorTest extends AbstractTestBase { String inputFile = createTempFile("datapoints.txt", input); ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment(); + env.getConfig().disableSysoutLogging(); OperatorStatisticsConfig operatorStatisticsConfig = new OperatorStatisticsConfig(false); @@ -267,8 +271,8 @@ public class OperatorStatsAccumulatorTest extends AbstractTestBase { JobExecutionResult result = env.execute(); OperatorStatistics globalStats = result.getAccumulatorResult(ACCUMULATOR_NAME); - System.out.println("Global Stats"); - System.out.println(globalStats.toString()); +// System.out.println("Global Stats"); +// System.out.println(globalStats.toString()); Assert.assertTrue("Count Distinct for accumulator should not be null",globalStats.heavyHitter!=null); }
