This is an automated email from the ASF dual-hosted git repository.

dianfu pushed a change to branch release-1.12
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from 8c146a5  [FLINK-22021][table-planner-blink] Fix exception when 
PushFilterIntoLegacyTableSourceScanRule is faced with INTERVAL types
     add 599b7ee  [FLINK-22297][python] Perform early validation for the result 
of Pandas UDF

No new revisions were added by this update.

Summary of changes:
 .../pyflink/fn_execution/flink_fn_execution_pb2.py | 133 +++++++++++----------
 .../pyflink/fn_execution/operation_utils.py        |  18 ++-
 .../pyflink/proto/flink-fn-execution.proto         |   3 +
 .../pyflink/table/tests/test_pandas_udf.py         |  24 ++++
 .../streaming/api/utils/PythonOperatorUtils.java   |   4 +
 5 files changed, 118 insertions(+), 64 deletions(-)

Reply via email to