Dian Fu created FLINK-16053:
-------------------------------
Summary: Remove redundant metrics in PyFlink
Key: FLINK-16053
URL: https://issues.apache.org/jira/browse/FLINK-16053
Project: Flink
Issue Type: Improvement
Components: API / Python
Reporter: Dian Fu
Assignee: Dian Fu
Fix For: 1.11.0
We have recorded the metrics about how many elements it has processed in Python
UDF. This kind of information is not necessary as there is also this kind of
information in the Java operator. I have performed a simple test and find that
removing it could improve the performance about 5% - 10%.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
