flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From u..@apache.org
Subject flink git commit: [contrib, tests] Disable sys out logging in operator stats tests
Date Wed, 21 Oct 2015 18:41:31 GMT
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 <uce@apache.org>
Authored: Wed Oct 21 20:41:07 2015 +0200
Committer: Ufuk Celebi <uce@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);
 	}


Mime
View raw message