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 1bacaee [FLINK-18094][network] Buffers are only addressed through
InputChannelInfo.
add c42a2f9 [FLINK-18299][json] Fix the non SQL standard timestamp format
in JSON format
No new revisions were added by this update.
Summary of changes:
docs/dev/table/connectors/formats/canal.md | 14 +++-
docs/dev/table/connectors/formats/canal.zh.md | 14 +++-
docs/dev/table/connectors/formats/debezium.md | 14 +++-
docs/dev/table/connectors/formats/debezium.zh.md | 14 +++-
docs/dev/table/connectors/formats/json.md | 12 +++
docs/dev/table/connectors/formats/json.zh.md | 12 +++
.../table/Elasticsearch6DynamicSinkITCase.java | 12 +--
.../table/Elasticsearch7DynamicSinkITCase.java | 12 +--
.../tests/util/kafka/SQLClientKafkaITCase.java | 16 ++--
.../formats/json/JsonFileSystemFormatFactory.java | 9 ++-
.../flink/formats/json/JsonFormatFactory.java | 17 ++++-
.../org/apache/flink/formats/json/JsonOptions.java | 43 +++++++++++
.../json/JsonRowDataDeserializationSchema.java | 54 ++++++-------
.../json/JsonRowDataSerializationSchema.java | 40 +++++++---
.../org/apache/flink/formats/json/TimeFormats.java | 18 ++++-
.../apache/flink/formats/json/TimestampFormat.java | 18 ++---
.../json/canal/CanalJsonDeserializationSchema.java | 7 +-
.../formats/json/canal/CanalJsonFormatFactory.java | 17 +++--
.../DebeziumJsonDeserializationSchema.java | 7 +-
.../json/debezium/DebeziumJsonFormatFactory.java | 16 ++--
.../flink/formats/json/JsonFormatFactoryTest.java | 26 ++++++-
.../formats/json/JsonRowDataSerDeSchemaTest.java | 89 ++++++++++++++++++----
.../canal/CanalJsonDeserializationSchemaTest.java | 4 +-
.../json/canal/CanalJsonFormatFactoryTest.java | 5 +-
.../DebeziumJsonDeserializationSchemaTest.java | 4 +-
.../debezium/DebeziumJsonFormatFactoryTest.java | 5 +-
26 files changed, 378 insertions(+), 121 deletions(-)
copy
flink-clients/src/main/java/org/apache/flink/client/program/ClusterClientProvider.java
=>
flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/TimestampFormat.java
(67%)
