Yun Gao created FLINK-30906: ------------------------------- Summary: TwoInputStreamTask passes wrong configuration object when creating input processor Key: FLINK-30906 URL: https://issues.apache.org/jira/browse/FLINK-30906 Project: Flink Issue Type: Bug Affects Versions: 1.16.1, 1.17.0 Reporter: Yun Gao
It seems _StreamTwoInputProcessorFactory.create_ is passed with wrong configuration object: the taskManagerConfiguration should be __ _getEnvironment().getTaskManagerInfo().getConfiguration()._ And in the following logic, it seems to indeed try to load taskmanager options from this configuration object, like state-backend and taskmanager.memory.managed.consumer-weights [1]https://github.com/apache/flink/blob/111342f37bdc0d582d3f7af458d9869f0548299f/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/TwoInputStreamTask.java#L98 -- This message was sent by Atlassian Jira (v8.20.10#820010)