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

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


    from f19f032daee [FLINK-29645] BatchExecutionKeyedStateBackend is using 
incorrect ExecutionConfig when creating serializer
     add 5e4da2cc868 [FLINK-29658][python] Fix the missing LocalTime support 
when converting Table to DataStream

No new revisions were added by this update.

Summary of changes:
 flink-python/pyflink/common/typeinfo.py            |  44 +++++++++
 .../pyflink/fn_execution/coder_impl_fast.pxd       |   9 ++
 .../pyflink/fn_execution/coder_impl_fast.pyx       |  77 +++++++++++++++
 .../pyflink/fn_execution/coder_impl_slow.py        |  80 ++++++++++++++++
 flink-python/pyflink/fn_execution/coders.py        |  23 ++++-
 .../pyflink/fn_execution/flink_fn_execution_pb2.py | 106 ++++++++++++---------
 .../pyflink/proto/flink-fn-execution.proto         |   3 +
 .../table/tests/test_table_environment_api.py      |  17 ++++
 .../flink/streaming/api/utils/PythonTypeUtils.java |  34 +++++++
 9 files changed, 345 insertions(+), 48 deletions(-)

Reply via email to