Как запустить оболочку Flink Scala в режиме пряжи - PullRequest
Новая
       8

Как запустить оболочку Flink Scala в режиме пряжи

0 голосов
/ 04 июня 2018

Я пытаюсь запустить оболочку Flink Scala в режиме пряжи, но нажимаю следующую ошибку:

Это команда, которую я использую, Я что-то пропускаю?Спасибо 

bin/start-scala-shell.sh yarn -n 2


Starting Flink Shell:
2018-06-04 17:31:18,166 INFO  org.apache.flink.configuration.GlobalConfiguration            - Loading configuration property: jobmanager.rpc.address, localhost
2018-06-04 17:31:18,168 INFO  org.apache.flink.configuration.GlobalConfiguration            - Loading configuration property: jobmanager.rpc.port, 6123
2018-06-04 17:31:18,168 INFO  org.apache.flink.configuration.GlobalConfiguration            - Loading configuration property: jobmanager.heap.mb, 1024
2018-06-04 17:31:18,168 INFO  org.apache.flink.configuration.GlobalConfiguration            - Loading configuration property: taskmanager.heap.mb, 1024
2018-06-04 17:31:18,169 INFO  org.apache.flink.configuration.GlobalConfiguration            - Loading configuration property: taskmanager.numberOfTaskSlots, 1
2018-06-04 17:31:18,169 INFO  org.apache.flink.configuration.GlobalConfiguration            - Loading configuration property: parallelism.default, 1
2018-06-04 17:31:18,169 INFO  org.apache.flink.configuration.GlobalConfiguration            - Loading configuration property: rest.port, 8081
Exception in thread "main" java.lang.UnsupportedOperationException: Can't deploy a standalone cluster.
    at org.apache.flink.client.deployment.StandaloneClusterDescriptor.deploySessionCluster(StandaloneClusterDescriptor.java:57)
    at org.apache.flink.client.deployment.StandaloneClusterDescriptor.deploySessionCluster(StandaloneClusterDescriptor.java:31)
    at org.apache.flink.api.scala.FlinkShell$.deployNewYarnCluster(FlinkShell.scala:272)
    at org.apache.flink.api.scala.FlinkShell$.fetchConnectionInfo(FlinkShell.scala:164)
    at org.apache.flink.api.scala.FlinkShell$.liftedTree1$1(FlinkShell.scala:194)
    at org.apache.flink.api.scala.FlinkShell$.startShell(FlinkShell.scala:193)
    at org.apache.flink.api.scala.FlinkShell$.main(FlinkShell.scala:135)
    at org.apache.flink.api.scala.FlinkShell.main(FlinkShell.scala)

1 Ответ

0 голосов
/ 04 июня 2018

Какую версию flink вы используете?Если это 1.5.0, есть известная проблема, что оболочка scala не работает с режимом flip-6 (включен по умолчанию).Вы можете попробовать запустить его в устаревшем режиме .Уже есть открытая JIRA FLINK-8795 для ее исправления.

...