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

Posted to commits@flink.apache.org by di...@apache.org on 2020/12/23 07:30:14 UTC

[flink] branch master updated (d42aa45 -> dca092f)

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

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


    from d42aa45  [FLINK-20690][table-planner-blink] Introduce BatchPhysicalCorrelate & BatchPhysicalPythonCorrelate, and make BatchExecCorrelate & BatchExecPythonCorrelate only extended from ExecNode
     add dca092f  [FLINK-20621][python] Improve the TypeInformation implementation in Python DataStream API

No new revisions were added by this update.

Summary of changes:
 flink-python/pyflink/common/serialization.py       |  23 +-
 flink-python/pyflink/common/tests/test_typeinfo.py |   8 +
 flink-python/pyflink/common/typeinfo.py            | 809 ++++++++++++---------
 flink-python/pyflink/datastream/connectors.py      |   9 +-
 flink-python/pyflink/datastream/data_stream.py     |  16 +-
 .../datastream/stream_execution_environment.py     |  13 +-
 flink-python/pyflink/datastream/utils.py           |  23 +-
 .../pyflink/fn_execution/beam/beam_operations.py   |   3 +-
 flink-python/pyflink/fn_execution/coders.py        |  40 +-
 .../pyflink/fn_execution/flink_fn_execution_pb2.py | 240 ++++--
 .../pyflink/proto/flink-fn-execution.proto         |  37 +-
 flink-python/pyflink/table/table_environment.py    |  14 +-
 .../flink/api/common/python/PythonBridgeUtils.java |  23 +-
 .../beam/BeamDataStreamPythonFunctionRunner.java   |   4 +-
 .../streaming/api/utils/PythonOperatorUtils.java   |   7 +-
 .../flink/streaming/api/utils/PythonTypeUtils.java | 102 ++-
 .../streaming/api/utils/PythonTypeUtilsTest.java   |  19 +-
 17 files changed, 850 insertions(+), 540 deletions(-)