Skip to content

Commit

Permalink
[FLINK-3561] remove unused timestampsEnabled flag
Browse files Browse the repository at this point in the history
  • Loading branch information
mxm committed Mar 10, 2016
1 parent 728463b commit f6e6924
Showing 1 changed file with 0 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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
*/
Expand Down Expand Up @@ -659,7 +657,6 @@ public boolean equals(Object obj) {
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) &&
Expand All @@ -685,7 +682,6 @@ public int hashCode() {
printProgressDuringExecution,
globalJobParameters,
autoWatermarkInterval,
timestampsEnabled,
registeredTypesWithKryoSerializerClasses,
defaultKryoSerializerClasses,
registeredKryoTypes,
Expand Down

0 comments on commit f6e6924

Please sign in to comment.