[FLINK-21916] Allow OPERATOR and PYTHON ManagedMemoryUseCase to be used in the same operator

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.13.0
• Component/s: API / DataStream, API / Python
• Labels: pull-request-available
• Assignee: Dian Fu
• Reporter: Dian Fu
• Created: 22/Mar/21 12:57
• Updated: 24/Mar/21 01:26
• Resolved: 24/Mar/21 01:26

Description

Currently, the implementation of SimpleTransformationTranslator restricts that OPERATOR and PYTHON use case could not be used in the same operator. For batch mode of Python DataStream API:

• OPERATOR use case will be added firstly in BatchExecutionUtils.applyBatchExecutionSettings for a keyed operator during translation
• Then the PYTHON use case which is set in the transformation could not be added in SimpleTransformationTranslator as the streamNode.getManagedMemoryOperatorScopeUseCaseWeights() is not empty.

We need to remove the restriction in SimpleTransformationTranslator  if there are no special reasons.

Issue Links

• links to: GitHub Pull Request #15337