Hi Sandeep,
Could you provide the error stack trace and Flink version you are using?
Regards,
Roman
On Fri, Jul 2, 2021 at 6:42 PM Sandeep khanzode wrote:
>
> Hi Guowei,
>
> I followed the document, but somehow, I am unable to get a working Java
> example for Avro state.
>
> So, I tried to sim
Hi Guowei,
I followed the document, but somehow, I am unable to get a working Java example
for Avro state.
So, I tried to simply use the Java SpecificRecords created by Avro Maven Plugin
and inject. Now, that works correctly, but I use Avro 1.7.7 since it is the
last version that I saw which d
Hi Sandeep
What I understand is that you want to manipulate the state. So I think you
could use the old schema to read the state first, and then write it to a
new schema, instead of using a new schema to read an old schema format data.
In addition, I would like to ask, if you want to do "State Sch
Hello,
1.] Can someone please share a working example of how to read ValueState
and MapState from a checkpoint and update it? I tried to assemble a
working Java example but there are bit and pieces of info around.
2.] I am using Avro 1.7.7 with Flink for state entities since versions belong
A
