You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by al...@apache.org on 2015/10/06 18:22:35 UTC
flink git commit: Create a deep-copy of the record when changing
timestamps.
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 <kk...@gmail.com>
Authored: Tue Oct 6 16:33:48 2015 +0200
Committer: Aljoscha Krettek <al...@gmail.com>
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