[jira] [Updated] (FLINK-30906) TwoInputStreamTask passes wrong configuration object when creating input processor
[ https://issues.apache.org/jira/browse/FLINK-30906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-30906: --- Fix Version/s: 1.19.0 > 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 > Components: Runtime / Task >Affects Versions: 1.17.0, 1.16.1 >Reporter: Yun Gao >Assignee: Yun Gao >Priority: Major > Labels: pull-request-available > Fix For: 1.19.0 > > > 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)
[jira] [Updated] (FLINK-30906) TwoInputStreamTask passes wrong configuration object when creating input processor
[ https://issues.apache.org/jira/browse/FLINK-30906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-30906: --- Labels: pull-request-available (was: ) > 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 > Components: Runtime / Task >Affects Versions: 1.17.0, 1.16.1 >Reporter: Yun Gao >Assignee: Yun Gao >Priority: Major > Labels: pull-request-available > > 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)
[jira] [Updated] (FLINK-30906) TwoInputStreamTask passes wrong configuration object when creating input processor
[ https://issues.apache.org/jira/browse/FLINK-30906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Gao updated FLINK-30906: Component/s: Runtime / Task > 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 > Components: Runtime / Task >Affects Versions: 1.17.0, 1.16.1 >Reporter: Yun Gao >Priority: Major > > 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)
