[3/8] flink git commit: [FLINK-4997] Add doc for ProcessWindowFunction

/4f047e13 Branch: refs/heads/master Commit: 4f047e13518ad2eb493903179e38eb174a37994c Parents: 86dff0e Author: Aljoscha Krettek Authored: Thu Feb 9 11:56:46 2017 +0100 Committer: Aljoscha Krettek Committed: Fri Feb 17 17:15:51 2017 +0100

[4/8] flink git commit: [hotfix] Fix trailing whitespace in WindowedStream.java

/flink/diff/82db667d Branch: refs/heads/master Commit: 82db667d319778f30244e9c4212bf3a2920f604f Parents: 09fe4b0 Author: Aljoscha Krettek Authored: Tue Feb 7 10:54:54 2017 +0100 Committer: Aljoscha Krettek Committed: Fri Feb 17 17:15:51 2017 +0100

[6/8] flink git commit: [FLINK-4997] [streaming] Introduce ProcessWindowFunction

/flink/diff/1dcb2dcd Branch: refs/heads/master Commit: 1dcb2dcd8969941988a4fc7e5488e9272dfd507e Parents: 82db667 Author: Ventura Del Monte Authored: Wed Nov 23 18:00:23 2016 +0100 Committer: Aljoscha Krettek Committed: Fri Feb 17 17:15:51 2017 +0100

[1/8] flink git commit: [FLINK-5237] Consolidate and harmonize Window Translation Tests

Repository: flink Updated Branches: refs/heads/master 09fe4b0b8 -> 5368a7d32 http://git-wip-us.apache.org/repos/asf/flink/blob/5368a7d3/flink-streaming-scala/src/test/scala/org/apache/flink/streaming/api/scala/WindowTranslationTest.scala -

[2/8] flink git commit: [FLINK-5237] Consolidate and harmonize Window Translation Tests

/repos/asf/flink/diff/5368a7d3 Branch: refs/heads/master Commit: 5368a7d32d96beb1b8298b87d9ea6d42ea306947 Parents: fe2a301 Author: Aljoscha Krettek Authored: Thu Nov 24 08:14:48 2016 +0100 Committer: Aljoscha Krettek Committed: Fri Feb 17 17:15:51 2017 +0100

[5/8] flink git commit: [FLINK-4997] [streaming] Introduce ProcessWindowFunction

http://git-wip-us.apache.org/repos/asf/flink/blob/1dcb2dcd/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperatorTest.java -- diff --git a/flink-streaming-java/src/test/java/org/ap

[8/8] flink git commit: [FLINK-4997] [streaming] Add ProcessWindowFunction to Scala API

/repos/asf/flink/diff/86dff0e6 Branch: refs/heads/master Commit: 86dff0e6d584027994dd1320845169cc8b1a83d5 Parents: 1dcb2dc Author: Ventura Del Monte Authored: Wed Nov 9 10:49:47 2016 +0100 Committer: Aljoscha Krettek Committed: Fri Feb 17 17:15:51 2017 +0100

[7/8] flink git commit: [FLINK-4997] Add ProcessWindowFunction support for .aggregate()

/repos/asf/flink/diff/fe2a3016 Branch: refs/heads/master Commit: fe2a3016f98e45d0c94a3fa1ed8c17b89a516859 Parents: 4f047e1 Author: Aljoscha Krettek Authored: Tue Feb 7 14:38:25 2017 +0100 Committer: Aljoscha Krettek Committed: Fri Feb 17 17:15:51 2017 +0100

flink git commit: [FLINK-5716] Add StreamStatusMaintainer mock in StreamSourceOperatorTest

ttp://git-wip-us.apache.org/repos/asf/flink/tree/8dac4361 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/8dac4361 Branch: refs/heads/master Commit: 8dac43613fbc937b2467b024a5f2524735fae5cf Parents: 234b905 Author: Aljoscha Krettek Authored: Thu Feb 23 14:21:24 2017 +0100 Committer: Aljos

[1/2] flink git commit: [FLINK-4856] Add MapState for keyed state

Repository: flink Updated Branches: refs/heads/master de2605ea7 -> 30c9e2b68 http://git-wip-us.apache.org/repos/asf/flink/blob/30c9e2b6/flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapKeyedStateBackend.java

[2/2] flink git commit: [FLINK-4856] Add MapState for keyed state

/30c9e2b6 Branch: refs/heads/master Commit: 30c9e2b683bf7f4776ffc23b6a860946a4429ae5 Parents: de2605e Author: xiaogang.sxg Authored: Fri Feb 17 11:19:18 2017 +0800 Committer: Aljoscha Krettek Committed: Thu Feb 23 16:56:29 2017 +0100

flink git commit: [FLINK-5743] Mark WindowedStream.aggregate() methods as PublicEvolving

git-wip-us.apache.org/repos/asf/flink/tree/5983069f Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/5983069f Branch: refs/heads/master Commit: 5983069fc2a40492b514ffa53a508cd8992c6bf2 Parents: 6f3723e Author: Aljoscha Krettek Authored: Fri Feb 24 11:27:08 2017 +0100 Committer: Aljos

