0

我是 Flink 的新手。我已经在 AWS 服务器上完成了 Flink 1.14.0 的独立安装，并在 java 1.8 中编写了一个简单的工作。

DataSet<String> set = executionEnvironment.fromCollection(text);
DataSet<String> upperCase = set.map(s -> s.toUpperCase());
upperCase.count();
JobExecutionResult result = executionEnvironment.execute("sample job");

当我运行代码时，我在 Flink 运行时收到以下错误


java.util.concurrent.CompletionException: org.apache.flink.runtime.rest.ConnectionClosedException: Channel became inactive.
    at java.util.concurrent.CompletableFuture.encodeRelay(CompletableFuture.java:326) [na:1.8.0_292]
    at java.util.concurrent.CompletableFuture.completeRelay(CompletableFuture.java:338) [na:1.8.0_292]
    at java.util.concurrent.CompletableFuture.uniRelay(CompletableFuture.java:925) [na:1.8.0_292]
    at java.util.concurrent.CompletableFuture$UniRelay.tryFire(CompletableFuture.java:913) ~[na:1.8.0_292]
    at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488) [na:1.8.0_292]
    at java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1990) [na:1.8.0_292]
    at org.apache.flink.runtime.rest.RestClient$ClientHandler.channelInactive(RestClient.java:634) ~[flink-runtime-1.14.0.jar:1.14.0]

我的工作是多次重试提交工作，最后以另一条消息停止

org.apache.flink.runtime.rest.util.RestClientException: [org.apache.flink.runtime.rest.handler.RestHandlerException: The jobGraphFileName field must not be omitted or be null.
    at org.apache.flink.runtime.rest.handler.job.JobSubmitHandler.handleRequest(JobSubmitHandler.java:105)

注意：我检查了我的应用程序和服务器中的 flink 和 java 版本。一切都一样（Flink 1.4.0 & java 1.8）

4

0 回答 0