[flink] branch master updated (3932683 -> 2d75031)

[ja...@apache.org]

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 3932683  [FLINK-18893][python] Fix Table.to_pandas for TableEnvironment created via EnvironmentSettings
     add 2d75031  [FLINK-18844][json][maxwell] Support maxwell-json format to read Maxwell changelogs

No new revisions were added by this update.

Summary of changes:
 .../MaxwellJsonDeserializationSchema.java}         |  92 ++++++++---------
 .../MaxwellJsonFormatFactory.java}                 |  50 ++++++----
 .../maxwell/MaxwellJsonSerializationSchema.java    | 111 +++++++++++++++++++++
 .../org.apache.flink.table.factories.Factory       |   1 +
 .../MaxwellJsonFormatFactoryTest.java}             |  73 ++++++++------
 .../MaxwellJsonSerDerTest.java}                    |  74 ++++++++++----
 .../flink-json/src/test/resources/maxwell-data.txt |  20 ++++
 7 files changed, 299 insertions(+), 122 deletions(-)
 copy flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/{canal/CanalJsonDeserializationSchema.java => maxwell/MaxwellJsonDeserializationSchema.java} (63%)
 copy flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/{debezium/DebeziumJsonFormatFactory.java => maxwell/MaxwellJsonFormatFactory.java} (76%)
 create mode 100644 flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/maxwell/MaxwellJsonSerializationSchema.java
 copy flink-formats/flink-json/src/test/java/org/apache/flink/formats/json/{debezium/DebeziumJsonFormatFactoryTest.java => maxwell/MaxwellJsonFormatFactoryTest.java} (68%)
 copy flink-formats/flink-json/src/test/java/org/apache/flink/formats/json/{canal/CanalJsonDeserializationSchemaTest.java => maxwell/MaxwellJsonSerDerTest.java} (53%)
 create mode 100644 flink-formats/flink-json/src/test/resources/maxwell-data.txt