You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by uc...@apache.org on 2015/10/21 20:41:31 UTC
flink git commit: [contrib,
tests] Disable sys out logging in operator stats tests
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 <uc...@apache.org>
Authored: Wed Oct 21 20:41:07 2015 +0200
Committer: Ufuk Celebi <uc...@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);
}