Ilya Soin created FLINK-39634:
---------------------------------
Summary: Savepoint Table API connector incorrectly infers map
state key type
Key: FLINK-39634
URL: https://issues.apache.org/jira/browse/FLINK-39634
Project: Flink
Issue Type: Bug
Components: API / State Processor
Affects Versions: 2.2.0
Reporter: Ilya Soin
In
[SavepointDynamicTableSourceFactory|https://github.com/apache/flink/blob/release-2.2/flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/table/SavepointDynamicTableSourceFactory.java#L193]:
{code:java}
TypeInformation<?> mapKeyTypeInfo =
getTypeInfo(
options,
keyFormatOption,
...
){code}
we infer TypeInformation for state key instead of map key. Should be:
{code:java}
TypeInformation<?> mapKeyTypeInfo =
getTypeInfo(
options,
keyFormatOption,
...
) {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
