flink git commit: [FLINK-3373] [build] Shade away Hadoop's HTTP Components dependency

2016-02-10 Thread sewen
Repository: flink Updated Branches: refs/heads/master aeee6efd4 -> 8ccd7544e [FLINK-3373] [build] Shade away Hadoop's HTTP Components dependency This closes #1615 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/8ccd7544

flink git commit: [FLINK-3372] Setting custom YARN application name is ignored

2016-02-10 Thread sewen
Repository: flink Updated Branches: refs/heads/release-0.10 2cd06181f -> 11bfe6f3e [FLINK-3372] Setting custom YARN application name is ignored This closes #1607 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/11bfe6f3

flink git commit: [docs] Fixed typo in Storm Compatibility page

2016-02-10 Thread mjsax
Repository: flink Updated Branches: refs/heads/master 0a63797a6 -> aeee6efd4 [docs] Fixed typo in Storm Compatibility page This closes #1618 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/aeee6efd Tree:

[6/6] flink git commit: [FLINK-3260] [runtime] Enforce terminal state of Executions

2016-02-10 Thread sewen
[FLINK-3260] [runtime] Enforce terminal state of Executions This commit fixes the problem that Executions could leave their terminal state FINISHED to transition to FAILED. Such a transition will be propagated to the ExecutionGraph where it entails JobStatus changes. Since the Execution already

[3/6] flink git commit: [hotfix] [tests] Ignore ZooKeeper logs in process tests

2016-02-10 Thread sewen
[hotfix] [tests] Ignore ZooKeeper logs in process tests Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/3a643c07 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/3a643c07 Diff:

[1/6] flink git commit: [FLINK-3341] Make 'auto.offset.reset' compatible with Kafka 0.8 and 0.9

2016-02-10 Thread sewen
Repository: flink Updated Branches: refs/heads/master 8ccd7544e -> 6968a57a1 [FLINK-3341] Make 'auto.offset.reset' compatible with Kafka 0.8 and 0.9 This closes #1597 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[2/6] flink git commit: [FLINK-3350] [tests] Increase default test Akka ask and ZooKeeper timeouts

2016-02-10 Thread sewen
[FLINK-3350] [tests] Increase default test Akka ask and ZooKeeper timeouts Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b8f40251 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/b8f40251 Diff:

[4/6] flink git commit: [hotfix] [tests] Log retry rule failures on warn level

2016-02-10 Thread sewen
[hotfix] [tests] Log retry rule failures on warn level Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/756cbaff Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/756cbaff Diff:

flink git commit: [FLINK-3107] [runtime] Start checkpoint ID counter with periodic scheduler

2016-02-10 Thread uce
Repository: flink Updated Branches: refs/heads/master 6968a57a1 -> 8df0bbacb [FLINK-3107] [runtime] Start checkpoint ID counter with periodic scheduler Problem: The job manager enables checkpoints during submission of streaming programs. This can lead to call to a call to

svn commit: r12334 - /release/flink/flink-0.10.2/

2016-02-10 Thread uce
Author: uce Date: Wed Feb 10 22:30:50 2016 New Revision: 12334 Log: Add Flink 0.10.2 release files Added: release/flink/flink-0.10.2/ release/flink/flink-0.10.2/flink-0.10.2-bin-hadoop1.tgz (with props) release/flink/flink-0.10.2/flink-0.10.2-bin-hadoop1.tgz.asc

[2/2] flink git commit: [FLINK-3384] [kafka] Add ClosableQueue for message exchanges between Kafka Threads

2016-02-10 Thread sewen
[FLINK-3384] [kafka] Add ClosableQueue for message exchanges between Kafka Threads Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/fd324ea7 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/fd324ea7 Diff:

[1/2] flink git commit: [FLINK-3371] [api-breaking] Move TriggerResult and TriggerContext to dedicated classes

2016-02-10 Thread sewen
Repository: flink Updated Branches: refs/heads/master 8df0bbacb -> fd324ea72 [FLINK-3371] [api-breaking] Move TriggerResult and TriggerContext to dedicated classes This closes #1603 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[4/4] flink git commit: [FLINK-3366] Rename @Experimental annotation to @PublicEvolving

2016-02-10 Thread fhueske
[FLINK-3366] Rename @Experimental annotation to @PublicEvolving This closes #1599 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/572855da Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/572855da Diff:

[1/4] flink git commit: [FLINK-3234] [dataSet] Add KeySelector support to sortPartition operation.

2016-02-10 Thread fhueske
Repository: flink Updated Branches: refs/heads/master 59b237b5d -> 0a63797a6 [FLINK-3234] [dataSet] Add KeySelector support to sortPartition operation. This closes #1585 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: