[ https://issues.apache.org/jira/browse/FLINK-29645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Dawid Wysakowicz reassigned FLINK-29645: ---------------------------------------- Assignee: Dawid Wysakowicz > BatchExecutionKeyedStateBackend is using incorrect ExecutionConfig when > creating serializer > ------------------------------------------------------------------------------------------- > > Key: FLINK-29645 > URL: https://issues.apache.org/jira/browse/FLINK-29645 > Project: Flink > Issue Type: Bug > Components: Runtime / State Backends > Affects Versions: 1.12.7, 1.13.6, 1.16.0, 1.17.0, 1.15.2, 1.14.6 > Reporter: Piotr Nowojski > Assignee: Dawid Wysakowicz > Priority: Major > > {{org.apache.flink.streaming.api.operators.sorted.state.BatchExecutionKeyedStateBackend#getOrCreateKeyedState}} > is using freshly constructed {{ExecutionConfig}}, instead of the one > configured by the user from the environment. > {code:java} > public <N, S extends State, T> S getOrCreateKeyedState( > TypeSerializer<N> namespaceSerializer, StateDescriptor<S, T> > stateDescriptor) > throws Exception { > checkNotNull(namespaceSerializer, "Namespace serializer"); > checkNotNull( > keySerializer, > "State key serializer has not been configured in the config. " > + "This operation cannot use partitioned state."); > if (!stateDescriptor.isSerializerInitialized()) { > stateDescriptor.initializeSerializerUnlessSet(new > ExecutionConfig()); > } > {code} > The correct one could be obtained from {{env.getExecutionConfig()}} in > {{org.apache.flink.streaming.api.operators.sorted.state.BatchExecutionStateBackend#createKeyedStateBackend}} > -- This message was sent by Atlassian Jira (v8.20.10#820010)