[ https://issues.apache.org/jira/browse/FLINK-29645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Dawid Wysakowicz closed FLINK-29645. ------------------------------------ Fix Version/s: 1.16.0 1.17.0 1.15.3 Resolution: Fixed Fixed in: * master ** 0ffcfb757965ca62f7b4f1b93fd1387a45a50b2c * 1.16 ** c07d5aa98c016201eab38f883d20f2e807213113 * 1.15 ** f19f032daee2fabefb4ccc6257740dd491b3a925 > 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: Minor > Labels: pull-request-available > Fix For: 1.16.0, 1.17.0, 1.15.3 > > > {{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)