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 879465f [FLINK-22991][network] Use Optional in NettyBufferPool
add a07450d [FLINK-23033][python] Add the missing ObjectArrayTypeInfo
(#16220)
No new revisions were added by this update.
Summary of changes:
.../docs/dev/python/datastream/data_types.md | 63 ++-
.../docs/dev/python/datastream/data_types.md | 63 ++-
flink-python/pyflink/common/__init__.py | 5 +-
flink-python/pyflink/common/tests/test_typeinfo.py | 4 +
flink-python/pyflink/common/typeinfo.py | 43 ++
.../pyflink/datastream/tests/test_data_stream.py | 21 +
flink-python/pyflink/datastream/utils.py | 6 +-
.../pyflink/fn_execution/coder_impl_fast.pxd | 2 +-
.../pyflink/fn_execution/coder_impl_fast.pyx | 2 +-
.../pyflink/fn_execution/coder_impl_slow.py | 6 +-
flink-python/pyflink/fn_execution/coders.py | 22 +-
.../pyflink/fn_execution/flink_fn_execution_pb2.py | 10 +-
.../pyflink/fn_execution/tests/test_coders.py | 8 +-
.../pyflink/proto/flink-fn-execution.proto | 1 +
.../flink/streaming/api/utils/PythonTypeUtils.java | 494 +++++++++++----------
.../streaming/api/utils/PythonTypeUtilsTest.java | 30 +-
16 files changed, 480 insertions(+), 300 deletions(-)
