[05/14] flink git commit: [FLINK-1638] [streaming] RegisterState removed from datastream + CoRecordReader barrier test added

[FLINK-1638] [streaming] RegisterState removed from datastream + CoRecordReader barrier test added Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/490fa700 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/490fa700

[06/14] flink git commit: [FLINK-1638] [streaming] Barrier sync added to CoRecordReader, barrier tests

[FLINK-1638] [streaming] Barrier sync added to CoRecordReader, barrier tests Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5327d56d Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/5327d56d Diff:

[03/14] flink git commit: [FLINK-1638] [streaming] Vertex level fault tolerance and state monitor

[FLINK-1638] [streaming] Vertex level fault tolerance and state monitor Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5061edb8 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/5061edb8 Diff:

[14/14] flink git commit: [FLINK-1638] [jobmanager] Cleanups in the ExecutionGraph for streaming fault tolerance

[FLINK-1638] [jobmanager] Cleanups in the ExecutionGraph for streaming fault tolerance Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2bba2b3f Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/2bba2b3f Diff:

[01/14] flink git commit: [FLINK-1638] [streaming] Operator state checkpointing and injection prototype

Repository: flink Updated Branches: refs/heads/master b4e8350f5 - 2bba2b3f0 [FLINK-1638] [streaming] Operator state checkpointing and injection prototype Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/452c39a9 Tree:

[09/14] flink git commit: [FLINK-1638] [streaming] Added persistent Kafka source

[FLINK-1638] [streaming] Added persistent Kafka source Exposed state registering in the public API Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/09aa841d Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/09aa841d

flink git commit: [docs] fix anchor positions of headlines, reduce size of nav bar

Repository: flink Updated Branches: refs/heads/master b0a57c32f - b4e8350f5 [docs] fix anchor positions of headlines, reduce size of nav bar Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b4e8350f Tree:

flink git commit: [FLINK-1628] [optimizer] Fix partitioning properties for Joins and CoGroups.

Repository: flink Updated Branches: refs/heads/release-0.8 d573926ab - 88c7ea256 [FLINK-1628] [optimizer] Fix partitioning properties for Joins and CoGroups. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/88c7ea25 Tree:

[5/5] flink git commit: [FLINK-1619] [FLINK-1620] Grouped sliding prereducers added for Time and Count

[FLINK-1619] [FLINK-1620] Grouped sliding prereducers added for Time and Count Closes #465 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2522f028 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/2522f028 Diff:

[1/5] flink git commit: [FLINK-1643] [streaming] Auto detection of tumbling policies added + WindowedDataStream refactor

Repository: flink Updated Branches: refs/heads/master 2bba2b3f0 - 2522f028b [FLINK-1643] [streaming] Auto detection of tumbling policies added + WindowedDataStream refactor Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: