wuleiflink created FLINK-18494:
----------------------------------
Summary: The job was migrated from flink1.9.0 to 1.10.1, and there
were incompatibilities: No enum constant
org.apache.flink.table.types.logical.LogicalTypeRoot.ANY
Key: FLINK-18494
URL: https://issues.apache.org/jira/browse/FLINK-18494
Project: Flink
Issue Type: Bug
Components: API / State Processor
Affects Versions: 1.10.1, 1.9.0
Reporter: wuleiflink
The job was migrated from *flink1.9.0 to 1.10.1*, and there were
incompatibilities:
{color:#FF0000}No enum constant
org.apache.flink.table.types.logical.LogicalTypeRoot.ANY.{color}
{color:#172b4d} I guess it is related to flink sql, because the migration
errors are all used by flink sql, The detailed log is：{color}
{code:java}
// code placeholder
{code}
{color:#172b4d}switched from RUNNING to FAILED.switched from RUNNING to
FAILED.java.lang.Exception: Exception while creating
StreamOperatorStateContext. at
org.apache.flink.streaming.api.operators.StreamTaskStateInitializerImpl.streamOperatorStateContext(StreamTaskStateInitializerImpl.java:191)
at
org.apache.flink.streaming.api.operators.AbstractStreamOperator.initializeState(AbstractStreamOperator.java:255)
at
org.apache.flink.streaming.runtime.tasks.StreamTask.initializeStateAndOpen(StreamTask.java:989)
at
org.apache.flink.streaming.runtime.tasks.StreamTask.lambda$beforeInvoke$0(StreamTask.java:453)
at
org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$SynchronizedStreamTaskActionExecutor.runThrowing(StreamTaskActionExecutor.java:94)
at
org.apache.flink.streaming.runtime.tasks.StreamTask.beforeInvoke(StreamTask.java:448)
at
org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:460)
at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:708) at
org.apache.flink.runtime.taskmanager.Task.run(Task.java:533) at
java.lang.Thread.run(Thread.java:748)Caused by:
org.apache.flink.util.FlinkException: Could not restore keyed state backend for
KeyedProcessOperator_d26553d858836b90d15e66f459fbcb50_(2/3) from any of the 1
provided restore options. at
org.apache.flink.streaming.api.operators.BackendRestorerProcedure.createAndRestore(BackendRestorerProcedure.java:135)
at
org.apache.flink.streaming.api.operators.StreamTaskStateInitializerImpl.keyedStatedBackend(StreamTaskStateInitializerImpl.java:304)
at
org.apache.flink.streaming.api.operators.StreamTaskStateInitializerImpl.streamOperatorStateContext(StreamTaskStateInitializerImpl.java:131)
... 9 moreCaused by: org.apache.flink.runtime.state.BackendBuildingException:
Failed when trying to restore heap backend at
org.apache.flink.runtime.state.heap.HeapKeyedStateBackendBuilder.build(HeapKeyedStateBackendBuilder.java:116)
at
org.apache.flink.runtime.state.filesystem.FsStateBackend.createKeyedStateBackend(FsStateBackend.java:529)
at
org.apache.flink.streaming.api.operators.StreamTaskStateInitializerImpl.lambda$keyedStatedBackend$1(StreamTaskStateInitializerImpl.java:288)
at
org.apache.flink.streaming.api.operators.BackendRestorerProcedure.attemptCreateAndRestore(BackendRestorerProcedure.java:142)
at
org.apache.flink.streaming.api.operators.BackendRestorerProcedure.createAndRestore(BackendRestorerProcedure.java:121)
... 11 moreCaused by: java.io.InvalidObjectException: enum constant ANY does
not exist in class org.apache.flink.table.types.logical.LogicalTypeRoot at
java.io.ObjectInputStream.readEnum(ObjectInputStream.java:2013) at
java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1569) at
java.io.ObjectInputStream.defaultReadFields(ObjectInputStream.java:2286) at
java.io.ObjectInputStream.readSerialData(ObjectInputStream.java:2166) at
java.io.ObjectInputStream.readOrdinaryObject(ObjectInputStream.java:2068) at
java.io.ObjectInputStream.readObject0(ObjectInputStream.java:1572) at
java.io.ObjectInputStream.readObject(ObjectInputStream.java:430) at
org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:576)
at
org.apache.flink.util.InstantiationUtil.deserializeObject(InstantiationUtil.java:555)
at
org.apache.flink.table.runtime.typeutils.BaseRowSerializer$BaseRowSerializerSnapshot.readSnapshot(BaseRowSerializer.java:306)
at
org.apache.flink.api.common.typeutils.TypeSerializerSnapshot.readVersionedSnapshot(TypeSerializerSnapshot.java:174)
at
org.apache.flink.api.common.typeutils.TypeSerializerSnapshotSerializationUtil$TypeSerializerSnapshotSerializationProxy.deserializeV2(TypeSerializerSnapshotSerializationUtil.java:179)
at
org.apache.flink.api.common.typeutils.TypeSerializerSnapshotSerializationUtil$TypeSerializerSnapshotSerializationProxy.read(TypeSerializerSnapshotSerializationUtil.java:150)
at
org.apache.flink.api.common.typeutils.TypeSerializerSnapshotSerializationUtil.readSerializerSnapshot(TypeSerializerSnapshotSerializationUtil.java:76)
at
org.apache.flink.runtime.state.metainfo.StateMetaInfoSnapshotReadersWriters$CurrentReaderImpl.readStateMetaInfoSnapshot(StateMetaInfoSnapshotReadersWriters.java:219)
at
org.apache.flink.runtime.state.KeyedBackendSerializationProxy.read(KeyedBackendSerializationProxy.java:169)
at
org.apache.flink.runtime.state.heap.HeapRestoreOperation.restore(HeapRestoreOperation.java:133)
at
org.apache.flink.runtime.state.heap.HeapKeyedStateBackendBuilder.build(HeapKeyedStateBackendBuilder.java:114)
... 15 moreCaused by: java.lang.IllegalArgumentException: No enum constant
org.apache.flink.table.types.logical.LogicalTypeRoot.ANY at
java.lang.Enum.valueOf(Enum.java:238) at
java.io.ObjectInputStream.readEnum(ObjectInputStream.java:2010) ... 32
more{color}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
