для получения дополнительной информации.

аюсь прочитать файл, используя:

final ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();
DataSet<String> line = env.readTextFile("file:///pathtofile/myfile.txt");

Я получаю следующую ошибку:

java.lang.NoSuchMethodError: org.apache.flink.api.common.io.DelimitedInputFormat: method <init>(Lorg/apache/flink/core/fs/Path;)V not found

Я использую Flink версии 1.3.2, Java версии "1.8.0_91"

Ответы на вопрос(6)

Ваш ответ на вопрос