[1/2] flink git commit: [FLINK-5157] [streaming] Introduce ProcessAllWindowFunction

Repository: flink Updated Branches: refs/heads/master 87b907736 -> 788b83921 http://git-wip-us.apache.org/repos/asf/flink/blob/788b8392/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/AllWindowTranslationTest.java ---

[2/2] flink git commit: [FLINK-5157] [streaming] Introduce ProcessAllWindowFunction

/asf/flink/diff/788b8392 Branch: refs/heads/master Commit: 788b839213811c6f2407ac6d54fef28dfa3d29a6 Parents: 87b9077 Author: Ventura Del Monte Authored: Wed Feb 22 14:55:17 2017 +0100 Committer: Aljoscha Krettek Committed: Tue Feb 28 14:02:56 2017 +0100

[3/5] flink git commit: [FLINK-4460] Make ProcessFunction abstract, add default onTime() method

-wip-us.apache.org/repos/asf/flink/commit/82eddcad Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/82eddcad Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/82eddcad Branch: refs/heads/master Commit: 82eddcad9674b09e90db921bc874b43b64796420 Parents: 62517ca Author: Aljoscha Krettek

[1/5] flink git commit: [FLINK-4460] Update doc: ProcessFunction now possible on DataStream

git-wip-us.apache.org/repos/asf/flink/tree/746c1efa Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/746c1efa Branch: refs/heads/master Commit: 746c1efa504267e18ddc6305712d4c3717ba4cb4 Parents: 06740fb Author: Aljoscha Krettek Authored: Mon Mar 6 12:24:46 2017 +0100 Committer: Aljoscha Kret

[5/5] flink git commit: [FLINK-4660] Allow ProcessFunction on DataStream

://git-wip-us.apache.org/repos/asf/flink/tree/0228676d Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/0228676d Branch: refs/heads/master Commit: 0228676d689b04accf1ba7d7c7f8064e121c6d88 Parents: 82eddca Author: Aljoscha Krettek Authored: Wed Mar 1 11:41:02 2017 +0100 Committer: Aljoscha

[2/5] flink git commit: [FLINK-4460] Make CoProcessFunction abstract, add default onTime() method

: Aljoscha Krettek Authored: Wed Mar 1 11:33:03 2017 +0100 Committer: Aljoscha Krettek Committed: Mon Mar 6 12:26:16 2017 +0100 -- .../api/datastream/ConnectedStreams.java| 9 - .../api/functions/co/CoProcessFunction.java

[4/5] flink git commit: [FLINK-4660] Allow CoProcessFunction on non-keyed ConnectedStreams

/commit/06740fb2 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/06740fb2 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/06740fb2 Branch: refs/heads/master Commit: 06740fb28d3f3269d040d68cbfefc5201203b60d Parents: e12f320 Author: Aljoscha Krettek Authored: Wed Mar 1 12:02:34 2017 +0100

flink git commit: [FLINK-6001] Fix ContinuousEventTimeTrigger firing without state

wip-us.apache.org/repos/asf/flink/tree/0a501e9f Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/0a501e9f Branch: refs/heads/master Commit: 0a501e9f7f56baba2905002b74746998458db007 Parents: a3627f2 Author: Aljoscha Krettek Authored: Mon Mar 13 15:04:01 2017 +0100 Committer: Aljoscha Kret

flink git commit: [FLINK-6001] Fix ContinuousEventTimeTrigger firing without state

git-wip-us.apache.org/repos/asf/flink/tree/697ede00 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/697ede00 Branch: refs/heads/release-1.2 Commit: 697ede00d044af4eb18a981fd2734fba3e112a30 Parents: 24306ad Author: Aljoscha Krettek Authored: Mon Mar 13 15:04:01 2017 +0100 Committer: Aljos

flink git commit: [FLINK-6018] Properly initialise StateDescriptor in AbstractStateBackend.getPartitionedState()

ter: Aljoscha Krettek Committed: Wed Mar 15 18:43:58 2017 +0100 -- .../streaming/state/RocksDBKeyedStateBackend.java | 6 -- .../contrib/streaming/state/RocksDBStateBackend.java| 3 ++- .../flink/runtime/st

flink git commit: [hotfix] Remove auto-boxing in ContinuousEventTimeTrigger

wip-us.apache.org/repos/asf/flink/tree/d160b5e5 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/d160b5e5 Branch: refs/heads/master Commit: d160b5e56fb40a0872a59c64d9ca3377d4cf4e86 Parents: e5057b7 Author: Aljoscha Krettek Authored: Thu Mar 16 14:11:18 2017 +0100 Committer: Aljoscha Krettek Commit

[3/3] flink git commit: [FLINK-5808] Move default parallelism to StreamingJobGraphGenerator

/repos/asf/flink/tree/9cfae899 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/9cfae899 Branch: refs/heads/master Commit: 9cfae899358e0694c3ecedae1fad20e428a1d359 Parents: 20fff32 Author: Aljoscha Krettek Authored: Fri Mar 10 13:30:21 2017 +0100 Committer: Aljoscha Krettek Committed: Fri Ma

[1/3] flink git commit: [FLINK-5808] Add proper checks in setParallelism()/setMaxParallelism()

