提交 14ba66ba 编写于 作者: M Maximilian Michels

[FLINK-2614][scala-shell] scala shell's default execution mode is broken

- call new start() method of FlinkMiniCluster
上级 53752163
......@@ -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).")
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册