You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Dian Fu (Jira)" <ji...@apache.org> on 2020/12/18 02:01:00 UTC

[jira] [Closed] (FLINK-20647) Use yield to generate output datas in ProcessFunction for Python DataStream

     [ https://issues.apache.org/jira/browse/FLINK-20647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Dian Fu closed FLINK-20647.
---------------------------
    Resolution: Fixed

Merged to
- master via 1317cab8ef86a8ab97619abda7f335a3c8585f9e
- release-1.12 via ffd2f601f954de916f6178794f84ec054bcfc76e

> Use yield to generate output datas in ProcessFunction for Python DataStream
> ---------------------------------------------------------------------------
>
>                 Key: FLINK-20647
>                 URL: https://issues.apache.org/jira/browse/FLINK-20647
>             Project: Flink
>          Issue Type: Improvement
>          Components: API / Python
>    Affects Versions: 1.12.0
>            Reporter: Shuiqiang Chen
>            Assignee: Shuiqiang Chen
>            Priority: Major
>              Labels: pull-request-available
>             Fix For: 1.13.0, 1.12.1
>
>
> Currently, users need to use a `collector` to collect the output of their ProcessFunction. We should use yield to make it more efficient that avoid using an array buffer to store the collected data, and it would be more pythonic as well.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)