[jira] [Created] (FLINK-39634) Savepoint Table API connector incorrectly infers map state key type

["Ilya Soin (Jira)" <ji...@apache.org>]

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)