Dian Fu created FLINK-15897: ------------------------------- Summary: Deserialize the Python UDF execution results when sending them out Key: FLINK-15897 URL: https://issues.apache.org/jira/browse/FLINK-15897 Project: Flink Issue Type: Improvement Components: API / Python Reporter: Dian Fu Assignee: Dian Fu Fix For: 1.11.0
Currently, the Python UDF execution results are deserialized and then buffered in a collection when received from the Python worker. The deserialization could be deferred when sending the execution results to the downstream operator. That's to say, it buffers the serialized bytes instead of the deserialized Java objects in the buffer. This could reduce the memory footprint of the Java operator. -- This message was sent by Atlassian Jira (v8.3.4#803005)