You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by mx...@apache.org on 2015/09/03 11:37:53 UTC
flink git commit: [FLINK-2614][scala-shell] scala shell's default
execution mode is broken
Repository: flink
Updated Branches:
refs/heads/master 53752163f -> 14ba66baf
[FLINK-2614][scala-shell] scala shell's default execution mode is broken
- call new start() method of FlinkMiniCluster
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/14ba66ba
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/14ba66ba
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/14ba66ba
Branch: refs/heads/master
Commit: 14ba66bafffc3f74a3d89ba2717de0ae9b407041
Parents: 5375216
Author: Maximilian Michels <mx...@apache.org>
Authored: Thu Sep 3 11:29:37 2015 +0200
Committer: Maximilian Michels <mx...@apache.org>
Committed: Thu Sep 3 11:35:44 2015 +0200
----------------------------------------------------------------------
.../src/main/scala/org.apache.flink/api/scala/FlinkShell.scala | 1 +
1 file changed, 1 insertion(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/14ba66ba/flink-staging/flink-scala-shell/src/main/scala/org.apache.flink/api/scala/FlinkShell.scala
----------------------------------------------------------------------
diff --git a/flink-staging/flink-scala-shell/src/main/scala/org.apache.flink/api/scala/FlinkShell.scala b/flink-staging/flink-scala-shell/src/main/scala/org.apache.flink/api/scala/FlinkShell.scala
index ad0f655..25ab492 100644
--- a/flink-staging/flink-scala-shell/src/main/scala/org.apache.flink/api/scala/FlinkShell.scala
+++ b/flink-staging/flink-scala-shell/src/main/scala/org.apache.flink/api/scala/FlinkShell.scala
@@ -67,6 +67,7 @@ object FlinkShell {
val (host,port) = if (userHost == "none" || userPort == -1 ) {
println("Creating new local server")
cluster = new LocalFlinkMiniCluster(new Configuration, false)
+ cluster.start()
("localhost",cluster.getLeaderRPCPort)
} else {
println(s"Connecting to remote server (host: $userHost, port: $userPort).")