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(-)