You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@seatunnel.apache.org by ni...@apache.org on 2022/03/01 01:44:55 UTC
[incubator-seatunnel] branch dev updated (7ed1a6d -> d0a4814)
This is an automated email from the ASF dual-hosted git repository.
nielifeng pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git.
from 7ed1a6d [SeaTunnel#1318] shouldn't check optional parameter in Hive sink (#1340)
add d0a4814 [Improve]optimize some code (#1354)
No new revisions were added by this update.
Summary of changes:
.../seatunnel/spark/utils/SparkStructTypeUtil.java | 2 +-
.../apache/seatunnel/flink/sink/ConsoleSink.java | 8 +--
.../seatunnel/flink/sink/DorisOutputFormat.java | 8 +--
.../org/apache/seatunnel/flink/sink/DorisSink.java | 2 +-
.../seatunnel/flink/sink/DorisSinkFunction.java | 8 +--
.../seatunnel/flink/sink/DruidOutputFormat.java | 2 +-
.../flink/sink/ElasticsearchOutputFormat.java | 3 +
.../org/apache/seatunnel/flink/sink/FileSink.java | 3 +-
.../seatunnel/flink/source/SocketStream.java | 4 +-
.../apache/seatunnel/spark/sink/Clickhouse.scala | 22 +++---
.../org/apache/seatunnel/spark/sink/Console.scala | 12 ++--
.../apache/seatunnel/spark/sink/DorisUtil.scala | 8 +--
.../apache/seatunnel/spark/sink/DataLocator.scala | 20 +++---
.../org/apache/seatunnel/spark/sink/Util.scala | 1 +
.../apache/seatunnel/spark/source/FakeStream.scala | 4 +-
.../org/apache/seatunnel/spark/sink/File.scala | 10 +--
.../org/apache/seatunnel/spark/sink/Hbase.scala | 2 +-
.../org/apache/seatunnel/spark/sink/Hive.scala | 43 ++++++-----
.../org/apache/seatunnel/spark/source/Jdbc.scala | 5 +-
.../execution/datasources/jdbc2/JDBCOptions.scala | 84 +++++++++++-----------
.../datasources/jdbc2/JDBCPartition.scala | 8 +--
.../org/apache/seatunnel/spark/sink/Kafka.scala | 14 ++--
.../seatunnel/spark/sink/KafkaProducerUtil.scala | 2 +-
.../seatunnel/spark/source/KafkaStream.scala | 2 +-
.../org/apache/seatunnel/spark/sink/MongoDB.scala | 2 +-
.../org/apache/phoenix/spark/sparkExtend.scala | 2 +
.../org/apache/seatunnel/spark/sink/Tidb.scala | 5 +-
.../main/java/org/apache/seatunnel/Seatunnel.java | 3 +-
28 files changed, 140 insertions(+), 149 deletions(-)