Repository: flink Updated Branches: refs/heads/master 728463b49 -> f6e6924eb
[FLINK-3561] remove unused timestampsEnabled flag Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/f6e6924e Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/f6e6924e Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/f6e6924e Branch: refs/heads/master Commit: f6e6924ebe8b10d649fea4d2af039e107410d716 Parents: 728463b Author: Maximilian Michels <[email protected]> Authored: Thu Mar 10 14:31:00 2016 +0100 Committer: Maximilian Michels <[email protected]> Committed: Thu Mar 10 14:39:07 2016 +0100 ---------------------------------------------------------------------- .../main/java/org/apache/flink/api/common/ExecutionConfig.java | 4 ---- 1 file changed, 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/f6e6924e/flink-core/src/main/java/org/apache/flink/api/common/ExecutionConfig.java ---------------------------------------------------------------------- diff --git a/flink-core/src/main/java/org/apache/flink/api/common/ExecutionConfig.java b/flink-core/src/main/java/org/apache/flink/api/common/ExecutionConfig.java index ffd30e9..9642fa9 100644 --- a/flink-core/src/main/java/org/apache/flink/api/common/ExecutionConfig.java +++ b/flink-core/src/main/java/org/apache/flink/api/common/ExecutionConfig.java @@ -102,8 +102,6 @@ public class ExecutionConfig implements Serializable { private long autoWatermarkInterval = 0; - private boolean timestampsEnabled = false; - /** * @deprecated Should no longer be used because it is subsumed by RestartStrategyConfiguration */ @@ -659,7 +657,6 @@ public class ExecutionConfig implements Serializable { printProgressDuringExecution == other.printProgressDuringExecution && Objects.equals(globalJobParameters, other.globalJobParameters) && autoWatermarkInterval == other.autoWatermarkInterval && - timestampsEnabled == other.timestampsEnabled && registeredTypesWithKryoSerializerClasses.equals(other.registeredTypesWithKryoSerializerClasses) && defaultKryoSerializerClasses.equals(other.defaultKryoSerializerClasses) && registeredKryoTypes.equals(other.registeredKryoTypes) && @@ -685,7 +682,6 @@ public class ExecutionConfig implements Serializable { printProgressDuringExecution, globalJobParameters, autoWatermarkInterval, - timestampsEnabled, registeredTypesWithKryoSerializerClasses, defaultKryoSerializerClasses, registeredKryoTypes,