pos/asf/flink/diff/f31a55e0 Branch: refs/heads/master Commit: f31a55e08ddb7b4bc9e47577a187bac31ad42f4b Parents: e4fbae3 Author: Aljoscha Krettek Authored: Fri Mar 10 14:35:37 2017 +0100 Committer: Aljoscha Krettek Committed: Fri Mar 17 21:34:54 2017 +0

[2/3] flink git commit: [FLINK-5808] Move max keygroup constants to ExecutionConfig

/commit/e4fbae36 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/e4fbae36 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/e4fbae36 Branch: refs/heads/master Commit: e4fbae36207c563363eed39886c24eea51d7db01 Parents: 9cfae89 Author: Aljoscha Krettek Authored: Fri Mar 10 14:37:26 2017

[02/11] flink git commit: [FLINK-4460] Add ITCase to verify watermark forwarding for side outputs

-us.apache.org/repos/asf/flink/diff/c3fc8b97 Branch: refs/heads/master Commit: c3fc8b97aaa4e46ed99d893d582cb536da98951e Parents: c2afe1b Author: Aljoscha Krettek Authored: Fri Mar 10 15:04:39 2017 +0100 Committer: Aljoscha Krettek Committed: Sat Mar 18 07:44:17 2017 +0100

[01/11] flink git commit: [FLINK-4460] Catch side output OutputTag id clashes

ttp://git-wip-us.apache.org/repos/asf/flink/tree/a0109e17 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/a0109e17 Branch: refs/heads/master Commit: a0109e17bdd125a042d8296a1b10821ea53c2e5c Parents: 709edb8 Author: Aljoscha Krettek Authored: Sat Mar 11 08:24:37 2017 +0100 Committer: Aljos

[06/11] flink git commit: [FLINK-4460] Expose OutputTag constructor that takes TypeInformation

/repos/asf/flink/diff/5a44a51a Branch: refs/heads/master Commit: 5a44a51a4b5381fb5d892e8f9f8b2add9418c363 Parents: 07a15d0 Author: Aljoscha Krettek Authored: Thu Feb 16 14:41:10 2017 +0100 Committer: Aljoscha Krettek Committed: Sat Mar 18 07:44:17 2017 +0100

[11/11] flink git commit: [FLINK-4460] Add WindowOperatorContractTest tests for late data emission

-us.apache.org/repos/asf/flink/diff/c2afe1b7 Branch: refs/heads/master Commit: c2afe1b7ba748ccdb1b4233321805f31a6465bc1 Parents: f0a58f7 Author: Aljoscha Krettek Authored: Fri Mar 10 11:42:56 2017 +0100 Committer: Aljoscha Krettek Committed: Sat Mar 18 07:44:17 2017 +0100

[07/11] flink git commit: [FLINK-4460] Add proper side output API for Scala API

/repos/asf/flink/commit/639dee3b Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/639dee3b Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/639dee3b Branch: refs/heads/master Commit: 639dee3b56c037684410bdb67390d16369fbb52c Parents: f828657 Author: Aljoscha Krettek Authored: Tue Mar 7 11

[03/11] flink git commit: [FLINK-4460] Add side outputs for ProcessFunction

/diff/f828657d Branch: refs/heads/master Commit: f828657dfe2fa96c87c3545cb0aa679d67587862 Parents: d406915 Author: Aljoscha Krettek Authored: Fri Oct 21 12:38:04 2016 -0700 Committer: Aljoscha Krettek Committed: Sat Mar 18 07:44:17 2017 +0100

[08/11] flink git commit: [FLINK-4460] Make chaining work with side outputs

/diff/d4069159 Branch: refs/heads/master Commit: d4069159c2f4f32fefae1e7491543827632ba8ea Parents: 5a44a51 Author: Aljoscha Krettek Authored: Thu Feb 16 14:09:26 2017 +0100 Committer: Aljoscha Krettek Committed: Sat Mar 18 07:44:17 2017 +0100

[10/11] flink git commit: [FLINK-4460] Add side output ITCase for multiple side out consumers

/repos/asf/flink/diff/709edb80 Branch: refs/heads/master Commit: 709edb80b8fca2d669f960b7daf983933a8a33c5 Parents: c3fc8b9 Author: Aljoscha Krettek Authored: Fri Mar 10 17:59:36 2017 +0100 Committer: Aljoscha Krettek Committed: Sat Mar 18 07:44:17 2017 +0100

[04/11] flink git commit: [FLINK-4460] Add support for side outputs

: Chen Qin Authored: Fri Oct 21 12:38:04 2016 -0700 Committer: Aljoscha Krettek Committed: Sat Mar 18 07:44:17 2017 +0100 -- .../flink/api/common/typeinfo/TypeHint.java | 9 +- .../java/org/apache/flink/util/OutputTag.java

[05/11] flink git commit: [FLINK-4460] Provide late-data output for window operations

/07a15d0e Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/07a15d0e Branch: refs/heads/master Commit: 07a15d0e1647c79ae010ca6df5b1830a4087dd56 Parents: e134d27 Author: Chen Qin Authored: Wed Mar 1 15:36:17 2017 +0100 Committer: Aljoscha Krettek Committed: Sat Mar 18 07:44:17 2017 +0100

