[10/19] flink git commit: [FLINK-4813] [test-utils] Make the hadoop-minikdc dependency optional

2017-02-19 Thread sewen
[FLINK-4813] [test-utils] Make the hadoop-minikdc dependency optional With this change, any project using flink-test-utils which also requires SecureTestEnvironment must add a dependency to hadoop-minikdc itself, e.g. in pom.xml: ... org.apache.hadoop hadoop-minikdc

[03/19] flink git commit: [FLINK-5497] [tests] Remove duplicated tests for hash tables

2017-02-19 Thread sewen
[FLINK-5497] [tests] Remove duplicated tests for hash tables This closes #3089 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/53134594 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/53134594 Diff:

[17/19] flink git commit: [hotfix] [core] Add missing @Internal annotations to classes in flink-core.

2017-02-19 Thread sewen
[hotfix] [core] Add missing @Internal annotations to classes in flink-core. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/082d40fd Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/082d40fd Diff:

[15/19] flink git commit: [FLINK-5747] [distributed coordination] Eager scheduling allocates slots and deploys tasks in bulk

2017-02-19 Thread sewen
http://git-wip-us.apache.org/repos/asf/flink/blob/f113d794/flink-runtime/src/test/java/org/apache/flink/runtime/leaderelection/LeaderChangeJobRecoveryTest.java -- diff --git

[04/19] flink git commit: [FLINK-5129] [distributed runtime] BlobCache to directly accesses Blobs from distrinbuted file system if possible

2017-02-19 Thread sewen
[FLINK-5129] [distributed runtime] BlobCache to directly accesses Blobs from distrinbuted file system if possible This closes #3084 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/9f544d83 Tree:

[05/19] flink git commit: [hotfix] [docs] Updated DC/OS setup instructions.

2017-02-19 Thread sewen
[hotfix] [docs] Updated DC/OS setup instructions. This closes #3349 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/e68ee5cb Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/e68ee5cb Diff:

[16/19] flink git commit: [FLINK-5747] [distributed coordination] Eager scheduling allocates slots and deploys tasks in bulk

2017-02-19 Thread sewen
[FLINK-5747] [distributed coordination] Eager scheduling allocates slots and deploys tasks in bulk That way, strictly topological deployment can be guaranteed. Also, many quick deploy/not-enough-resources/fail/recover cycles can be avoided in the cases where resources need some time to appear.

[12/19] flink git commit: [FLINK-5640] [build] Configure the explicit Unit Test file suffix

2017-02-19 Thread sewen
[FLINK-5640] [build] Configure the explicit Unit Test file suffix This closes #3211 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/4ce2557d Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/4ce2557d Diff:

[07/19] flink git commit: [hotfix] [core] Add missing @PublicEvolving annotations to classes in flink-core.

2017-02-19 Thread sewen
[hotfix] [core] Add missing @PublicEvolving annotations to classes in flink-core. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0aa9918c Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/0aa9918c Diff:

[13/19] flink git commit: [FLINK-5277] [tests] Add unit tests for ResultPartition#add() in case of failures

2017-02-19 Thread sewen
[FLINK-5277] [tests] Add unit tests for ResultPartition#add() in case of failures This verifies that the given network buffer is recycled as expected and that no notifiers are called upon failures to add a buffer. This closes #3309 Project: http://git-wip-us.apache.org/repos/asf/flink/repo

[02/19] flink git commit: [FLINK-5522] [storm compatibility] Move Storm LocalCluster based test to a separate class

2017-02-19 Thread sewen
[FLINK-5522] [storm compatibility] Move Storm LocalCluster based test to a separate class This fixes the problem that the Storm LocalCluster can't run with powermock This closes #3138 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[08/19] flink git commit: [FLINK-5739] [client] Fix NullPointerException in CliFrontend

2017-02-19 Thread sewen
[FLINK-5739] [client] Fix NullPointerException in CliFrontend This closes #3292 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5e32eb54 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/5e32eb54 Diff:

[01/19] flink git commit: [FLINK-5817] [tests] Use TemporaryFold to create temp files and folds for test

2017-02-19 Thread sewen
Repository: flink Updated Branches: refs/heads/master 70475b367 -> f113d7945 [FLINK-5817] [tests] Use TemporaryFold to create temp files and folds for test This closes #3341 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[06/19] flink git commit: [FLINK-5828] [distributed runtime] Fix initialization of Blob storage directories

2017-02-19 Thread sewen
[FLINK-5828] [distributed runtime] Fix initialization of Blob storage directories Flip the logic (check existence and create directory) to resolve currency problem This closes #3342 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[14/19] flink git commit: [FLINK-5812] [core] Cleanups in FileSystem (round 1)

2017-02-19 Thread sewen
[FLINK-5812] [core] Cleanups in FileSystem (round 1) - This makes the FileSystem use the 'WriteMode' (otherwise it was an unused enumeration) - Extends comments - Deprecate the method that controls the replication factor and block size Project:

[19/19] flink git commit: [FLINK-5812] [core] Cleanups in FileSystem (round 2)

2017-02-19 Thread sewen
[FLINK-5812] [core] Cleanups in FileSystem (round 2) Move the FileSystem safety net to a separate class. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5902ea0e Tree:

[09/19] flink git commit: [FLINK-5817] [test] (followup) Fix temporary folder and temp file path generation

2017-02-19 Thread sewen
[FLINK-5817] [test] (followup) Fix temporary folder and temp file path generation This makes sure the TemporaryFolder rule is already evaluated by the time the temp files are generated. This also injects a random parent directory to ensure that even for fix directory/file names, the absolute

[11/19] flink git commit: [FLINK-5669] [contrib] Change DataStreamUtils to use the loopback address (127.0.0.1) with local environments.

2017-02-19 Thread sewen
[FLINK-5669] [contrib] Change DataStreamUtils to use the loopback address (127.0.0.1) with local environments. Using loopback rather than the "local address" allows tests to run in situations where the local machine's hostname may not be resolvable in DNS (because DNS is unreacable or the

[18/19] flink git commit: [hotfix] [tests] Use random actor names in JobManagerHARecoveryTest to avoid name collisions

2017-02-19 Thread sewen
[hotfix] [tests] Use random actor names in JobManagerHARecoveryTest to avoid name collisions Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/31c26e3f Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/31c26e3f Diff:

[1/2] flink git commit: [hotfix] [docs] Updated DC/OS setup instructions.

2017-02-19 Thread sewen
Repository: flink Updated Branches: refs/heads/release-1.2 b21f9d11d -> fee020c42 [hotfix] [docs] Updated DC/OS setup instructions. This closes #3349 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/fee020c4 Tree:

[2/2] flink git commit: [FLINK-5828] [distributed runtime] Fix initialization of Blob storage directories

2017-02-19 Thread sewen
[FLINK-5828] [distributed runtime] Fix initialization of Blob storage directories Flip the logic (check existence and create directory) to resolve currency problem This closes #3342 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

buildbot success in on flink-docs-release-1.1

2017-02-19 Thread buildbot
The Buildbot has detected a restored build on builder flink-docs-release-1.1 while building . Full details are available at: https://ci.apache.org/builders/flink-docs-release-1.1/builds/211 Buildbot URL: https://ci.apache.org/ Buildslave for this Build: bb_slave3_ubuntu Build Reason: The