Hi Flink mailing list,
I am Ilan from Start.io data platform team, need some guidance.
We have a flow with the following use case:
* We read files from AWS S3 buckets process them on our cluster and sink
the data into files using Flink file sink.
* The jobs use always the same jar, we
know when this
version is planned to be released?
Thanks again,
Ilan.
From: David Morávek
Date: Thursday, 2 December 2021 at 17:25
To: Ilan Huchansky
Cc: user@flink.apache.org , Start.io SDP
Subject: Re: Unable to create new native thread error
Hi Ilan,
we are aware of multiple issues when web
Hi David,
In that case, I will start working on using the CLI instead of the REST API
right away.
Will update you when I finish.
Thanks for the help,
Ilan.
From: David Morávek
Date: Monday, 6 December 2021 at 10:34
To: Ilan Huchansky
Cc: user@flink.apache.org , Start.io SDP
Subject: Re
java.net.Socket.connect(Socket.java:607)\n',
org.apache.flink.runtime.blob.BlobClient.(BlobClient.java:96)\n',
\t... 14 more\n',
]\n',
org.apache.flink.runtime.rest.RestClient.parseResponse(RestClient.java:486)\n',
org.apache.flink.runtime.rest.RestClient.la
966)\n',
java.util.concurrent.CompletableFuture$UniCompose.tryFire(CompletableFuture.java:940)\n',
\t... 4 more\n']
Could the blob error lead to the native thread error?
Is there any changes on the configuration that we can make to avoid the blob
related errors?
configured on the task and job managers.
Kind regards,
Ilan
From: David Morávek
Date: Monday, 13 December 2021 at 16:25
To: Ilan Huchansky
Cc: user@flink.apache.org , Start.io SDP
Subject: Re: Unable to create new native thread error
Hi Ilan, can you please check number of threads on the task