[09/11] flink git commit: [FLINK-4460] Add documentation for side outputs

/f0a58f78 Branch: refs/heads/master Commit: f0a58f7882ba6ed5081769b5006b3c81b3508ae5 Parents: 639dee3 Author: Aljoscha Krettek Authored: Tue Mar 7 12:06:01 2017 +0100 Committer: Aljoscha Krettek Committed: Sat Mar 18 07:44:17 2017 +0100

[2/3] flink git commit: [FLINK-5808] Move max keygroup constants to ExecutionConfig

/commit/d3b275f4 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d3b275f4 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/d3b275f4 Branch: refs/heads/release-1.2 Commit: d3b275f4b7d49b67013e26d1f29a065d3131c664 Parents: b563f0a Author: Aljoscha Krettek Authored: Fri Mar 10 14:37:26

[3/3] flink git commit: [FLINK-5808] Add proper checks in setParallelism()/setMaxParallelism()

: 99fb80be773499907d379553010dd999214f64fb Parents: d3b275f Author: Aljoscha Krettek Authored: Fri Mar 10 14:35:37 2017 +0100 Committer: Aljoscha Krettek Committed: Sat Mar 18 07:43:42 2017 +0100 -- .../flink/api/common/ExecutionConfig.java

[1/3] flink git commit: [FLINK-5808] Move default parallelism to StreamingJobGraphGenerator

ttp://git-wip-us.apache.org/repos/asf/flink/commit/b563f0ae Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/b563f0ae Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/b563f0ae Branch: refs/heads/release-1.2 Commit: b563f0ae2e7b7233e29e03fbb2cf18b0d853c0ca Parents: edd1065 Author: Alj

[2/3] flink git commit: [FLINK-5929] Allow Access to Per-Window State in ProcessWindowFunction

-us.apache.org/repos/asf/flink/diff/fad201bf Branch: refs/heads/master Commit: fad201bfb0b1f2757f68f7b3ffaf97a486eb93e8 Parents: 5c37e55 Author: Seth Wiesman Authored: Sun Mar 5 23:07:18 2017 -0500 Committer: Aljoscha Krettek Committed: Sat Mar 25 16:59:17 2017 +0100

[3/3] flink git commit: [hotfix] Make GC test more strict in WindowOperatorContractTest

/repos/asf/flink/diff/662ed33d Branch: refs/heads/master Commit: 662ed33d8f5baed95035b8176daf95a1caa0b278 Parents: fad201b Author: Aljoscha Krettek Authored: Sat Mar 25 16:59:31 2017 +0100 Committer: Aljoscha Krettek Committed: Sat Mar 25 16:59:31 2017 +0100

[1/3] flink git commit: [FLINK-5929] Allow Access to Per-Window State in ProcessWindowFunction

Repository: flink Updated Branches: refs/heads/master 5c37e55c8 -> 662ed33d8 http://git-wip-us.apache.org/repos/asf/flink/blob/fad201bf/flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/windowing/functions/InternalWindowFunctionTest.java ---

[2/3] flink git commit: Revert "[FLINK-5808] Move max keygroup constants to ExecutionConfig"

/repos/asf/flink/commit/fd98e8b8 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/fd98e8b8 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/fd98e8b8 Branch: refs/heads/release-1.2 Commit: fd98e8b8c059b54f82d80d251b72b80459f8fee5 Parents: 04a1d6b Author: Aljoscha Krettek Authored: Mon A

[3/3] flink git commit: Revert "[FLINK-5808] Add proper checks in setParallelism()/setMaxParallelism()"

apache.org/repos/asf/flink/commit/04a1d6b9 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/04a1d6b9 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/04a1d6b9 Branch: refs/heads/release-1.2 Commit: 04a1d6b9331c411be1b88ffc402a5dd74dd10e7e Parents: 3c63c9e Author: Aljoscha Krettek Aut

[1/3] flink git commit: Revert "[FLINK-5808] Move default parallelism to StreamingJobGraphGenerator"

se-1.2 Commit: 3e41ed1b1e9ee30f546374206d4759e009ced39b Parents: fd98e8b Author: Aljoscha Krettek Authored: Mon Apr 3 18:40:14 2017 +0200 Committer: Aljoscha Krettek Committed: Tue Apr 4 13:42:17 2017 +0200 -- .../api/environment/LocalStreamEnv

[3/4] flink git commit: Revert "[FLINK-5808] Move default parallelism to StreamingJobGraphGenerator"

apache.org/repos/asf/flink/commit/0182141d Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/0182141d Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/0182141d Branch: refs/heads/master Commit: 0182141d41be52ae0cf4a3563d4b8c6f3daca02e Parents: a13750c Author: Aljoscha Krettek Authored:

[1/4] flink git commit: [FLINK-6294] Add close without input test for BucketingSink

nts: 9d3f127 Author: Aljoscha Krettek Authored: Tue Apr 18 15:00:41 2017 +0200 Committer: Aljoscha Krettek Committed: Tue Apr 18 17:42:05 2017 +0200 -- .../connectors/fs/bucketing/BucketingSinkTest.java | 13 + 1 f

