You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by lz...@apache.org on 2020/05/19 10:24:02 UTC
[flink] branch master updated (a47c611 -> 92d6742)
This is an automated email from the ASF dual-hosted git repository.
lzljs3620320 pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from a47c611 [FLINK-17027][hotfix] Rename back-off infix to backoff in new Elasticsearch properties
add 92d6742 [FLINK-17626][fs-connector] Fs connector should use FLIP-122 format options style
No new revisions were added by this update.
Summary of changes:
.../flink/connectors/hive/HiveTableSink.java | 6 +-
.../formats/avro/AvroFileSystemFormatFactory.java | 40 +++---
.../org.apache.flink.table.factories.Factory | 1 +
.../org.apache.flink.table.factories.TableFactory | 1 -
.../flink/formats/avro/AvroFilesystemITCase.java | 2 +-
.../formats/csv/CsvFileSystemFormatFactory.java | 141 +++++++++------------
.../apache/flink/formats/csv/CsvFormatFactory.java | 2 +-
.../org.apache.flink.table.factories.Factory | 1 +
.../org.apache.flink.table.factories.TableFactory | 1 -
.../formats/csv/CsvFilesystemBatchITCase.java | 8 +-
.../formats/json/JsonFileSystemFormatFactory.java | 57 ++++-----
.../flink/formats/json/JsonFormatFactory.java | 23 +---
.../org/apache/flink/formats/json/JsonOptions.java | 26 ++--
.../org.apache.flink.table.factories.Factory | 1 +
.../org.apache.flink.table.factories.TableFactory | 1 -
.../formats/json/JsonBatchFileSystemITCase.java | 2 +-
.../flink/orc/OrcFileSystemFormatFactory.java | 65 ++++------
...ry => org.apache.flink.table.factories.Factory} | 0
.../org/apache/flink/orc/OrcFileSystemITCase.java | 33 ++++-
.../parquet/ParquetFileSystemFormatFactory.java | 83 ++++--------
...ry => org.apache.flink.table.factories.Factory} | 0
.../formats/parquet/ParquetFileSystemITCase.java | 41 +++++-
.../table/factories/FileSystemFormatFactory.java | 12 +-
.../physical/batch/BatchExecLegacySinkRule.scala | 4 +-
.../rules/physical/batch/BatchExecSinkRule.scala | 4 +-
.../physical/stream/StreamExecLegacySinkRule.scala | 4 +-
.../rules/physical/stream/StreamExecSinkRule.scala | 4 +-
.../utils/TestCsvFileSystemFormatFactory.java | 31 ++---
.../org.apache.flink.table.factories.Factory | 1 +
.../org.apache.flink.table.factories.TableFactory | 1 -
.../batch/sql/FileSystemTestCsvITCase.scala | 4 +-
.../batch/sql/PartitionableSinkITCase.scala | 6 +-
.../stream/sql/FsStreamingSinkTestCsvITCase.scala | 5 +-
.../stream/sql/StreamFileSystemTestCsvITCase.scala | 4 +-
.../flink/table/filesystem/FileSystemOptions.java | 29 +++++
.../table/filesystem/FileSystemTableFactory.java | 124 +++++-------------
.../table/filesystem/FileSystemTableSink.java | 15 ++-
.../table/filesystem/FileSystemTableSource.java | 33 +++--
38 files changed, 383 insertions(+), 433 deletions(-)
copy flink-kubernetes/src/main/java/org/apache/flink/kubernetes/configuration/KubernetesConfigOptionsInternal.java => flink-formats/flink-json/src/main/java/org/apache/flink/formats/json/JsonOptions.java (56%)
rename flink-formats/flink-orc/src/main/resources/META-INF/services/{org.apache.flink.table.factories.TableFactory => org.apache.flink.table.factories.Factory} (100%)
rename flink-formats/flink-parquet/src/main/resources/META-INF/services/{org.apache.flink.table.factories.TableFactory => org.apache.flink.table.factories.Factory} (100%)