flink git commit: [FLINK-3084] [streaming] FsStateBackend backs up very small state directly with the metadata.

2015-12-01 Thread sewen
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:

flink git commit: [hotfix] Declare env and insertStatement transient in DbStateBackend

2015-12-01 Thread trohrmann
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:

flink git commit: [tests] Decrease verbosity of ChaosMonkeyITCase

2015-12-01 Thread trohrmann
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:

flink git commit: [FLINK-3092] [docs] Fix Scala API quick start word count example

2015-12-01 Thread chiwanpark
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

[1/2] flink git commit: [FLINK-2624] improvements to the RabbitMQ source

2015-12-01 Thread mxm
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.

[2/2] flink git commit: [FLINK-2624] RabbitMQSource uses MessageAcknowledgingSourceBase

2015-12-01 Thread mxm
[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: