This is an automated email from the ASF dual-hosted git repository.
jark pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 8efa521 [hotfix][table] Move JoinedRowData to utils subpackage
add 24d612b [FLINK-20041][kafka] Support watermark push down for kafka
source
No new revisions were added by this update.
Summary of changes:
.../connectors/kafka/table/KafkaDynamicSource.java | 23 ++++-
.../connectors/kafka/table/KafkaTableITCase.java | 97 ++++++++++++++++++++++
.../kafka/table/UpsertKafkaTableITCase.java | 2 -
.../factories/TestValuesRuntimeFunctions.java | 14 +++-
.../planner/factories/TestValuesTableFactory.java | 51 ++++++++++--
5 files changed, 175 insertions(+), 12 deletions(-)
