Hi.
I'm running Flink 1.3.1 with checkpoints stored in Azure blobs. Incremental
checkpoints feature is on.
The job is trying to restore a checkpoint and consistently gets:
java.lang.IllegalStateException: Could not initialize keyed state backend.
at
org.apache.flink.streaming.api.operato
that’s the only possible way at the
moment.
On 6 June 2017 at 5:45:12 PM, Shai Kaplan
(shai.kap...@microsoft.com<mailto:shai.kap...@microsoft.com>) wrote:
No. This way you can set default serializers for specific classes, I want to
change the default serializer that Kryo uses when it ca
work.
You can also specify it directly:
StreamExecutionEnvironment.registerTypeWithKryoSerializer(YourClass.class,
TaggedFieldSerializer.class).
Does the above work?
On 6 June 2017 at 5:09:21 PM, Shai Kaplan
(shai.kap...@microsoft.com<mailto:shai.kap...@microsoft.com>) wrote:
I underst
he default serializer?
From: Tzu-Li (Gordon) Tai [mailto:tzuli...@apache.org]
Sent: Sunday, June 04, 2017 3:28 PM
To: Shai Kaplan ; user@flink.apache.org
Subject: Re: KryoException: Encountered unregistered class ID
Hi Shai,
Flink’s Kryo registrations do not allow specifying the registration ID. They
si
Hi.
I'm running a job from a savepoint. I've changed one of the classes stored in
state. When I try to load the value from the state I get
"com.esotericsoftware.kryo.KryoException: Encountered unregistered class ID:
97".
I tried to understand if the problem arise from the nature of the change, o
And now it's happening again
-Original Message-
From: Shai Kaplan [mailto:shai.kap...@microsoft.com]
Sent: Wednesday, February 22, 2017 12:02 PM
To: user@flink.apache.org
Subject: RE: Flink checkpointing gets stuck
I changed the checkpoint interval to 30 minutes, and also swi
job
failed and the checkpoint coordinator is shut down because of that. Can you
check the TaskManager and JobManager logs if other errors are reported? Feel
free to share them. Then I could help with going over them.
– Ufuk
On Tue, Feb 21, 2017 at 2:47 PM, Shai Kaplan wrote:
> Hi.
>
>
1%7C0%7C636232825326824798&sdata=z0YAi2n6itetqIfkD6tuOpHKQY0qbOLNUuAoYiQEWak%3D&reserved=0>
What is the configuration on which you running the job ?
What is the RocksDB predefined option you are using ?
Regards,
Vinay Patil
On Tue, Feb 21, 2017 at 7:13 PM, Shai Kaplan [via Apache Flink User Mailing
List archive.] <[hidd
Hi.
I'm running a Flink 1.2 job with a 10 seconds checkpoint interval. After some
running time (minutes-hours) Flink fails to save checkpoints, and stops
processing records (I'm not sure if the checkpointing failure is the cause of
the problem or just a symptom).
After several checkpoints that t
