flink git commit: [FLINK-2385] [scala api] Add parenthesis to 'distinct' transformation.

2015-07-23 Thread sewen
Repository: flink Updated Branches: refs/heads/master 45428 -> 5d475f887 [FLINK-2385] [scala api] Add parenthesis to 'distinct' transformation. This closes #933 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5d475f88

[5/6] flink git commit: [FLINK-2332] [runtime] Adds leader session IDs and registration session IDs to JobManager and TaskManager messages.

2015-07-23 Thread trohrmann
http://git-wip-us.apache.org/repos/asf/flink/blob/4542/flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/RuntimeEnvironment.java -- diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/R

[6/6] flink git commit: [FLINK-2332] [runtime] Adds leader session IDs and registration session IDs to JobManager and TaskManager messages.

2015-07-23 Thread trohrmann
[FLINK-2332] [runtime] Adds leader session IDs and registration session IDs to JobManager and TaskManager messages. Refactors Flink's actor traits to support stackable traits Refactored Flink's actors to use a factory method to generate messages Replaced ActorRef with InstanceGateway in Task, R

[3/6] flink git commit: [FLINK-2332] [runtime] Adds leader session IDs and registration session IDs to JobManager and TaskManager messages.

2015-07-23 Thread trohrmann
http://git-wip-us.apache.org/repos/asf/flink/blob/4542/flink-runtime/src/test/java/org/apache/flink/runtime/instance/InstanceManagerTest.java -- diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/instance/Instan

[1/6] flink git commit: [FLINK-2332] [runtime] Adds leader session IDs and registration session IDs to JobManager and TaskManager messages.

2015-07-23 Thread trohrmann
Repository: flink Updated Branches: refs/heads/master fa78be6df -> 45428 http://git-wip-us.apache.org/repos/asf/flink/blob/4542/flink-yarn/src/main/scala/org/apache/flink/yarn/ApplicationMasterActor.scala -- diff --git

[2/6] flink git commit: [FLINK-2332] [runtime] Adds leader session IDs and registration session IDs to JobManager and TaskManager messages.

2015-07-23 Thread trohrmann
http://git-wip-us.apache.org/repos/asf/flink/blob/4542/flink-runtime/src/test/scala/org/apache/flink/runtime/jobmanager/JobManagerITCase.scala -- diff --git a/flink-runtime/src/test/scala/org/apache/flink/runtime/jobmanager/Jo

[4/6] flink git commit: [FLINK-2332] [runtime] Adds leader session IDs and registration session IDs to JobManager and TaskManager messages.

2015-07-23 Thread trohrmann
http://git-wip-us.apache.org/repos/asf/flink/blob/4542/flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskManager.scala -- diff --git a/flink-runtime/src/main/scala/org/apache/flink/runtime/taskmanager/TaskM

flink git commit: [FLINK-2400] [tests] Improve error message on unexpected TaskTest message

2015-07-23 Thread uce
Repository: flink Updated Branches: refs/heads/release-0.9 633276139 -> d71e65b8b [FLINK-2400] [tests] Improve error message on unexpected TaskTest message Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d71e65b8 Tree: htt

flink git commit: [FLINK-2400] [tests] Improve error message on unexpected TaskTest message

2015-07-23 Thread uce
Repository: flink Updated Branches: refs/heads/master c52e753a8 -> fa78be6df [FLINK-2400] [tests] Improve error message on unexpected TaskTest message Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/fa78be6d Tree: http://g

[2/3] flink git commit: [FLINK-2357] [web dashboard] New dashboard backend server supports requests from old web server as well.

2015-07-23 Thread sewen
http://git-wip-us.apache.org/repos/asf/flink/blob/c52e753a/flink-runtime-web/web-dashboard/web/js/index.js -- diff --git a/flink-runtime-web/web-dashboard/web/js/index.js b/flink-runtime-web/web-dashboard/web/js/index.js index 966

[3/3] flink git commit: [FLINK-2357] [web dashboard] New dashboard backend server supports requests from old web server as well.

2015-07-23 Thread sewen
[FLINK-2357] [web dashboard] New dashboard backend server supports requests from old web server as well. Also moves TestRunner to test scope. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c52e753a Tree: http://git-wip-us.a

[1/3] flink git commit: [FLINK-2357] [web dashboard] New dashboard backend server supports requests from old web server as well.

2015-07-23 Thread sewen
Repository: flink Updated Branches: refs/heads/master 4473db64c -> c52e753a8 http://git-wip-us.apache.org/repos/asf/flink/blob/c52e753a/flink-runtime/src/main/scala/org/apache/flink/runtime/jobmanager/JobManager.scala -- diff -

flink git commit: [docs] Fixes broken links on the setup_quickstart.html site

2015-07-23 Thread trohrmann
Repository: flink Updated Branches: refs/heads/master 0c538915b -> 4473db64c [docs] Fixes broken links on the setup_quickstart.html site Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/4473db64 Tree: http://git-wip-us.apac