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

Posted to commits@flink.apache.org by hx...@apache.org on 2021/02/07 04:54:22 UTC

[flink] branch master updated (8e69b2f -> 78f4b1f)

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

hxb pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from 8e69b2f  [hotfix][jdbc] Fix typo in UnsignedTypeConversionITCase
     add 78f4b1f  [FLINK-21208][python] Make Arrow Coder serialize schema info in every batch

No new revisions were added by this update.

Summary of changes:
 flink-python/pyflink/fn_execution/ResettableIO.py     |  8 ++++----
 .../pyflink/fn_execution/beam/beam_coder_impl_slow.py | 10 +++++-----
 flink-python/pyflink/table/tests/test_udaf.py         |  4 ++--
 flink-python/pyflink/testing/test_case_utils.py       |  8 ++++++++
 .../runtime/arrow/serializers/ArrowSerializer.java    | 19 +++++++++++++++++++
 .../arrow/ArrowPythonScalarFunctionFlatMap.java       |  2 ++
 ...atchArrowPythonGroupAggregateFunctionOperator.java |  2 ++
 ...rowPythonGroupWindowAggregateFunctionOperator.java |  2 ++
 ...rrowPythonOverWindowAggregateFunctionOperator.java |  2 ++
 ...AbstractStreamArrowPythonBoundedRangeOperator.java |  1 +
 .../AbstractStreamArrowPythonBoundedRowsOperator.java |  1 +
 ...rrowPythonOverWindowAggregateFunctionOperator.java |  1 +
 ...rowPythonGroupWindowAggregateFunctionOperator.java |  2 ++
 .../arrow/ArrowPythonScalarFunctionOperator.java      |  2 ++
 .../RowDataArrowPythonScalarFunctionOperator.java     |  2 ++
 .../PassThroughPythonAggregateFunctionRunner.java     |  3 +++
 16 files changed, 58 insertions(+), 11 deletions(-)