Класс не разрешается при развертывании локального кластера - PullRequest
Новая
       8

Класс не разрешается при развертывании локального кластера

0 голосов
/ 03 июля 2019

Я хочу развернуть мое приложение flink в локальном кластере.Я начал свой локальный узел с ./start-cluster-sh, а затем попытался выполнить развертывание из кода.Обратите внимание, что при развертывании jar приложения через командную строку проблем не возникает.

Я пробовал метод createLocalEnvironment, он работает нормально, но приложение не развернуто в моем локальном кластере. 

 StreamExecutionEnvironment environment = StreamExecutionEnvironment.createRemoteEnvironment("127.0.0.1",8081);

, 

Caused by: java.lang.ClassNotFoundException: altosis.flinkcompute.compute.Main$1
    at java.net.URLClassLoader.findClass(URLClassLoader.java:382)
    at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
    at org.apache.flink.runtime.execution.librarycache.FlinkUserCodeClassLoaders$ChildFirstClassLoader.loadClass(FlinkUserCodeClassLoaders.java:129)
    at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
    at java.lang.Class.forName0(Native Method)
    at java.lang.Class.forName(Class.java:348)
...