You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ja...@apache.org on 2020/11/11 03:00:35 UTC
[flink] branch master updated (0ab2389 -> ba7c232)
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 0ab2389 [FLINK-19842][python][tests] Fix the instable test case PyFlinkStreamUserDefinedTableFunctionTests.test_table_function_with_sql_query
add ba7c232 [FLINK-19912][json] Fix JSON format fails to serialize map value with null keys
No new revisions were added by this update.
Summary of changes:
docs/dev/table/connectors/formats/canal.md | 22 ++++-
docs/dev/table/connectors/formats/canal.zh.md | 22 ++++-
docs/dev/table/connectors/formats/debezium.md | 21 ++++
docs/dev/table/connectors/formats/debezium.zh.md | 20 ++++
docs/dev/table/connectors/formats/json.md | 20 ++++
docs/dev/table/connectors/formats/json.zh.md | 20 ++++
.../flink/formats/json/JsonFormatFactory.java | 39 +++-----
.../org/apache/flink/formats/json/JsonOptions.java | 106 ++++++++++++++++++++-
.../json/JsonRowDataSerializationSchema.java | 27 ++++--
.../formats/json/RowDataToJsonConverters.java | 36 ++++++-
.../formats/json/canal/CanalJsonFormatFactory.java | 41 ++++----
.../flink/formats/json/canal/CanalJsonOptions.java | 69 ++++++++++++++
.../json/canal/CanalJsonSerializationSchema.java | 11 ++-
.../json/debezium/DebeziumJsonFormatFactory.java | 39 ++++----
.../formats/json/debezium/DebeziumJsonOptions.java | 77 +++++++++++++++
.../debezium/DebeziumJsonSerializationSchema.java | 13 ++-
.../json/maxwell/MaxwellJsonFormatFactory.java | 26 +++--
.../formats/json/maxwell/MaxwellJsonOptions.java | 55 +++++++++++
.../maxwell/MaxwellJsonSerializationSchema.java | 13 ++-
.../flink/formats/json/JsonFormatFactoryTest.java | 28 +++++-
.../formats/json/JsonRowDataSerDeSchemaTest.java | 83 +++++++++++++++-
.../json/canal/CanalJsonFormatFactoryTest.java | 32 ++++++-
.../json/canal/CanalJsonSerDeSchemaTest.java | 5 +-
.../debezium/DebeziumJsonFormatFactoryTest.java | 34 ++++++-
.../json/debezium/DebeziumJsonSerDeSchemaTest.java | 6 +-
.../json/maxwell/MaxwellJsonFormatFactoryTest.java | 28 +++++-
.../json/maxwell/MaxwellJsonSerDerTest.java | 5 +-
.../apache/flink/table/data/GenericMapData.java | 2 +-
28 files changed, 790 insertions(+), 110 deletions(-)
create mode 100644 flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/canal/CanalJsonOptions.java
create mode 100644 flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/debezium/DebeziumJsonOptions.java
create mode 100644 flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/maxwell/MaxwellJsonOptions.java