Flink state evolution with avro

classic Classic list List threaded Threaded
3 messages Options
Reply | Threaded
Open this post in threaded view
|

Flink state evolution with avro

casel.chen
Is there any live code example about flink state evolution with avro? Thanks!
Reply | Threaded
Open this post in threaded view
|

Re: Flink state evolution with avro

Yun Tang
Hi,

你可以参照社区的 state-evolution的 E2E 测试代码 [1], 整个程序就是使用的avro作为相关类的声明工具。


[1] https://github.com/apache/flink/tree/master/flink-end-to-end-tests/flink-state-evolution-test/src/main

祝好
唐云
________________________________
From: casel.chen <[hidden email]>
Sent: Friday, June 11, 2021 8:13
To: [hidden email] <[hidden email]>
Subject: Flink state evolution with avro

Is there any live code example about flink state evolution with avro? Thanks!
Reply | Threaded
Open this post in threaded view
|

question about flink on k8s per-job mode

at003
哈喽,各位专家/大神:

为啥flink官方文档说明了flink on k8s 还有 native k8s都不支持 per-job mode 呢,但是搜索可以搜到好多教程。。。

谢谢