This is an automated email from the ASF dual-hosted git repository.
bli pushed a change to branch dynamick
in repository https://gitbox.apache.org/repos/asf/flink.git
from 1292188de3d fix python tests
add 00880828112 add more classes
No new revisions were added by this update.
Summary of changes:
.../pyflink/datastream/connectors/__init__.py | 2 ++
.../pyflink/datastream/connectors/dynamic_kafka.py | 29 ++++++++++++++++
.../connectors/tests/test_dynamic_kafka.py | 39 +++++++++++++++++++++-
3 files changed, 69 insertions(+), 1 deletion(-)
