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:
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:
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:
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:
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:
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:
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:
[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:
[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:
[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:
[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:
[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.
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
13 matches
Mail list logo