Hi 目前增减列数据会导致状态无法兼容
Best, Shammon FY On Fri, Apr 14, 2023 at 9:09 PM Elvis Chen <elvisc...@yelp.com.invalid> wrote: > 我们正在使用flink-1.16.0的Table API和RocksDB作为后端,为我们的用户提供运行SQL > > queries的服务。表格是使用Avro模式创建的,当以兼容的方式更改模式,例如添加一个带默认值的field时,我们无法从savepoint恢复作业。这是在数据结构升级后的报错: > Caused by: org.apache.flink.util.StateMigrationException: The new state > serializer > (org.apache.flink.table.runtime.typeutils.RowDataSerializer@aad5b03a) must > not be incompatible with the old state serializer > (org.apache.flink.table.runtime.typeutils.RowDataSerializer@9d089984) > ... >