flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rmetz...@apache.org
Subject flink git commit: [FLINK-3660][hotfix] Add missing default value in ConfigConstants
Date Fri, 14 Oct 2016 13:19:14 GMT
Repository: flink
Updated Branches:
  refs/heads/master 436c3335b -> 5dc624bf8


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


Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5dc624bf
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/5dc624bf
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/5dc624bf

Branch: refs/heads/master
Commit: 5dc624bf816093ca0c240c7bcfe37841605ce592
Parents: 436c333
Author: Robert Metzger <rmetzger@apache.org>
Authored: Fri Oct 14 15:18:09 2016 +0200
Committer: Robert Metzger <rmetzger@apache.org>
Committed: Fri Oct 14 15:18:19 2016 +0200

----------------------------------------------------------------------
 .../java/org/apache/flink/configuration/ConfigConstants.java   | 6 ++++++
 .../flink/streaming/api/operators/AbstractStreamOperator.java  | 2 +-
 2 files changed, 7 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/5dc624bf/flink-core/src/main/java/org/apache/flink/configuration/ConfigConstants.java
----------------------------------------------------------------------
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
index 3fe0306..a828281 100644
--- 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
*/

http://git-wip-us.apache.org/repos/asf/flink/blob/5dc624bf/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperator.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperator.java
b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperator.java
index 77e4d9a..167dfb0 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperator.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/AbstractStreamOperator.java
@@ -134,7 +134,7 @@ public abstract class AbstractStreamOperator<OUT>
 		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;
 		}
 


Mime
View raw message