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 2016/06/15 12:33:55 UTC
flink git commit: [FLINK-4028] Create correct TimeWindow in
AbstractAlignedProcessingTimeWindowOperator
Repository: flink
Updated Branches:
refs/heads/master c4bbed9e4 -> 867be9b6a
[FLINK-4028] Create correct TimeWindow in AbstractAlignedProcessingTimeWindowOperator
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/867be9b6
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/867be9b6
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/867be9b6
Branch: refs/heads/master
Commit: 867be9b6a50f83ee3286309149bdeb71166bda05
Parents: c4bbed9
Author: Aljoscha Krettek <al...@gmail.com>
Authored: Mon Jun 13 12:03:32 2016 +0200
Committer: Aljoscha Krettek <al...@gmail.com>
Committed: Wed Jun 15 14:33:19 2016 +0200
----------------------------------------------------------------------
.../windowing/AbstractAlignedProcessingTimeWindowOperator.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/867be9b6/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/AbstractAlignedProcessingTimeWindowOperator.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/AbstractAlignedProcessingTimeWindowOperator.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/AbstractAlignedProcessingTimeWindowOperator.java
index 0a8c6b5..32c4e67 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/AbstractAlignedProcessingTimeWindowOperator.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/AbstractAlignedProcessingTimeWindowOperator.java
@@ -236,7 +236,7 @@ public abstract class AbstractAlignedProcessingTimeWindowOperator<KEY, IN, OUT,
private void computeWindow(long timestamp) throws Exception {
out.setAbsoluteTimestamp(timestamp);
panes.truncatePanes(numPanesPerWindow);
- panes.evaluateWindow(out, new TimeWindow(timestamp, timestamp + windowSize), this);
+ panes.evaluateWindow(out, new TimeWindow(timestamp - windowSize, timestamp), this);
}
// ------------------------------------------------------------------------