You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Shyam (Jira)" <ji...@apache.org> on 2021/10/20 08:40:00 UTC
[jira] [Updated] (FLINK-24601) Error in submitting the job
[ https://issues.apache.org/jira/browse/FLINK-24601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Shyam updated FLINK-24601:
---------------------------
Description:
I am new to Flink. I have done Flink 1.14.0 standalone installation in AWS server and written a simple job in java 1.8. I am new to Flink. I have done Flink 1.14.0 standalone installation in AWS server and written a simple job in java 1.8.
{code:java}
DataSet<String> set = executionEnvironment.fromCollection(text);
DataSet<String> upperCase = set.map(s -> s.toUpperCase());
upperCase.count();
executionEnvironment.execute("sample job");
{code}
When I run the code, I get the following error in Flink runtime
{code:java}
2021-10-19 16:00:51.398 WARN 14358 — [-netty-thread-1] o.a.f.c.program.rest.RestClusterClient : Attempt to submit job 'Flink Java Job at Tue Oct 19 16:00:38 IST 2021' (f38d6a987100a98662e10ada551d05b9) to 'http://xx.xx.xx.xx:8081' has failed.
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]{code}
My job is retrying to submit the job for the multiple times and finally stopped with another message
{code:java}
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){code}
Note: I checked the Flink and java version in my app and server. Everything is the same (Flink 1.4.0 & java 1.8)
was:
I am new to Flink. I have done Flink 1.14.0 standalone installation in AWS server and written a simple job in java 1.8. I am new to Flink. I have done Flink 1.14.0 standalone installation in AWS server and written a simple job in 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");```When I run the code, I get the following error in Flink runtime
2021-10-19 16:00:51.398 WARN 14358 --- [-netty-thread-1] o.a.f.c.program.rest.RestClusterClient : Attempt to submit job 'Flink Java Job at Tue Oct 19 16:00:38 IST 2021' (f38d6a987100a98662e10ada551d05b9) to 'http://xx.xx.xx.xx:8081' has failed.
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]
My job is retrying to submit the job for the multiple times and finally stopped with another message
{code:java}
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){code}
Note: I checked the flink and java version in my app and server. Everything is same (Flink 1.4.0 & java 1.8)
> Error in submitting the job
> ---------------------------
>
> Key: FLINK-24601
> URL: https://issues.apache.org/jira/browse/FLINK-24601
> Project: Flink
> Issue Type: Bug
> Reporter: Shyam
> Priority: Major
>
> I am new to Flink. I have done Flink 1.14.0 standalone installation in AWS server and written a simple job in java 1.8. I am new to Flink. I have done Flink 1.14.0 standalone installation in AWS server and written a simple job in java 1.8.
>
> {code:java}
> DataSet<String> set = executionEnvironment.fromCollection(text);
> DataSet<String> upperCase = set.map(s -> s.toUpperCase());
> upperCase.count();
> executionEnvironment.execute("sample job");
> {code}
>
> When I run the code, I get the following error in Flink runtime
>
> {code:java}
> 2021-10-19 16:00:51.398 WARN 14358 — [-netty-thread-1] o.a.f.c.program.rest.RestClusterClient : Attempt to submit job 'Flink Java Job at Tue Oct 19 16:00:38 IST 2021' (f38d6a987100a98662e10ada551d05b9) to 'http://xx.xx.xx.xx:8081' has failed.
> 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]{code}
>
>
> My job is retrying to submit the job for the multiple times and finally stopped with another message
> {code:java}
> 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){code}
> Note: I checked the Flink and java version in my app and server. Everything is the same (Flink 1.4.0 & java 1.8)
--
This message was sent by Atlassian Jira
(v8.3.4#803005)