[FLINK-3660][hotfix] Add missing default value in ConfigConstants

JoeMalt · Oct 14, 2016 · 5dc624b · 5dc624b
1 parent 436c333
commit 5dc624b
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 1 deletion.
diff --git a/flink-core/src/main/java/org/apache/flink/configuration/ConfigConstants.java b/flink-core/src/main/java/org/apache/flink/configuration/ConfigConstants.java
@@ -1303,6 +1303,12 @@ public final class ConfigConstants {
 	/** Default retry delay on location lookup failures. */
 	public static final int DEFAULT_QUERYABLE_STATE_CLIENT_LOOKUP_RETRY_DELAY = 1000;
 
+	// ----------------------------- Metrics ----------------------------
+
+	/** The default number of measured latencies to maintain at each operator */
+	public static final int DEFAULT_METRICS_LATENCY_HISTORY_SIZE = 128;
+
+
 	// ----------------------------- Environment Variables ----------------------------
 
 	/** The environment variable name which contains the location of the configuration directory */

diff --git a/...g-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperator.java b/...g-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperator.java
@@ -134,7 +134,7 @@ public void setup(StreamTask<?, ?> containingTask, StreamConfig config, Output<S
 		Configuration taskManagerConfig = container.getEnvironment().getTaskManagerInfo().getConfiguration();
 		int historySize = taskManagerConfig.getInteger(ConfigConstants.METRICS_LATENCY_HISTORY_SIZE, ConfigConstants.DEFAULT_METRICS_LATENCY_HISTORY_SIZE);
 		if (historySize <= 0) {
-			LOG.warn("{} has been set to a value below 0: {}. Using default.", ConfigConstants.METRICS_LATENCY_HISTORY_SIZE, historySize);
+			LOG.warn("{} has been set to a value equal or below 0: {}. Using default.", ConfigConstants.METRICS_LATENCY_HISTORY_SIZE, historySize);
 			historySize = ConfigConstants.DEFAULT_METRICS_LATENCY_HISTORY_SIZE;
 		}