flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From m..@apache.org
Subject flink git commit: [FLINK-2614][scala-shell] scala shell's default execution mode is broken
Date Thu, 03 Sep 2015 09:37:53 GMT
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 <mxm@apache.org>
Authored: Thu Sep 3 11:29:37 2015 +0200
Committer: Maximilian Michels <mxm@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).")


Mime
View raw message