Re: flink状态恢复

2023-01-15 文章 Hangxiang Yu 
Hi,
Flink目前仅支持DataStream作业对POJO类型加减字段，及符合AVRO规则的状态迁移恢复[1]；
如果是其他类型，或者是sql作业，目前社区版本还尚不支持从旧状态恢复，只能无状态启动；

[1]
https://nightlies.apache.org/flink/flink-docs-release-1.16/docs/dev/datastream/fault-tolerance/serialization/schema_evolution/#supported-data-types-for-schema-evolution

On Thu, Jan 12, 2023 at 10:32 AM 小昌同学  wrote:

> 我有一个flink任务运行很久了，统计的指标是一些聚合值，但是现在业务想要增加字段，请问一下这个场景大家是怎么处理的啊
>
>
> | |
> 小昌同学
> |
> |
> ccc0606fight...@163.com
> |



-- 
Best,
Hangxiang.

Re: 未知类异常： org/apache/flink/table/connector/sink/abilities/SupportsSchemaEvolutionWriting

2023-01-15 文章 Shammon FY 
Hi

如果本地能运行，你可以检查下这个类在哪个包里，确认下k8s集群是不是有相关的包和类，是不是有其他包没有打进去

Best,
Shammon

On Thu, Jan 12, 2023 at 5:09 PM highfei2011  wrote:

> 本地测试正常。 On k8s 运行时，发生了异常。
>
>
> 在 2023年1月12日 15:39，highfei2011 写道：
>
>
> Hi, 大家好！我在使用 apache flink 的 table api 写阿里云 hologres
> 时，抛出了如下异常，与各位一起讨论下，谢谢！ Apache Flink 版本： 1.15.3 Hologres connector
> 版本：1.15-vvr-6.0.2-3，链接：
> https://search.maven.org/artifact/com.alibaba.ververica/ververica-connector-hologres/1.15-vvr-6.0.2-3/jar
> 异常信息： Caused by: java.lang.NoClassDefFoundError:
> org/apache/flink/table/connector/sink/abilities/SupportsSchemaEvolutionWriting
> at java.base/java.lang.ClassLoader.defineClass1(Native Method) at
> java.base/java.lang.ClassLoader.defineClass(Unknown Source) at
> java.base/java.security.SecureClassLoader.defineClass(Unknown Source) at
> java.base/jdk.internal.loader.BuiltinClassLoader.defineClass(Unknown
> Source) at
> java.base/jdk.internal.loader.BuiltinClassLoader.findClassOnClassPathOrNull(Unknown
> Source) at
> java.base/jdk.internal.loader.BuiltinClassLoader.loadClassOrNull(Unknown
> Source) at
> java.base/jdk.internal.loader.BuiltinClassLoader.loadClass(Unknown Source)
> at
> java.base/jdk.internal.loader.ClassLoaders$AppClassLoader.loadClass(Unknown
> Source) at java.base/java.lang.ClassLoader.loadClass(Unknown Source) at
> com.alibaba.ververica.connectors.hologres.factory.HologresTableFactory.createDynamicTableSink(HologresTableFactory.java:49)
> at
> org.apache.flink.table.factories.FactoryUtil.createDynamicTableSink(FactoryUtil.java:259)

取消订阅

2023-01-15 文章 wangwj03 
取消订阅