В настоящее время мы используем Flink 1.9.2 в нашем проекте и отправляем задание из jar.
ниже - это тот код, который мы используем в настоящее время для отправки задания:
clusterClient.setDetached(true);
clusterClient.run(packagedProgram, Integer.valueOf(params.get(Constants.PARAMS_PARALLELISM)));
После обновления до Flink 1.11.1 вышеуказанный фрагмент кода не работает. Также новый конструктор packagedProgram ожидает "Configuration" в качестве параметра.
Как мы можем изменить это, чтобы оно работало для наших нужд?