flink git commit: [FLINK-2226][YARN] fail application on failed single-job cluster job

2015-06-16 Thread mxm
Repository: flink Updated Branches: refs/heads/master 1bd0af738 - 46ad40588 [FLINK-2226][YARN] fail application on failed single-job cluster job Failing jobs executed in the YARN cluster mode leave the application container in the SUCCEEDED final state. While for long-running Flink YARN

[3/3] flink git commit: [FLINK-2120][runtime] rename AbstractJobVertex to JobVertex

2015-06-16 Thread mxm
[FLINK-2120][runtime] rename AbstractJobVertex to JobVertex This closes #840. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/1bd0af73 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/1bd0af73 Diff:

[1/3] flink git commit: [FLINK-2120][runtime] rename AbstractJobVertex to JobVertex

2015-06-16 Thread mxm
Repository: flink Updated Branches: refs/heads/master 20d7e5ad3 - 1bd0af738 http://git-wip-us.apache.org/repos/asf/flink/blob/1bd0af73/flink-staging/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/IterateTest.java

flink git commit: [FLINK-2210] Table API support for aggregation on columns with null values

2015-06-16 Thread aljoscha
Repository: flink Updated Branches: refs/heads/master 46ad40588 - b59c81bc4 [FLINK-2210] Table API support for aggregation on columns with null values Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b59c81bc Tree:

flink git commit: [FLINK-2225] [scheduler] Excludes static code paths from co-location constraint to avoid scheduling problems

2015-06-16 Thread trohrmann
Repository: flink Updated Branches: refs/heads/master d38154129 - 5374ba97c [FLINK-2225] [scheduler] Excludes static code paths from co-location constraint to avoid scheduling problems This closes #843. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit:

[2/2] flink git commit: [legal] Updates LICENSE/NOTICE file of source and binary distribution

2015-06-16 Thread trohrmann
[legal] Updates LICENSE/NOTICE file of source and binary distribution This closes #830. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6a9782af Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/6a9782af Diff:

[1/2] flink git commit: [FLINK-2225] [scheduler] Excludes static code paths from co-location constraint to avoid scheduling problems

2015-06-16 Thread trohrmann
Repository: flink Updated Branches: refs/heads/release-0.9 0a8142a99 - 6a9782afe [FLINK-2225] [scheduler] Excludes static code paths from co-location constraint to avoid scheduling problems This closes #843. Conflicts:

flink git commit: [hotfix] Removed execute() that followed print() in quickstart wordcount jobs

2015-06-16 Thread fhueske
Repository: flink Updated Branches: refs/heads/master b59c81bc4 - d38154129 [hotfix] Removed execute() that followed print() in quickstart wordcount jobs Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d3815412 Tree:

flink git commit: [hotfix] Removed execute() that followed print() in quickstart wordcount jobs

2015-06-16 Thread fhueske
Repository: flink Updated Branches: refs/heads/release-0.9 2359b49f5 - 0a8142a99 [hotfix] Removed execute() that followed print() in quickstart wordcount jobs Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0a8142a9 Tree:

[3/8] flink git commit: [FLINK-2120][runtime] rename AbstractJobVertex to JobVertex

2015-06-16 Thread mxm
[FLINK-2120][runtime] rename AbstractJobVertex to JobVertex This closes #840. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/57955d97 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/57955d97 Diff:

[2/8] flink git commit: [FLINK-2120][runtime] rename AbstractJobVertex to JobVertex

2015-06-16 Thread mxm
http://git-wip-us.apache.org/repos/asf/flink/blob/57955d97/flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/ExecutionGraphConstructionTest.java -- diff --git

[1/8] flink git commit: [FLINK-2120][runtime] rename AbstractJobVertex to JobVertex

2015-06-16 Thread mxm
Repository: flink Updated Branches: refs/heads/release-0.9 6a9782afe - 0914a7d0a http://git-wip-us.apache.org/repos/asf/flink/blob/57955d97/flink-staging/flink-streaming/flink-streaming-core/src/test/java/org/apache/flink/streaming/api/IterateTest.java

