Repository: flink
Updated Branches:
refs/heads/master cd899f3be -> d1ea365ef
[FLINK-3084] [streaming] FsStateBackend backs up very small state directly with
the metadata.
This closes #1423
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit:
Repository: flink
Updated Branches:
refs/heads/master d1ea365ef -> 19b2a8e3e
[hotfix] Declare env and insertStatement transient in DbStateBackend
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/19b2a8e3
Tree:
Repository: flink
Updated Branches:
refs/heads/master 5a3d0728f -> 31f6a744c
[tests] Decrease verbosity of ChaosMonkeyITCase
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/31f6a744
Tree:
Repository: flink
Updated Branches:
refs/heads/master 19b2a8e3e -> 5a3d0728f
[FLINK-3092] [docs] Fix Scala API quick start word count example
This closes #1424.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5a3d0728
Repository: flink
Updated Branches:
refs/heads/master 31f6a744c -> 9215b7242
[FLINK-2624] improvements to the RabbitMQ source
The RabbitMQ source may operate in three different modes:
1) Exactly-once (when checkpointed) with RabbitMQ transactions and messages with
unique correlation IDs.
[FLINK-2624] RabbitMQSource uses MessageAcknowledgingSourceBase
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b6305802
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/b6305802
Diff: