Hi Chesnay,
Thank you so much for the help. The fix is working now.
Thanks,
Sudhansu
On Mon, May 10, 2021 at 2:48 PM Chesnay Schepler wrote:
> From what I can tell this method does exist in 1.12.2 .
>
>
> https://ci.apache.org/projects/flink/flink-docs-release-1.12/api/java/org/apache/flink/ap
From what I can tell this method does exist in 1.12.2 .
https://ci.apache.org/projects/flink/flink-docs-release-1.12/api/java/org/apache/flink/api/common/ExecutionConfig.html#addDefaultKryoSerializer-java.lang.Class-java.lang.Class-
https://github.com/apache/flink/blob/release-1.12.2/flink-core/
Hi,
Thanks for the prompt response. I have already visited that page but in the
current flink version i.e 1.12.2, the method addDefaultKryoSerializer is
not available in the config object.
Thanks,
Sudhansu
On Mon, May 10, 2021 at 2:24 PM Chesnay Schepler wrote:
> Please have a look at
> https:
Please have a look at
https://stackoverflow.com/questions/32453030/using-an-collectionsunmodifiablecollection-with-apache-flink
On 5/10/2021 10:48 AM, sudhansu jena wrote:
Hi Team,
We have recently enabled check pointing in our flink job using S3 as
the state backend, but while submitting the
Hi Team,
We have recently enabled check pointing in our flink job using S3 as the
state backend, but while submitting the Job, it fails with the below
error.Can you please let us know what is going wrong here.
Below is the code snippet for enabling check pointing.
env.setStateBackend(new