[4/8] flink git commit: [build] merge transitive notice files to shaded notices

2015-06-16 Thread mxm
[build] merge transitive notice files to shaded notices This closes #837. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/57810b53 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/57810b53 Diff:

[8/8] flink git commit: [FLINK-2210] Table API support for aggregation on columns with null values

2015-06-16 Thread mxm
[FLINK-2210] Table API support for aggregation on columns with null values Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/0914a7d0 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/0914a7d0 Diff:

[6/8] flink git commit: [FLINK-2226][YARN] fail application on failed single-job cluster job

2015-06-16 Thread mxm
[FLINK-2226][YARN] fail application on failed single-job cluster job Failing jobs executed in the YARN cluster mode leave the application container in the SUCCEEDED final state. While for long-running Flink YARN clusters where multiple jobs are run, this is fine, for single jobs it is appropriate

[5/8] flink git commit: [FLINK-2174] allow comments in 'slaves' file

2015-06-16 Thread mxm
[FLINK-2174] allow comments in 'slaves' file This closes #796. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/fa02e5f3 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/fa02e5f3 Diff:

[7/8] flink git commit: [FLINK-2203] handling null values for RowSerializer

2015-06-16 Thread mxm
[FLINK-2203] handling null values for RowSerializer This closes #831 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/adc3e0e6 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/adc3e0e6 Diff:

flink git commit: [hotfix] Some small fixups in README.md

2015-06-16 Thread uce
Repository: flink Updated Branches: refs/heads/release-0.9 a300eec63 - d147c71a4 [hotfix] Some small fixups in README.md This closes #841. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d147c71a Tree:

flink git commit: [FLINK-2219] [webfrontend] Fix IllegalArgumentException and decrease log level

2015-06-16 Thread uce
Repository: flink Updated Branches: refs/heads/release-0.9 c4f3f4886 - a300eec63 [FLINK-2219] [webfrontend] Fix IllegalArgumentException and decrease log level - Pressing the state button in the job history view (like SCHEDULED, FINISHED) sends a null (String) as group vertex ID, which

[2/3] flink git commit: [FLINK-2209] [docs] Document linking with jars not in the binary dist

2015-06-16 Thread mbalassi
[FLINK-2209] [docs] Document linking with jars not in the binary dist Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/be507951 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/be507951 Diff:

[1/3] flink git commit: [FLINK-2221] [docs] Docs for not using local filesystem on the cluster as state backup

2015-06-16 Thread mbalassi
Repository: flink Updated Branches: refs/heads/master af4481c7a - 20d7e5ad3 [FLINK-2221] [docs] Docs for not using local filesystem on the cluster as state backup This is just a clear documentation of the problem for the 0.9 release. Closes #839 Project:

flink git commit: [hotfix] Some small fixups in README.md

2015-06-16 Thread uce
Repository: flink Updated Branches: refs/heads/master f9168194e - af4481c7a [hotfix] Some small fixups in README.md This closes #841. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/af4481c7 Tree:

[1/3] flink git commit: [FLINK-2221] [docs] Docs for not using local filesystem on the cluster as state backup

2015-06-16 Thread mbalassi
Repository: flink Updated Branches: refs/heads/release-0.9 d147c71a4 - 2359b49f5 [FLINK-2221] [docs] Docs for not using local filesystem on the cluster as state backup This is just a clear documentation of the problem for the 0.9 release. Closes #839 Project:

[2/3] flink git commit: [FLINK-2209] [docs] Document linking with jars not in the binary dist

2015-06-16 Thread mbalassi
[FLINK-2209] [docs] Document linking with jars not in the binary dist Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c2b1e128 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/c2b1e128 Diff:

[3/3] flink git commit: [docs] Update obsolate cluster execution guide

2015-06-16 Thread mbalassi
[docs] Update obsolate cluster execution guide Closes #835 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2359b49f Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/2359b49f Diff: