You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "Dian Fu (Jira)" <ji...@apache.org> on 2021/04/16 03:03:00 UTC

[jira] [Created] (FLINK-22297) Perform early check to ensure that the length of the result is the same as the input for Pandas UDF

Dian Fu created FLINK-22297:
-------------------------------

             Summary: Perform early check to ensure that the length of the result is the same as the input for Pandas UDF
                 Key: FLINK-22297
                 URL: https://issues.apache.org/jira/browse/FLINK-22297
             Project: Flink
          Issue Type: Improvement
          Components: API / Python
            Reporter: Dian Fu
            Assignee: Dian Fu


For Pandas UDF, the input type for each input argument is Pandas.Series and the result type is also of type Pandas.Series. Besides, the length of the result should be the same as the inputs. If this is not the case, currently the behavior is unclear. We should perform early check for this and provide a clear error message.



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