[contrib, tests] Disable sys out logging in operator stats tests

nltran · Oct 21, 2015 · b198c33 · b198c33
1 parent 3cad56d
commit b198c33
Showing 1 changed file with 12 additions and 8 deletions.
diff --git a/...c/test/java/org/apache/flink/contrib/operatorstatistics/OperatorStatsAccumulatorTest.java b/...c/test/java/org/apache/flink/contrib/operatorstatistics/OperatorStatsAccumulatorTest.java
@@ -111,6 +111,7 @@ public void testAccumulatorAllStatistics() throws Exception {
  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 void testAccumulatorAllStatistics() throws Exception {
  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 void testAccumulatorMinMax() throws Exception {
  String inputFile = createTempFile("datapoints.txt", input);
 
  ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();
+ env.getConfig().disableSysoutLogging();
 
  OperatorStatisticsConfig operatorStatisticsConfig =
  new OperatorStatisticsConfig(false);
@@ -191,8 +193,8 @@ public void testAccumulatorMinMax() throws Exception {
  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 void testAccumulatorCountDistinctLinearCounting() throws Exception {
  String inputFile = createTempFile("datapoints.txt", input);
 
  ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();
+ env.getConfig().disableSysoutLogging();
 
  OperatorStatisticsConfig operatorStatisticsConfig =
  new OperatorStatisticsConfig(false);
@@ -230,8 +233,8 @@ public void testAccumulatorCountDistinctLinearCounting() throws Exception {
  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 void testAccumulatorHeavyHitterCountMinSketch() throws Exception {
  String inputFile = createTempFile("datapoints.txt", input);
 
  ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();
+ env.getConfig().disableSysoutLogging();
 
  OperatorStatisticsConfig operatorStatisticsConfig =
  new OperatorStatisticsConfig(false);
@@ -267,8 +271,8 @@ public void testAccumulatorHeavyHitterCountMinSketch() throws Exception {
  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);
  }