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
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
[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
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
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
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
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
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
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
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
[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
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 -
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
13 matches
Mail list logo