[4/4] flink git commit: Revert "[FLINK-5808] Move max keygroup constants to ExecutionConfig"

/repos/asf/flink/commit/a13750cc Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/a13750cc Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/a13750cc Branch: refs/heads/master Commit: a13750ccf7bf2fc8c15746d891d8d6959ea073ad Parents: 5b4dd41 Author: Aljoscha Krettek Authored: Tue Apr

[2/4] flink git commit: Revert "[FLINK-5808] Add proper checks in setParallelism()/setMaxParallelism()"

apache.org/repos/asf/flink/commit/5b4dd411 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/5b4dd411 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/5b4dd411 Branch: refs/heads/master Commit: 5b4dd4117d111514590dfb1bd0a1f4bba3db2b9e Parents: 04aae30 Author: Aljoscha Krettek Authore

flink git commit: [hotfix] Fix some typos in "concepts" doc

org/repos/asf/flink/tree/76968c63 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/76968c63 Branch: refs/heads/master Commit: 76968c6360c17d5deb4e42727c16bc1b9a891b26 Parents: 9e7c664 Author: Aljoscha Krettek Authored: Mon Apr 4 10:44:35 2016 +0200 Committer: Aljoscha Krettek Committed: Mo

flink git commit: [hotfix] Fix some typos in "concepts" doc

che.org/repos/asf/flink/tree/f40ffd7d Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/f40ffd7d Branch: refs/heads/release-1.0 Commit: f40ffd7daef5684c6c405f6e3938a7883794b9dd Parents: 9e5f59a Author: Aljoscha Krettek Authored: Mon Apr 4 10:44:35 2016 +0200 Committer: Aljoscha Krettek C

[4/4] flink git commit: [FLINK-3174] Add MergingWindowAssigner and SessionWindows

-us.apache.org/repos/asf/flink/commit/6cd8ceb1 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/6cd8ceb1 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/6cd8ceb1 Branch: refs/heads/master Commit: 6cd8ceb10c841827cf89b74ecf5a0495a6933d53 Parents: 505512d Author: Aljoscha Krettek Authored: Tue

[1/4] flink git commit: [FLINK-3614] Remove Non-Keyed Window Operator

Repository: flink Updated Branches: refs/heads/master b1e508645 -> 6cd8ceb10 http://git-wip-us.apache.org/repos/asf/flink/blob/505512db/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/functions/InternalSingleValueWindowFunction.java

[3/4] flink git commit: [FLINK-3174] Add MergingWindowAssigner and SessionWindows

http://git-wip-us.apache.org/repos/asf/flink/blob/6cd8ceb1/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperator.java -- diff --git a/flink-streaming-java/src/main/java/org/apache

[2/4] flink git commit: [FLINK-3614] Remove Non-Keyed Window Operator

/tree/505512db Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/505512db Branch: refs/heads/master Commit: 505512dbe461b9840dde6197c71dbb90b49c0495 Parents: b1e5086 Author: Aljoscha Krettek Authored: Wed Mar 16 15:59:05 2016 +0100 Committer: Aljoscha Krettek Committed: Tue Apr 5 16:26:54

flink git commit: [FLINK-3637] Refactored output stream handling from RollingSink.

mit: b3186b6a109e4cd43216799e2f1c63ad8646bdab Parents: 24f89b7 Author: Lasse Dalegaard Authored: Tue Mar 22 10:24:11 2016 +0100 Committer: Aljoscha Krettek Committed: Wed Apr 6 11:31:23 2016 +0200 -- .../streaming/connectors

flink git commit: [hotfix] Fix EvictingWindowOperator to work with MergingWindowAssigner

git-wip-us.apache.org/repos/asf/flink/tree/a3415028 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/a3415028 Branch: refs/heads/master Commit: a3415028dd7bec24e170c0d8a3531b19c021aaaf Parents: 02ef68f Author: Aljoscha Krettek Authored: Wed Apr 6 18:12:34 2016 +0200 Committer: Aljoscha Kret

flink git commit: [FLINK-3711][docs] Documentation of Scala fold()() uses correct syntax

ter: Aljoscha Krettek Committed: Thu Apr 7 10:54:22 2016 +0200 -- docs/apis/streaming/index.md | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) -- http://git-

flink git commit: [FLINK-3711][docs] Documentation of Scala fold()() uses correct syntax

530 Committer: Aljoscha Krettek Committed: Thu Apr 7 10:55:12 2016 +0200 -- docs/apis/streaming/index.md | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) -- h

flink git commit: [FLINK-3654] Disable Write-Ahead-Log in RocksDB State

wip-us.apache.org/repos/asf/flink/tree/3fe53d39 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/3fe53d39 Branch: refs/heads/master Commit: 3fe53d39fe452aecaa7b075b94b0ca33a1d71864 Parents: e5b93da Author: Aljoscha Krettek Authored: Tue Mar 22 18:08:15 2016 +0100 Committer: Aljoscha Krettek Committed:

flink git commit: [FLINK-3654] Disable Write-Ahead-Log in RocksDB State

