У меня есть программа в Apache Flink. Я тестировал и запускал его на локальной машине, и все прекрасно работает. Чтобы запустить программу на удаленном кластере, я сделал необходимые изменения, как указано в Apache Flink Official Website.Запуск программы Flink на удаленном кластере
я сделал следующие изменения:
Две точки ниже
ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();ExecutionEnvironment env = ExecutionEnvironment.createRemoteEnvironment("taskManagerName",
portNo,paralelismNo);
Фиксирующие необходимые пути для чтения файлов ввода и записи выходов ,
Сформировать тонкую баночку из программы и поставить необходимые JAR библиотеки в папку, кроме моей баночки файла проекта под названием
myproj.jar.копирование данных и библиотеки банки и myproj.jar в кластер и выполнить следующую команду на удаленном кластере:
java -cp pathToJarLib \\* -jar myproj.jar
Но, я получаю ошибку ниже и я не У меня есть ключ к решению проблемы. Не существует соответствующих файлов журналов, которые могут помочь мне в устранении этой проблемы.
Ошибка:
Exception in thread "main" java.lang.NoClassDefFoundError: org/apache/flink/api/common/functions/MapFunction at java.lang.Class.getDeclaredMethods0(Native Method) at java.lang.Class.privateGetDeclaredMethods(Class.java:2570) at java.lang.Class.getMethod0(Class.java:2813) at java.lang.Class.getMethod(Class.java:1663) at sun.launcher.LauncherHelper.getMainMethod(LauncherHelper.java:494) at sun.launcher.LauncherHelper.checkAndLoadMain(LauncherHelper.java:486) Caused by: java.lang.ClassNotFoundException: org.apache.flink.api.common.functions.MapFunction at java.net.URLClassLoader$1.run(URLClassLoader.java:366) at java.net.URLClassLoader$1.run(URLClassLoader.java:355) at java.security.AccessController.doPrivileged(Native Method) at java.net.URLClassLoader.findClass(URLClassLoader.java:354) at java.lang.ClassLoader.loadClass(ClassLoader.java:425) at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:308) at java.lang.ClassLoader.loadClass(ClassLoader.java:358) ... 6 more