[3/4] flink git commit: [FLINK-1771] Add support for submitting single jobs to a detached YARN session

2015-03-31 Thread rmetzger
http://git-wip-us.apache.org/repos/asf/flink/blob/6b0d4076/flink-optimizer/src/test/java/org/apache/flink/optimizer/PropertyDataSourceTest.java -- diff --git

[4/4] flink git commit: [FLINK-1771] Add support for submitting single jobs to a detached YARN session

2015-03-31 Thread rmetzger
[FLINK-1771] Add support for submitting single jobs to a detached YARN session With this change, users can submit a Flink job to a YARN cluster without having a local client monitoring the Application Master or job. You can basically fire and forget a Flink job to YARN. For supporting this, the

flink git commit: [FLINK-1806] Improve error message when no S3 access/secret key configured

2015-03-31 Thread uce
Repository: flink Updated Branches: refs/heads/master 6b0d40764 - c0b297573 [FLINK-1806] Improve error message when no S3 access/secret key configured Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c0b29757 Tree:

flink git commit: [FLINK-1805]The class IOManagerAsync should use its own Log instance

2015-03-31 Thread hsaputra
Repository: flink Updated Branches: refs/heads/master b8aa49ce7 - 224fa94c6 [FLINK-1805]The class IOManagerAsync should use its own Log instance Although class 'IOManagerAsync' is extended from 'IOManager' in package 'org.apache.flink.runtime.io.disk.iomanager', but I think it should has its

flink git commit: [FLINK-1766]Fix the bug of equals function of FSKey

2015-03-31 Thread hsaputra
Repository: flink Updated Branches: refs/heads/master 224fa94c6 - d8c74d209 [FLINK-1766]Fix the bug of equals function of FSKey The equals function in org.apache.flink.core.fs.FileSystem.FSKey should first confirm whether obj == this, if obj is the same object.It should return true Author:

flink git commit: [FLINK-1794] [test-utils] Adds test base for scala tests and adapts existing flink-ml tests

2015-03-31 Thread trohrmann
Repository: flink Updated Branches: refs/heads/master c0b297573 - b8aa49ce7 [FLINK-1794] [test-utils] Adds test base for scala tests and adapts existing flink-ml tests [FLINK-1794] [test-utils] Adds scala docs to FlinkTestBase This closes #540. Project: