Huang Xingbo created FLINK-20933:
------------------------------------
Summary: Config Python Operator Use Managed Memory In Python
DataStream
Key: FLINK-20933
URL: https://issues.apache.org/jira/browse/FLINK-20933
Project: Flink
Issue Type: Bug
Components: API / Python
Affects Versions: 1.12.0, 1.13.0
Reporter: Huang Xingbo
Now the way to set `Python DataStream Operator` to use managed memory is to set
a hook in the `execute` method of `Python StreamExecutionEnvironment` to
traverse the `StreamGraph` and set the `Python Operator` to use managed memory.
But when the user’s job uses `from_data_stream` to convert the `DataStream` to
a `Table`, the `TableEnvironment.execute` method is used at the end rather than
`StreamExecutionEnvironment.execute`, so the `Python DataStream` related
operators will not have `Managed Memory` set.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
