[jira] [Created] (FLINK-16053) Remove redundant metrics in PyFlink

[Shang Yuanchun (Jira)]

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)