This is an automated email from the ASF dual-hosted git repository.
hequn pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 14665dd [FLINK-18956][task] StreamTask.invoke should catch Throwable
add 1fc400d [FLINK-18879][python] Support Row Serialization and
Deserialization schemas for Python DataStream API. (#13150)
No new revisions were added by this update.
Summary of changes:
.../pyflink/common/serialization_schemas.py | 367 +++++++++++++++++++++
.../common/tests/test_serialization_schemas.py | 103 ++++++
2 files changed, 470 insertions(+)
create mode 100644 flink-python/pyflink/common/serialization_schemas.py
create mode 100644
flink-python/pyflink/common/tests/test_serialization_schemas.py
