This is an automated email from the ASF dual-hosted git repository.
twalthr pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 1ba35fb [FLINK-19182][doc-zh] Update translation for intra-slot
managed memory sharing.
add 29bce28 [FLINK-20147][connector-kafka] Replace lambdas with classes
to prevent serialization issues
add 488bc0a [FLINK-20147][json] Replace lambdas with classes to prevent
serialization issues
No new revisions were added by this update.
Summary of changes:
.../connectors/kafka/table/KafkaDynamicSink.java | 25 +++--
.../connectors/kafka/table/KafkaDynamicSource.java | 64 ++++++++++---
.../json/debezium/DebeziumJsonDecodingFormat.java | 104 ++++++++++++++-------
.../DebeziumJsonDeserializationSchema.java | 18 +++-
4 files changed, 152 insertions(+), 59 deletions(-)
