Repository: flink Updated Branches: refs/heads/master 48791c347 -> af1e03e13
Create a deep-copy of the record when changing timestamps. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/af1e03e1 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/af1e03e1 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/af1e03e1 Branch: refs/heads/master Commit: af1e03e131bbc72baa12b4ffdcde35648a41ad4d Parents: 48791c3 Author: Kostas Kloudas <[email protected]> Authored: Tue Oct 6 16:33:48 2015 +0200 Committer: Aljoscha Krettek <[email protected]> Committed: Tue Oct 6 18:21:06 2015 +0200 ---------------------------------------------------------------------- .../streaming/runtime/operators/ExtractTimestampsOperator.java | 3 --- 1 file changed, 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/af1e03e1/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/runtime/operators/ExtractTimestampsOperator.java ---------------------------------------------------------------------- diff --git a/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/runtime/operators/ExtractTimestampsOperator.java b/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/runtime/operators/ExtractTimestampsOperator.java index f79b4c3..864ca76 100644 --- a/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/runtime/operators/ExtractTimestampsOperator.java +++ b/flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/runtime/operators/ExtractTimestampsOperator.java @@ -43,9 +43,6 @@ public class ExtractTimestampsOperator<T> public ExtractTimestampsOperator(TimestampExtractor<T> extractor) { super(extractor); chainingStrategy = ChainingStrategy.ALWAYS; - - // we don't give the element to any user code, so input copy is not necessary - disableInputCopy(); } @Override
