flink git commit: [FLINK-3225] Enforce translation to DataSetNodes

2016-02-01 Thread fhueske
Repository: flink Updated Branches: refs/heads/tableOnCalcite 7ecb70105 -> 297564646 [FLINK-3225] Enforce translation to DataSetNodes Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/29756464 Tree:

flink git commit: [FLINK-3300] fix concurrency bug in YarnJobManager

2016-02-01 Thread mxm
Repository: flink Updated Branches: refs/heads/master 086acf681 -> 2a49eaaf3 [FLINK-3300] fix concurrency bug in YarnJobManager Adds message passing between Hadoop's async resource manager client and the YarnJobManager actor. This closes #1561. Project:

flink git commit: [hotfix] Remove 'ByteArrayInputView' and replace deserialization in TypeInformationSerializationSchema with more efficient reusable buffers.

2016-02-01 Thread sewen
Repository: flink Updated Branches: refs/heads/master 67b380d61 -> 92efcd34a [hotfix] Remove 'ByteArrayInputView' and replace deserialization in TypeInformationSerializationSchema with more efficient reusable buffers. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

flink git commit: [fix] [docs] Fix typo in savepoints documentation

2016-02-01 Thread trohrmann
Repository: flink Updated Branches: refs/heads/master 92efcd34a -> 6c0a83e4f [fix] [docs] Fix typo in savepoints documentation Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6c0a83e4 Tree:

flink git commit: [hotfix] fix non-exhaustive match warning

2016-02-01 Thread mxm
Repository: flink Updated Branches: refs/heads/master 2a49eaaf3 -> ef58cf302 [hotfix] fix non-exhaustive match warning Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ef58cf30 Tree:

flink git commit: [FLINK-3281] IndexOutOfBoundsException when range partition on empty DataSet

2016-02-01 Thread chengxiang
Repository: flink Updated Branches: refs/heads/master 6c0a83e4f -> 233c0147b [FLINK-3281] IndexOutOfBoundsException when range partition on empty DataSet Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/233c0147 Tree:

[1/5] flink git commit: [FLINK-3306] [core] Fix auto-type registry util

2016-02-01 Thread sewen
Repository: flink Updated Branches: refs/heads/master ef58cf302 -> 5e2fb3cb5 [FLINK-3306] [core] Fix auto-type registry util Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c4bc47af Tree:

[4/5] flink git commit: [FLINK-3305] [core] Remove limited and inconsistent auto-magic for Joda Time

2016-02-01 Thread sewen
[FLINK-3305] [core] Remove limited and inconsistent auto-magic for Joda Time The auto-magic for Joda Time was limited to very few classes. It was intransparent what cases would be handled. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[5/5] flink git commit: [hotfix] Add deprecation message to old Key interface

2016-02-01 Thread sewen
[hotfix] Add deprecation message to old Key interface Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5e2fb3cb Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/5e2fb3cb Diff:

[2/5] flink git commit: [hotfix] Clean up warnings in Serializers util class

2016-02-01 Thread sewen
[hotfix] Clean up warnings in Serializers util class Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d902d164 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d902d164 Diff:

[3/5] flink git commit: [hotfix] [streaming] Tasks print subtask in log statements

2016-02-01 Thread sewen
[hotfix] [streaming] Tasks print subtask in log statements Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8c8f1c45 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/8c8f1c45 Diff:

[2/2] flink git commit: [FLINK-3265][tests] adapt RMQSource checkpointing test to runtime behavior

2016-02-01 Thread mxm
[FLINK-3265][tests] adapt RMQSource checkpointing test to runtime behavior The methods snapshotState and notifyCheckpointComplete are always mutually exclusive. The RMQSource relies on this but the test makes a false assumption when it calls those two methods at the same time. This closes #1569.

[1/2] flink git commit: Revert "[FLINK-3265] [rabbitmq] Fix concurrency bug in RabbitMQ"

2016-02-01 Thread mxm
Repository: flink Updated Branches: refs/heads/master 5e2fb3cb5 -> 67b380d61 Revert "[FLINK-3265] [rabbitmq] Fix concurrency bug in RabbitMQ" This reverts commit 6b01a89020f2de3f7710cf72336291b1e8ca8562. The introduced locks are not necessary. The checkpointing test case only needs to be