wip-us.apache.org/repos/asf/flink/tree/17909aae Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/17909aae Branch: refs/heads/release-1.0 Commit: 17909aae775736cfef674935d8a51447a3823d3a Parents: a057465 Author: Aljoscha Krettek Authored: Tue Mar 22 18:08:15 2016 +0100 Committer: Aljoscha Kret

flink git commit: [FLINK-3688] WindowOperator.trigger() does not emit Watermark anymore

mit: a234719a25836f8c125aee27f1235caf42943b3b Parents: 9f52422 Author: Konstantin Knauf Authored: Sun Apr 3 13:57:35 2016 +0200 Committer: Aljoscha Krettek Committed: Fri Apr 8 15:50:13 2016 +0200 -- .../runtime/operators/windowing/WindowOperator.j

flink git commit: [FLINK-3688] WindowOperator.trigger() does not emit Watermark anymore

ter: Aljoscha Krettek Committed: Fri Apr 8 15:54:39 2016 +0200 -- .../runtime/operators/windowing/WindowOperator.java| 13 - 1 file changed, 8 insertions(+), 5 deleti

flink git commit: [FLINK-3730] Fix RocksDB Local Directory Initialization

wip-us.apache.org/repos/asf/flink/tree/db6528be Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/db6528be Branch: refs/heads/master Commit: db6528be00d624d6a389d5b303e565ca6b1c0f40 Parents: db85f38 Author: Aljoscha Krettek Authored: Tue Apr 12 10:46:59 2016 +0200 Committer: Aljoscha Krettek Commit

flink git commit: [FLINK-3730] Fix RocksDB Local Directory Initialization

wip-us.apache.org/repos/asf/flink/tree/ff38202b Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/ff38202b Branch: refs/heads/release-1.0 Commit: ff38202bacfbe07e91bc1b46d44e5eb46e991e79 Parents: 4f9c198 Author: Aljoscha Krettek Authored: Tue Apr 12 10:46:59 2016 +0200 Committer: Aljoscha Kret

[1/6] flink-web git commit: Add FlinkForward 2016 Announcement

org/repos/asf/flink-web/tree/7ca729a8 Diff: http://git-wip-us.apache.org/repos/asf/flink-web/diff/7ca729a8 Branch: refs/heads/asf-site Commit: 7ca729a84e1fb20dc85e2bdeadea0e216ec5c1f5 Parents: 24f3ba5 Author: Aljoscha Krettek Authored: Thu Apr 14 15:10:58 2016 +0200 Committer: Aljoscha Krettek Commit

[4/6] flink-web git commit: Rebuild Website

/blog/index.html @@ -161,6 +161,19 @@ + Flink Forward 2016 Call for Submissions Is Now Open + 14 Apr 2016 by Aljoscha Krettek (https://twitter.com/aljoscha";>@aljoscha) + + We are happy to announce that the call for submissions for Flink Forward 2016 is now o

[6/6] flink-web git commit: Rebuild Website

Branch: refs/heads/asf-site Commit: 48be7c6f24ed5cc901573ebd39047e56e48e3223 Parents: 7ca729a Author: Aljoscha Krettek Authored: Thu Apr 14 15:11:19 2016 +0200 Committer: Aljoscha Krettek Committed: Thu Apr 14 15:11:19 2016 +0200

[2/6] flink-web git commit: Rebuild Website

ow to Contribute +Contribute Code +Contribute Documentation +Improve the Website + + + + + Project + + + Project +Slides +Material +

[3/6] flink-web git commit: Rebuild Website

http://git-wip-us.apache.org/repos/asf/flink-web/blob/48be7c6f/content/news/2015/02/09/streaming-example.html -- diff --git a/content/news/2015/02/09/streaming-example.html b/content/news/2015/02/09/streaming-example.html index 77

[5/6] flink-web git commit: Rebuild Website

http://git-wip-us.apache.org/repos/asf/flink-web/blob/48be7c6f/content/blog/feed.xml -- diff --git a/content/blog/feed.xml b/content/blog/feed.xml index ef1a75c..4724a31 100644 --- a/content/blog/feed.xml +++ b/content/blog/feed.xm

flink git commit: [FLINK-3760] Fix StateDescriptor.readObject

pos/asf/flink/tree/494212b3 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/494212b3 Branch: refs/heads/master Commit: 494212b37b64b45cd777cc09fc6d3d3d8fbf5999 Parents: 1a34f21 Author: Aljoscha Krettek Authored: Thu Apr 14 16:10:06 2016 +0200 Committer: Aljoscha Krettek Committed: Thu Apr 14

flink git commit: [FLINK-3760] Fix StateDescriptor.readObject

org/repos/asf/flink/tree/aadc5fad Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/aadc5fad Branch: refs/heads/release-1.0 Commit: aadc5fad55af0e017b9fd2aab51b338e5d2d9623 Parents: ea50ed3 Author: Aljoscha Krettek Authored: Thu Apr 14 16:10:06 2016 +0200 Committer: Aljoscha Krettek Committed:

flink git commit: [hotfix] Make initial currentWatermark==Long.MIN_VALUE everywhere

wip-us.apache.org/repos/asf/flink/tree/1b93b324 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/1b93b324 Branch: refs/heads/master Commit: 1b93b32426f6cf6ef344880c4b45f78e983bd7de Parents: 50d8797 Author: Aljoscha Krettek Authored: Fri Apr 15 10:15:50 2016 +0200 Committer: Aljoscha Kret

[2/2] flink git commit: [FLINK-3718] Add Option For Completely Async Backup in RocksDB State Backend

Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/c33325e3 Branch: refs/heads/master Commit: c33325e3ffb9acecfc9c562b21a3ac703bae983d Parents: 77f1a2e Author: Aljoscha Krettek Authored: Fri Apr 8 14:58:50 2016 +0200 Committer: Aljoscha Krettek Committed: Wed Apr 20 16:06:41 2016 +0200

[1/2] flink git commit: [FLINK-3718] Add Option For Completely Async Backup in RocksDB State Backend

Repository: flink Updated Branches: refs/heads/master 77f1a2ed5 -> c33325e3f http://git-wip-us.apache.org/repos/asf/flink/blob/c33325e3/flink-contrib/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/RocksDBValueState.java

flink git commit: [FLINK-3740] Make Session Window State Checkpointed

org/repos/asf/flink/tree/f2f5bd5b Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/f2f5bd5b Branch: refs/heads/master Commit: f2f5bd5bed2f737b8418be09359691e899462184 Parents: e48a5f1 Author: Aljoscha Krettek Authored: Tue Apr 12 16:27:18 2016 +0200 Committer: Aljoscha Krettek Committed:

flink git commit: [hotfix] Disable WAL in RocksDB state "clear"

che.org/repos/asf/flink/tree/879bb1bb Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/879bb1bb Branch: refs/heads/master Commit: 879bb1bb029ed37e33adc7a655328940135cfcb3 Parents: 06bf4bf Author: Aljoscha Krettek Authored: Tue Apr 26 15:20:11 2016 +0200 Committer: Aljoscha Krettek Committe

flink git commit: [FLINK-3840] Remove Testing Files in RocksDB Backend

22c Parents: 4f5dbc2 Author: Aljoscha Krettek Authored: Thu Apr 28 10:02:26 2016 +0200 Committer: Aljoscha Krettek Committed: Thu Apr 28 10:02:26 2016 +0200 -- .../apache/flink/contrib/streaming/state/RocksDBStateBackend.java

flink git commit: [FLINK-3840] Remove Testing Files in RocksDB Backend

mit: 81c69f9ccaa386ba71473ca3619660237a313c1f Parents: 4a34f6f Author: Aljoscha Krettek Authored: Thu Apr 28 10:02:26 2016 +0200 Committer: Aljoscha Krettek Committed: Thu Apr 28 14:15:58 2016 +0200 -- .../apache/flink/contrib/streaming/st

flink git commit: [FLINK-3669] Timer coalescing across keys and cleanup of unused trigger tasks

nts: 47faa90 Author: Konstantin Knauf Authored: Tue Apr 5 19:59:19 2016 +0200 Committer: Aljoscha Krettek Committed: Tue May 3 11:36:26 2016 +0200 -- .../kafka/testutils/MockRuntimeContext.java | 5 +- .../api/operat

flink git commit: [hotfix] Fix doc link to "Working with Time"

che.org/repos/asf/flink/tree/254054fb Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/254054fb Branch: refs/heads/master Commit: 254054fbb05ee35d34b970dadd01a5bb54ea353b Parents: 23d1cba Author: Aljoscha Krettek Authored: Mon May 30 10:45:01 2016 +0200 Committer: Aljoscha Krettek Committe

[1/2] flink git commit: [FLINK-3948] Protect RocksDB cleanup by cleanup lock

mit: 61d69a229b40e52460f26804e4a36cf12e150004 Parents: cfffdc8 Author: Aljoscha Krettek Authored: Fri May 20 22:37:14 2016 +0200 Committer: Aljoscha Krettek Committed: Mon Jun 6 09:29:33 2016 +0200 -- .../flink-statebackend-rocksdb/pom.

[2/2] flink git commit: Revert "[FLINK-3960] ignore EventTimeWindowCheckpointingITCase for now"

://git-wip-us.apache.org/repos/asf/flink/tree/cfffdc87 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/cfffdc87 Branch: refs/heads/master Commit: cfffdc87e3a3ac8aa7e33db87223df7bb7c8aef9 Parents: ccc3e44 Author: Aljoscha Krettek Authored: Sat Jun 4 07:59:48 2016 +0200 Committer: Aljoscha Krettek Comm

flink git commit: [FLINK-4026] Fix code, grammar, and link issues in the Streaming documentation

Repository: flink Updated Branches: refs/heads/master 61d69a229 -> 9c561fb48 [FLINK-4026] Fix code, grammar, and link issues in the Streaming documentation Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/9c561fb4 Tree: htt

[2/4] flink git commit: [FLINK-2314] Make Streaming File Sources Persistent

http://git-wip-us.apache.org/repos/asf/flink/blob/d353895b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/environment/StreamExecutionEnvironment.java -- diff --git a/flink-streaming-java/src/main/java/org/apache

[3/4] flink git commit: [FLINK-2314] Make Streaming File Sources Persistent

: d353895ba512a5e30fb08a25643fd93f085e8456 Parents: bc19486 Author: kl0u Authored: Sun Apr 10 16:56:42 2016 +0200 Committer: Aljoscha Krettek Committed: Tue Jun 14 18:11:22 2016 +0200 -- .../flink/api/java/io/AvroInputFormat.java | 85 +++- .../io

[1/4] flink git commit: [FLINK-2314] Make Streaming File Sources Persistent

Repository: flink Updated Branches: refs/heads/master fdf436099 -> d353895ba http://git-wip-us.apache.org/repos/asf/flink/blob/d353895b/flink-tests/src/test/java/org/apache/flink/test/checkpointing/StreamFaultToleranceTestBase.java ---

[4/4] flink git commit: [FLINK-3896] Allow a StreamTask to be Externally Cancelled

Committer: Aljoscha Krettek Committed: Tue Jun 14 18:11:22 2016 +0200 -- .../apache/flink/runtime/execution/Environment.java | 11 +++ .../runtime/taskmanager/RuntimeEnvironment.java | 9 + .../org/apache

flink git commit: [FLINK-4028] Create correct TimeWindow in AbstractAlignedProcessingTimeWindowOperator

9b6 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 Authored: Mon Jun 13 12:03:32 2016 +0200 Commit

flink git commit: [FLINK-4063] Add Metrics Support for Triggers

pos/asf/flink/tree/10495852 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/10495852 Branch: refs/heads/master Commit: 10495852370fed3b7683d428f6c2cc7470b3d8ed Parents: fe0eb60 Author: Aljoscha Krettek Authored: Wed Jun 15 14:30:06 2016 +0200 Committer: Aljoscha Krettek Committed: Thu Jun

flink git commit: [FLINK-4075] ContinuousFileProcessingCheckpointITCase failed on Travis

git-wip-us.apache.org/repos/asf/flink/tree/fc4abd7f Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/fc4abd7f Branch: refs/heads/master Commit: fc4abd7fff5fa9bbfbd2196e61bf696a1dd57ad7 Parents: ec6d975 Author: kl0u Authored: Thu Jun 16 18:18:28 2016 +0200 Committer: Aljoscha Krettek Commit

[4/6] flink git commit: [FLINK-3714] Rename getCleanupTimeForWindow to cleanupTime in WindowOperator

-us.apache.org/repos/asf/flink/diff/62c5a3c0 Branch: refs/heads/master Commit: 62c5a3c07f8e10bad305316b2a1bf6d91620e9b4 Parents: 0104a92 Author: Aljoscha Krettek Authored: Mon Jun 20 16:39:52 2016 +0200 Committer: Aljoscha Krettek Committed: Tue Jun 21 12:16:26 2016 +0200

[2/6] flink git commit: [FLINK-3714] Add Support for "Allowed Lateness"

/asf/flink/tree/34a8b03d Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/34a8b03d Branch: refs/heads/master Commit: 34a8b03d2ad40db7dc00fa47923b96374c289838 Parents: f2e9c52 Author: kl0u Authored: Tue May 31 17:13:58 2016 +0200 Committer: Aljoscha Krettek Committed: Tue Jun 21 12:14:06

[5/6] flink git commit: [FLINK-3714] Extend comments in WindowOperatorTest

/repos/asf/flink/tree/87195a89 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/87195a89 Branch: refs/heads/master Commit: 87195a89ef7bfd6637eff0375bac6ded8a3ca9dc Parents: 62c5a3c Author: Aljoscha Krettek Authored: Mon Jun 20 16:40:54 2016 +0200 Committer: Aljoscha Krettek Committed: Tue Jun

[6/6] flink git commit: [hotfix] Remove "initialTime" in WindowOperatorTest

/asf/flink/commit/09e28109 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/09e28109 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/09e28109 Branch: refs/heads/master Commit: 09e28109b3707f23230ea50526b7db8aa166df15 Parents: 87195a8 Author: Aljoscha Krettek Authored: Mon Jun 20 16:44:44

[1/6] flink git commit: [FLINK-3714] Add Support for "Allowed Lateness"

Repository: flink Updated Branches: refs/heads/master f2e9c521a -> 09e28109b http://git-wip-us.apache.org/repos/asf/flink/blob/34a8b03d/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/operators/windowing/WindowOperatorTest.java -

[3/6] flink git commit: [FLINK-3714] Remove Unneccesary Timer in EventTimeTrigger

ommit: 0104a9260353e9a044504b65d480c83a7d3799fc Parents: 34a8b03 Author: Aljoscha Krettek Authored: Mon Jun 20 16:38:22 2016 +0200 Committer: Aljoscha Krettek Committed: Tue Jun 21 12:16:19 2016 +0200 -- .../api/windowing/triggers/EventTimeTrigger

flink git commit: [FLINK-4082] Add Setting for enabling/disabling LargeRecordHandler

1ba Parents: bc427d5 Author: Aljoscha Krettek Authored: Thu Jun 16 14:39:23 2016 +0200 Committer: Aljoscha Krettek Committed: Tue Jun 21 19:10:56 2016 +0200 -- .../flink/configuration/ConfigConstants.java |

<    1   2   3   4   5   6   7   8   9   10   >