This is an automated email from the ASF dual-hosted git repository.
kirs pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git.
from 36e7ef3 [hotfix][Connectors] Fix Iceberg sink path (#1454)
add d3814a7 [Improvement][source] Add FormatType emum and add UT of
connector-flink-file module (#1449)
No new revisions were added by this update.
Summary of changes:
.../apache/seatunnel/flink/enums/FormatType.java | 26 +++++--
.../apache/seatunnel/flink/util/SchemaUtil.java | 36 +++++----
.../seatunnel-connector-flink-file/pom.xml | 4 +
.../org/apache/seatunnel/flink/sink/FileSink.java | 15 ++--
.../apache/seatunnel/flink/source/FileSource.java | 45 ++++++-----
.../seatunnel/flink/source/FileSourceTest.java | 91 ++++++++++++++++++++++
.../src/test/resources/JsonFile.text | 2 +-
.../src/test/resources/TestFile.text} | 4 +-
.../src/test/resources/flink.streaming.json.conf | 20 ++---
.../src/test/resources/flink.streaming.text.conf | 19 ++---
.../seatunnel/flink/source/KafkaTableStream.java | 7 +-
11 files changed, 183 insertions(+), 86 deletions(-)
copy
seatunnel-common/src/main/java/org/apache/seatunnel/common/config/DeployMode.java
=>
seatunnel-apis/seatunnel-api-flink/src/main/java/org/apache/seatunnel/flink/enums/FormatType.java
(61%)
create mode 100644
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-file/src/test/java/org/apache/seatunnel/flink/source/FileSourceTest.java
copy deploy/docker/flink/config/flink-conf.yaml =>
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-file/src/test/resources/JsonFile.text
(95%)
copy
seatunnel-connectors/{seatunnel-connectors-spark/seatunnel-connector-spark-doris/src/main/resources/META-INF/services/org.apache.seatunnel.spark.BaseSparkSink
=>
seatunnel-connectors-flink/seatunnel-connector-flink-file/src/test/resources/TestFile.text}
(95%)
copy config/flink.streaming.conf.template =>
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-file/src/test/resources/flink.streaming.json.conf
(80%)
copy config/flink.streaming.conf.template =>
seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-file/src/test/resources/flink.streaming.text.conf
(80%)
