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 1678b60 [FLINK-21024][dist] Keep dynamic properties before job
arguments.
add 6ee32ee [FLINK-19446][canal-json] Fix canal-json format parse UPDATE
record with null value will get wrong result
No new revisions were added by this update.
Summary of changes:
.../json/canal/CanalJsonDeserializationSchema.java | 15 +++++++++++----
.../formats/json/canal/CanalJsonSerDeSchemaTest.java | 8 ++++----
.../src/test/resources/canal-data-filter-table.txt | 4 ++--
.../flink-json/src/test/resources/canal-data.txt | 4 ++--
4 files changed, 19 insertions(+), 12 deletions(-)
