Apache Flink Kubernetes Работа Аргументы - PullRequest
Новая
       11

Apache Flink Kubernetes Работа Аргументы

0 голосов
/ 09 октября 2018

Я пытаюсь настроить кластер (Apache Flink 1.6.1) с Kubernetes и получаю следующую ошибку при запуске задания на нем: 

2018-10-09 14:29:43.212 [main] INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint  - --------------------------------------------------------------------------------
2018-10-09 14:29:43.214 [main] INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint  - Registered UNIX signal handlers for [TERM, HUP, INT]
Exception in thread "main" java.lang.NoSuchMethodError: org.apache.flink.runtime.entrypoint.ClusterConfiguration.<init>(Ljava/lang/String;Ljava/util/Properties;[Ljava/lang/String;)V
    at org.apache.flink.runtime.entrypoint.EntrypointClusterConfiguration.<init>(EntrypointClusterConfiguration.java:37)
    at org.apache.flink.container.entrypoint.StandaloneJobClusterConfiguration.<init>(StandaloneJobClusterConfiguration.java:41)
    at org.apache.flink.container.entrypoint.StandaloneJobClusterConfigurationParserFactory.createResult(StandaloneJobClusterConfigurationParserFactory.java:78)
    at org.apache.flink.container.entrypoint.StandaloneJobClusterConfigurationParserFactory.createResult(StandaloneJobClusterConfigurationParserFactory.java:42)
    at org.apache.flink.runtime.entrypoint.parser.CommandLineParser.parse(CommandLineParser.java:55)
    at org.apache.flink.container.entrypoint.StandaloneJobClusterEntryPoint.main(StandaloneJobClusterEntryPoint.java:153)

Мое задание принимает файл конфигурации (файл.свойства) в качестве параметра.Это прекрасно работает в автономном режиме, но, очевидно, кластер Kubernetes не может разобрать его

job-cluster-job.yaml: 

args: ["job-cluster", "--job-classname", "com.test.Abcd", "-Djobmanager.rpc.address=flink-job-cluster",
       "-Dparallelism.default=1", "-Dblob.server.port=6124", "-Dquery.server.ports=6125", "file.properties"]

Как это исправить?

Обновление:Задание было построено для Apache 1.4.2, и это может быть проблемой, если разобраться в этом.

1 Ответ

0 голосов
/ 10 октября 2018

Задание было построено для 1.4.2, класс с ошибкой (EntrypointClusterConfiguration.java) был добавлен в 1.6.1 (https://github.com/apache/flink/commit/ab9bd87e521d19db7c7d783268a3532d2e876a5d#diff-d1169e00afa40576ea8e4f3c472cf858), похоже, поэтому возникла проблема. Мы обновили зависимости задания доуказывают на новую версию 1.6.1, и аргументы анализируются правильно.

...