You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "Yun Gao (Jira)" <ji...@apache.org> on 2023/02/06 07:22:00 UTC

[jira] [Created] (FLINK-30906) TwoInputStreamTask passes wrong configuration object when creating input processor

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)