This is an automated email from the ASF dual-hosted git repository.
kirs pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git
The following commit(s) were added to refs/heads/dev by this push:
new 48537f5 [Feature] [flink] Upgrade flink to 1.13.5 (#1089)
48537f5 is described below
commit 48537f5cc00629fb9a910d6a8c071d1d44a013c1
Author: lamberken <[email protected]>
AuthorDate: Mon Feb 7 17:39:31 2022 +0800
[Feature] [flink] Upgrade flink to 1.13.5 (#1089)
* [SeaTunnel #1083] [flink] Upgrade flink to 1.13.5
* trigger ci
---
pom.xml | 7 +-
.../apache/seatunnel/flink/FlinkEnvironment.java | 4 +-
.../seatunnel/flink/batch/FlinkBatchExecution.java | 2 +-
.../flink/stream/FlinkStreamExecution.java | 2 +-
.../org/apache/seatunnel/flink/util/TableUtil.java | 4 +-
.../org/apache/seatunnel/flink/sink/DorisSink.java | 4 +-
.../seatunnel-connector-flink-jdbc/pom.xml | 2 +-
.../org/apache/seatunnel/flink/sink/JdbcSink.java | 35 +++++-----
.../apache/seatunnel/flink/source/JdbcSource.java | 6 +-
.../apache/seatunnel/flink/sink/KafkaTable.java | 5 +-
.../seatunnel/flink/source/KafkaTableStream.java | 4 +-
seatunnel-core/seatunnel-core-sql/pom.xml | 10 ---
seatunnel-dist/release-docs/LICENSE | 44 +++++--------
.../seatunnel-flink-examples/pom.xml | 7 --
seatunnel-examples/seatunnel-sql-examples/pom.xml | 1 -
.../flink/transform/DataStreamToTable.java | 2 +-
.../org/apache/seatunnel/flink/transform/Sql.java | 4 +-
.../flink/transform/TableToDataStream.java | 4 +-
tools/dependencies/checkLicense.sh | 0
tools/dependencies/known-dependencies.txt | 77 +++++++++-------------
20 files changed, 91 insertions(+), 133 deletions(-)
diff --git a/pom.xml b/pom.xml
index 9e76053..54e46b4 100644
--- a/pom.xml
+++ b/pom.xml
@@ -70,7 +70,7 @@
<spark.version>2.4.0</spark.version>
<spark.binary.version>2.4</spark.binary.version>
<neo4j.connector.spark.version>4.1.0</neo4j.connector.spark.version>
- <flink.version>1.9.0</flink.version>
+ <flink.version>1.13.5</flink.version>
<hudi.version>0.10.0</hudi.version>
<hadoop.binary.version>2.7</hadoop.binary.version>
<hadoop.version>2.7.5</hadoop.version>
@@ -181,16 +181,17 @@
<version>${flink.version}</version>
<scope>${flink.scope}</scope>
</dependency>
+
<dependency>
<groupId>org.apache.flink</groupId>
-
<artifactId>flink-streaming-scala_${scala.binary.version}</artifactId>
+
<artifactId>flink-streaming-java_${scala.binary.version}</artifactId>
<version>${flink.version}</version>
<scope>${flink.scope}</scope>
</dependency>
<dependency>
<groupId>org.apache.flink</groupId>
-
<artifactId>flink-streaming-java_${scala.binary.version}</artifactId>
+
<artifactId>flink-connector-jdbc_${scala.binary.version}</artifactId>
<version>${flink.version}</version>
<scope>${flink.scope}</scope>
</dependency>
diff --git
a/seatunnel-apis/seatunnel-api-flink/src/main/java/org/apache/seatunnel/flink/FlinkEnvironment.java
b/seatunnel-apis/seatunnel-api-flink/src/main/java/org/apache/seatunnel/flink/FlinkEnvironment.java
index a6cd9fd..9d7e208 100644
---
a/seatunnel-apis/seatunnel-api-flink/src/main/java/org/apache/seatunnel/flink/FlinkEnvironment.java
+++
b/seatunnel-apis/seatunnel-api-flink/src/main/java/org/apache/seatunnel/flink/FlinkEnvironment.java
@@ -35,8 +35,8 @@ import
org.apache.flink.streaming.api.environment.CheckpointConfig;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.apache.flink.table.api.EnvironmentSettings;
import org.apache.flink.table.api.TableConfig;
-import org.apache.flink.table.api.java.BatchTableEnvironment;
-import org.apache.flink.table.api.java.StreamTableEnvironment;
+import org.apache.flink.table.api.bridge.java.BatchTableEnvironment;
+import org.apache.flink.table.api.bridge.java.StreamTableEnvironment;
import org.apache.flink.util.TernaryBoolean;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
diff --git
a/seatunnel-apis/seatunnel-api-flink/src/main/java/org/apache/seatunnel/flink/batch/FlinkBatchExecution.java
b/seatunnel-apis/seatunnel-api-flink/src/main/java/org/apache/seatunnel/flink/batch/FlinkBatchExecution.java
index 3db20a0..4de7312 100644
---
a/seatunnel-apis/seatunnel-api-flink/src/main/java/org/apache/seatunnel/flink/batch/FlinkBatchExecution.java
+++
b/seatunnel-apis/seatunnel-api-flink/src/main/java/org/apache/seatunnel/flink/batch/FlinkBatchExecution.java
@@ -27,7 +27,7 @@ import org.apache.seatunnel.shade.com.typesafe.config.Config;
import org.apache.flink.api.java.DataSet;
import org.apache.flink.table.api.Table;
-import org.apache.flink.table.api.java.BatchTableEnvironment;
+import org.apache.flink.table.api.bridge.java.BatchTableEnvironment;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
diff --git
a/seatunnel-apis/seatunnel-api-flink/src/main/java/org/apache/seatunnel/flink/stream/FlinkStreamExecution.java
b/seatunnel-apis/seatunnel-api-flink/src/main/java/org/apache/seatunnel/flink/stream/FlinkStreamExecution.java
index 4709c82..64687ab 100644
---
a/seatunnel-apis/seatunnel-api-flink/src/main/java/org/apache/seatunnel/flink/stream/FlinkStreamExecution.java
+++
b/seatunnel-apis/seatunnel-api-flink/src/main/java/org/apache/seatunnel/flink/stream/FlinkStreamExecution.java
@@ -27,7 +27,7 @@ import org.apache.seatunnel.shade.com.typesafe.config.Config;
import org.apache.flink.streaming.api.datastream.DataStream;
import org.apache.flink.table.api.Table;
-import org.apache.flink.table.api.java.StreamTableEnvironment;
+import org.apache.flink.table.api.bridge.java.StreamTableEnvironment;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
diff --git
a/seatunnel-apis/seatunnel-api-flink/src/main/java/org/apache/seatunnel/flink/util/TableUtil.java
b/seatunnel-apis/seatunnel-api-flink/src/main/java/org/apache/seatunnel/flink/util/TableUtil.java
index 5d9be61..06878d0 100644
---
a/seatunnel-apis/seatunnel-api-flink/src/main/java/org/apache/seatunnel/flink/util/TableUtil.java
+++
b/seatunnel-apis/seatunnel-api-flink/src/main/java/org/apache/seatunnel/flink/util/TableUtil.java
@@ -22,8 +22,8 @@ import org.apache.flink.api.java.DataSet;
import org.apache.flink.streaming.api.datastream.DataStream;
import org.apache.flink.table.api.Table;
import org.apache.flink.table.api.TableEnvironment;
-import org.apache.flink.table.api.java.BatchTableEnvironment;
-import org.apache.flink.table.api.java.StreamTableEnvironment;
+import org.apache.flink.table.api.bridge.java.BatchTableEnvironment;
+import org.apache.flink.table.api.bridge.java.StreamTableEnvironment;
import org.apache.flink.table.catalog.Catalog;
import org.apache.flink.table.catalog.ObjectPath;
import org.apache.flink.types.Row;
diff --git
a/seatunnel-connectors/seatunnel-connector-flink-doris/src/main/java/org/apache/seatunnel/flink/sink/DorisSink.java
b/seatunnel-connectors/seatunnel-connector-flink-doris/src/main/java/org/apache/seatunnel/flink/sink/DorisSink.java
index 5709942..6318fde 100644
---
a/seatunnel-connectors/seatunnel-connector-flink-doris/src/main/java/org/apache/seatunnel/flink/sink/DorisSink.java
+++
b/seatunnel-connectors/seatunnel-connector-flink-doris/src/main/java/org/apache/seatunnel/flink/sink/DorisSink.java
@@ -31,8 +31,8 @@ import org.apache.flink.api.java.operators.DataSink;
import org.apache.flink.streaming.api.datastream.DataStream;
import org.apache.flink.streaming.api.datastream.DataStreamSink;
import org.apache.flink.table.api.Table;
-import org.apache.flink.table.api.java.BatchTableEnvironment;
-import org.apache.flink.table.api.java.StreamTableEnvironment;
+import org.apache.flink.table.api.bridge.java.BatchTableEnvironment;
+import org.apache.flink.table.api.bridge.java.StreamTableEnvironment;
import org.apache.flink.types.Row;
import org.apache.flink.util.Preconditions;
diff --git a/seatunnel-connectors/seatunnel-connector-flink-jdbc/pom.xml
b/seatunnel-connectors/seatunnel-connector-flink-jdbc/pom.xml
index eddbcdb..bef60e0 100644
--- a/seatunnel-connectors/seatunnel-connector-flink-jdbc/pom.xml
+++ b/seatunnel-connectors/seatunnel-connector-flink-jdbc/pom.xml
@@ -57,7 +57,7 @@
<dependency>
<groupId>org.apache.flink</groupId>
- <artifactId>flink-jdbc_${scala.binary.version}</artifactId>
+
<artifactId>flink-connector-jdbc_${scala.binary.version}</artifactId>
</dependency>
</dependencies>
diff --git
a/seatunnel-connectors/seatunnel-connector-flink-jdbc/src/main/java/org/apache/seatunnel/flink/sink/JdbcSink.java
b/seatunnel-connectors/seatunnel-connector-flink-jdbc/src/main/java/org/apache/seatunnel/flink/sink/JdbcSink.java
index 24244da..4e8b51a 100644
---
a/seatunnel-connectors/seatunnel-connector-flink-jdbc/src/main/java/org/apache/seatunnel/flink/sink/JdbcSink.java
+++
b/seatunnel-connectors/seatunnel-connector-flink-jdbc/src/main/java/org/apache/seatunnel/flink/sink/JdbcSink.java
@@ -22,19 +22,15 @@ import org.apache.seatunnel.common.config.CheckResult;
import org.apache.seatunnel.flink.FlinkEnvironment;
import org.apache.seatunnel.flink.batch.FlinkBatchSink;
import org.apache.seatunnel.flink.stream.FlinkStreamSink;
-import org.apache.seatunnel.flink.util.SchemaUtil;
import org.apache.seatunnel.shade.com.typesafe.config.Config;
-import org.apache.flink.api.common.typeinfo.TypeInformation;
import org.apache.flink.api.java.DataSet;
-import org.apache.flink.api.java.io.jdbc.JDBCAppendTableSink;
import org.apache.flink.api.java.operators.DataSink;
import org.apache.flink.streaming.api.datastream.DataStream;
import org.apache.flink.streaming.api.datastream.DataStreamSink;
import org.apache.flink.table.api.Table;
import org.apache.flink.table.api.TableEnvironment;
-import org.apache.flink.table.sinks.TableSink;
import org.apache.flink.types.Row;
public class JdbcSink implements FlinkStreamSink<Row, Row>,
FlinkBatchSink<Row, Row> {
@@ -94,20 +90,21 @@ public class JdbcSink implements FlinkStreamSink<Row, Row>,
FlinkBatchSink<Row,
}
private void createSink(TableEnvironment tableEnvironment, Table table) {
- TypeInformation<?>[] fieldTypes = table.getSchema().getFieldTypes();
- String[] fieldNames = table.getSchema().getFieldNames();
- TableSink sink = JDBCAppendTableSink.builder()
- .setDrivername(driverName)
- .setDBUrl(dbUrl)
- .setUsername(username)
- .setPassword(password)
- .setBatchSize(batchSize)
- .setQuery(query)
- .setParameterTypes(fieldTypes)
- .build()
- .configure(fieldNames, fieldTypes);
- String uniqueTableName = SchemaUtil.getUniqueTableName();
- tableEnvironment.registerTableSink(uniqueTableName, sink);
- table.insertInto(uniqueTableName);
+ /* TypeInformation<?>[] fieldTypes =
table.getSchema().getFieldTypes();
+ String[] fieldNames = table.getSchema().getFieldNames();
+ TableSink sink = JDBCAppendTableSink.builder()
+ .setDrivername(driverName)
+ .setDBUrl(dbUrl)
+ .setUsername(username)
+ .setPassword(password)
+ .setBatchSize(batchSize)
+ .setQuery(query)
+ .setParameterTypes(fieldTypes)
+ .build()
+ .configure(fieldNames, fieldTypes);
+ String uniqueTableName = SchemaUtil.getUniqueTableName();
+ tableEnvironment.registerTableSink(uniqueTableName, sink);
+ table.insertInto(uniqueTableName);
+ */
}
}
diff --git
a/seatunnel-connectors/seatunnel-connector-flink-jdbc/src/main/java/org/apache/seatunnel/flink/source/JdbcSource.java
b/seatunnel-connectors/seatunnel-connector-flink-jdbc/src/main/java/org/apache/seatunnel/flink/source/JdbcSource.java
index 5abf144..6025bca 100644
---
a/seatunnel-connectors/seatunnel-connector-flink-jdbc/src/main/java/org/apache/seatunnel/flink/source/JdbcSource.java
+++
b/seatunnel-connectors/seatunnel-connector-flink-jdbc/src/main/java/org/apache/seatunnel/flink/source/JdbcSource.java
@@ -38,8 +38,8 @@ import org.apache.seatunnel.shade.com.typesafe.config.Config;
import org.apache.flink.api.common.typeinfo.SqlTimeTypeInfo;
import org.apache.flink.api.common.typeinfo.TypeInformation;
import org.apache.flink.api.java.DataSet;
-import org.apache.flink.api.java.io.jdbc.JDBCInputFormat;
import org.apache.flink.api.java.typeutils.RowTypeInfo;
+import org.apache.flink.connector.jdbc.JdbcInputFormat;
import org.apache.flink.types.Row;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -73,7 +73,7 @@ public class JdbcSource implements FlinkBatchSource<Row> {
private HashMap<String, TypeInformation> informationMapping = new
HashMap<>();
- private JDBCInputFormat jdbcInputFormat;
+ private JdbcInputFormat jdbcInputFormat;
{
informationMapping.put("VARCHAR", STRING_TYPE_INFO);
@@ -145,7 +145,7 @@ public class JdbcSource implements FlinkBatchSource<Row> {
fetchSize = config.getInt("fetch_size");
}
- jdbcInputFormat = JDBCInputFormat.buildJDBCInputFormat()
+ jdbcInputFormat = JdbcInputFormat.buildJdbcInputFormat()
.setDrivername(driverName)
.setDBUrl(dbUrl)
.setUsername(username)
diff --git
a/seatunnel-connectors/seatunnel-connector-flink-kafka/src/main/java/org/apache/seatunnel/flink/sink/KafkaTable.java
b/seatunnel-connectors/seatunnel-connector-flink-kafka/src/main/java/org/apache/seatunnel/flink/sink/KafkaTable.java
index 87563e6..cc19203 100644
---
a/seatunnel-connectors/seatunnel-connector-flink-kafka/src/main/java/org/apache/seatunnel/flink/sink/KafkaTable.java
+++
b/seatunnel-connectors/seatunnel-connector-flink-kafka/src/main/java/org/apache/seatunnel/flink/sink/KafkaTable.java
@@ -31,7 +31,7 @@ import org.apache.flink.streaming.api.datastream.DataStream;
import org.apache.flink.streaming.api.datastream.DataStreamSink;
import org.apache.flink.table.api.Table;
import org.apache.flink.table.api.TableEnvironment;
-import org.apache.flink.table.api.java.StreamTableEnvironment;
+import org.apache.flink.table.api.bridge.java.StreamTableEnvironment;
import org.apache.flink.table.descriptors.FormatDescriptor;
import org.apache.flink.table.descriptors.Json;
import org.apache.flink.table.descriptors.Kafka;
@@ -60,11 +60,12 @@ public class KafkaTable implements FlinkStreamSink<Row,
Row> {
String[] fieldNames = table.getSchema().getFieldNames();
Schema schema = getSchema(types, fieldNames);
String uniqueTableName = SchemaUtil.getUniqueTableName();
+
tableEnvironment.connect(getKafkaConnect())
.withSchema(schema)
.withFormat(setFormat())
.inAppendMode()
- .registerTableSink(uniqueTableName);
+ .createTemporaryTable(uniqueTableName);
table.insertInto(uniqueTableName);
}
diff --git
a/seatunnel-connectors/seatunnel-connector-flink-kafka/src/main/java/org/apache/seatunnel/flink/source/KafkaTableStream.java
b/seatunnel-connectors/seatunnel-connector-flink-kafka/src/main/java/org/apache/seatunnel/flink/source/KafkaTableStream.java
index 832a8f0..63ce2db 100644
---
a/seatunnel-connectors/seatunnel-connector-flink-kafka/src/main/java/org/apache/seatunnel/flink/source/KafkaTableStream.java
+++
b/seatunnel-connectors/seatunnel-connector-flink-kafka/src/main/java/org/apache/seatunnel/flink/source/KafkaTableStream.java
@@ -33,7 +33,7 @@ import com.alibaba.fastjson.parser.Feature;
import org.apache.commons.lang3.StringUtils;
import org.apache.flink.streaming.api.datastream.DataStream;
import org.apache.flink.table.api.Table;
-import org.apache.flink.table.api.java.StreamTableEnvironment;
+import org.apache.flink.table.api.bridge.java.StreamTableEnvironment;
import org.apache.flink.table.descriptors.FormatDescriptor;
import org.apache.flink.table.descriptors.Kafka;
import org.apache.flink.table.descriptors.Rowtime;
@@ -118,7 +118,7 @@ public class KafkaTableStream implements
FlinkStreamSource<Row> {
.withFormat(setFormat())
.withSchema(getSchema())
.inAppendMode()
- .registerTableSource(tableName);
+ .createTemporaryTable(tableName);
Table table = tableEnvironment.scan(tableName);
return TableUtil.tableToDataStream(tableEnvironment, table, true);
}
diff --git a/seatunnel-core/seatunnel-core-sql/pom.xml
b/seatunnel-core/seatunnel-core-sql/pom.xml
index 53c46ee..3ae7a66 100644
--- a/seatunnel-core/seatunnel-core-sql/pom.xml
+++ b/seatunnel-core/seatunnel-core-sql/pom.xml
@@ -30,11 +30,6 @@
<artifactId>seatunnel-core-sql</artifactId>
- <properties>
- <flink.version>1.13.3</flink.version>
- <scala.binary.version>2.11</scala.binary.version>
- </properties>
-
<dependencies>
<dependency>
<groupId>org.apache.seatunnel</groupId>
@@ -62,11 +57,6 @@
<version>${flink.version}</version>
</dependency>
<dependency>
- <groupId>org.apache.flink</groupId>
-
<artifactId>flink-streaming-scala_${scala.binary.version}</artifactId>
- <version>${flink.version}</version>
- </dependency>
- <dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
</dependency>
diff --git a/seatunnel-dist/release-docs/LICENSE
b/seatunnel-dist/release-docs/LICENSE
index 26bf284..7788598 100644
--- a/seatunnel-dist/release-docs/LICENSE
+++ b/seatunnel-dist/release-docs/LICENSE
@@ -224,7 +224,6 @@ The text of each license is the standard Apache 2.0 license.
(The Apache Software License, Version 2.0) Aggregate Designer Algorithm
(net.hydromatic:aggdesigner-algorithm:6.0 -
http://github.com/julianhyde/aggdesigner/aggdesigner-algorithm)
(The Apache Software License, Version 2.0) aggs-matrix-stats
(org.elasticsearch.plugin:aggs-matrix-stats-client:6.3.1 -
https://github.com/elastic/elasticsearch)
(Apache License 2.0) aircompressor (io.airlift:aircompressor:0.10 -
http://github.com/airlift/aircompressor)
- (Apache License 2.0) aircompressor (io.airlift:aircompressor:0.8 -
http://github.com/airlift/aircompressor)
(Apache License 2.0) airline (io.airlift:airline:0.7 -
https://github.com/airlift/airline)
(The Apache Software License, Version 2.0) IntelliJ IDEA Annotations
(org.jetbrains:annotations:13.0 - http://www.jetbrains.org)
(The Apache License, Version 2.0) org.apiguardian:apiguardian-api
(org.apiguardian:apiguardian-api:1.1.0 -
https://github.com/apiguardian-team/apiguardian)
@@ -268,6 +267,7 @@ The text of each license is the standard Apache 2.0 license.
(Apache License, Version 2.0) Apache Commons Collections
(org.apache.commons:commons-collections4:4.4 -
https://commons.apache.org/proper/commons-collections/)
(Apache License, Version 2.0) Apache Commons Compress
(org.apache.commons:commons-compress:1.18 -
https://commons.apache.org/proper/commons-compress/)
(Apache License, Version 2.0) Apache Commons Compress
(org.apache.commons:commons-compress:1.19 -
https://commons.apache.org/proper/commons-compress/)
+ (Apache License, Version 2.0) Apache Commons Compress
(org.apache.commons:commons-compress:1.20 -
https://commons.apache.org/proper/commons-compress/)
(Apache License, Version 2.0) Apache Commons Compress
(org.apache.commons:commons-compress:1.21 -
https://commons.apache.org/proper/commons-compress/)
(The Apache Software License, Version 2.0) Commons Compress
(org.apache.commons:commons-compress:1.4.1 -
http://commons.apache.org/compress/)
(The Apache Software License, Version 2.0) Apache Commons Compress
(org.apache.commons:commons-compress:1.8.1 -
http://commons.apache.org/proper/commons-compress/)
@@ -354,24 +354,18 @@ The text of each license is the standard Apache 2.0
license.
(Apache License, Version 2.0) fastutil (it.unimi.dsi:fastutil-extra:8.5.4
- http://fastutil.di.unimi.it/)
(Apache License, Version 2.0) fastutil (it.unimi.dsi:fastutil-core:8.5.4
- http://fastutil.di.unimi.it/)
(Apache License, Version 2.0) fastutil (it.unimi.dsi:fastutil:8.5.4 -
http://fastutil.di.unimi.it/)
- (The Apache Software License, Version 2.0) Flink : Formats : Avro
(org.apache.flink:flink-avro:1.13.3 -
https://flink.apache.org/flink-formats/flink-avro)
- (The Apache Software License, Version 2.0) flink-avro
(org.apache.flink:flink-avro:1.9.0 -
http://flink.apache.org/flink-formats/flink-avro)
- (The Apache Software License, Version 2.0)
flink-connector-elasticsearch-base
(org.apache.flink:flink-connector-elasticsearch-base_2.11:1.9.0 -
http://flink.apache.org/flink-connectors/flink-connector-elasticsearch-base_2.11)
- (The Apache Software License, Version 2.0) flink-connector-elasticsearch6
(org.apache.flink:flink-connector-elasticsearch6_2.11:1.9.0 -
http://flink.apache.org/flink-connectors/flink-connector-elasticsearch6_2.11)
- (The Apache Software License, Version 2.0) flink-connector-kafka-base
(org.apache.flink:flink-connector-kafka-base_2.11:1.9.0 -
http://flink.apache.org/flink-connectors/flink-connector-kafka-base_2.11)
- (The Apache Software License, Version 2.0) flink-connector-kafka
(org.apache.flink:flink-connector-kafka_2.11:1.9.0 -
http://flink.apache.org/flink-connectors/flink-connector-kafka_2.11)
- (The Apache Software License, Version 2.0) Flink : Formats : Csv
(org.apache.flink:flink-csv:1.13.3 -
https://flink.apache.org/flink-formats/flink-csv)
- (The Apache Software License, Version 2.0) flink-csv
(org.apache.flink:flink-csv:1.9.0 -
http://flink.apache.org/flink-formats/flink-csv)
- (The Apache Software License, Version 2.0) flink-jdbc
(org.apache.flink:flink-jdbc_2.11:1.9.0 -
http://flink.apache.org/flink-connectors/flink-jdbc_2.11)
- (The Apache Software License, Version 2.0) Flink : Formats : Json
(org.apache.flink:flink-json:1.13.3 -
https://flink.apache.org/flink-formats/flink-json)
- (The Apache Software License, Version 2.0) flink-json
(org.apache.flink:flink-json:1.9.0 -
http://flink.apache.org/flink-formats/flink-json)
- (The Apache Software License, Version 2.0) Flink : Formats : Orc
(org.apache.flink:flink-orc_2.11:1.13.3 -
https://flink.apache.org/flink-formats/flink-orc_2.11)
- (The Apache Software License, Version 2.0) flink-orc
(org.apache.flink:flink-orc_2.11:1.9.0 -
http://flink.apache.org/flink-connectors/flink-orc_2.11)
- (The Apache Software License, Version 2.0) Flink : Formats : Parquet
(org.apache.flink:flink-parquet_2.11:1.13.3 -
https://flink.apache.org/flink-formats/flink-parquet_2.11)
- (The Apache Software License, Version 2.0) flink-parquet
(org.apache.flink:flink-parquet_2.11:1.9.0 -
http://flink.apache.org/flink-formats/flink-parquet_2.11)
- (The Apache Software License, Version 2.0) Flink : State backends :
RocksDB (org.apache.flink:flink-statebackend-rocksdb_2.11:1.13.3 -
https://flink.apache.org/flink-state-backends/flink-statebackend-rocksdb_2.11)
- (The Apache Software License, Version 2.0) flink-statebackend-rocksdb
(org.apache.flink:flink-statebackend-rocksdb_2.11:1.9.0 -
http://flink.apache.org/flink-state-backends/flink-statebackend-rocksdb_2.11)
- (Apache License, Version 2.0) Flink : Tools : Force Shading
(org.apache.flink:force-shading:1.13.3 - https://www.apache.org/force-shading/)
+ (The Apache Software License, Version 2.0) Flink : Connectors : Base
(org.apache.flink:flink-connector-base:1.13.5 -
http://flink.apache.org/flink-connectors/flink-connector-base)
+ (The Apache Software License, Version 2.0) Flink : Formats : Avro
(org.apache.flink:flink-avro:1.13.5 -
https://flink.apache.org/flink-formats/flink-avro)
+ (The Apache Software License, Version 2.0)
flink-connector-elasticsearch-base
(org.apache.flink:flink-connector-elasticsearch-base_2.11:1.13.5 -
http://flink.apache.org/flink-connectors/flink-connector-elasticsearch-base_2.11)
+ (The Apache Software License, Version 2.0) flink-connector-elasticsearch6
(org.apache.flink:flink-connector-elasticsearch6_2.11:1.13.5 -
http://flink.apache.org/flink-connectors/flink-connector-elasticsearch6_2.11)
+ (The Apache Software License, Version 2.0) flink-connector-kafka
(org.apache.flink:flink-connector-kafka_2.11:1.13.5 -
http://flink.apache.org/flink-connectors/flink-connector-kafka_2.11)
+ (The Apache Software License, Version 2.0) Flink : Formats : Csv
(org.apache.flink:flink-csv:1.13.5 -
https://flink.apache.org/flink-formats/flink-csv)
+ (The Apache Software License, Version 2.0) Flink : Formats : Json
(org.apache.flink:flink-json:1.13.5 -
https://flink.apache.org/flink-formats/flink-json)
+ (The Apache Software License, Version 2.0) Flink : Formats : Orc
(org.apache.flink:flink-orc_2.11:1.13.5 -
https://flink.apache.org/flink-formats/flink-orc_2.11)
+ (The Apache Software License, Version 2.0) Flink : Formats : Parquet
(org.apache.flink:flink-parquet_2.11:1.13.5 -
https://flink.apache.org/flink-formats/flink-parquet_2.11)
+ (The Apache Software License, Version 2.0) Flink : State backends :
RocksDB (org.apache.flink:flink-statebackend-rocksdb_2.11:1.13.5 -
https://flink.apache.org/flink-state-backends/flink-statebackend-rocksdb_2.11)
+ (The Apache Software License, Version 2.0) flink-statebackend-rocksdb
(org.apache.flink:flink-statebackend-rocksdb_2.11:1.13.5 -
http://flink.apache.org/flink-state-backends/flink-statebackend-rocksdb_2.11)
+ (Apache License, Version 2.0) Flink : Tools : Force Shading
(org.apache.flink:force-shading:1.13.5 - https://www.apache.org/force-shading/)
(Apache License, Version 2.0) force-shading
(org.apache.flink:force-shading:1.9.0 - https://www.apache.org/force-shading/)
(The Apache Software License, Version 2.0) Google APIs Client Library for
Java (com.google.api-client:google-api-client:1.26.0 -
https://github.com/google/google-api-java-client/google-api-client)
(The Apache Software License, Version 2.0) Google HTTP Client Library for
Java (com.google.http-client:google-http-client:1.26.0 -
https://github.com/googleapis/google-http-java-client/google-http-client)
@@ -456,7 +450,6 @@ The text of each license is the standard Apache 2.0 license.
(The Apache Software License, Version 2.0) Hive Beeline
(org.spark-project.hive:hive-beeline:1.2.1.spark2 -
http://hive.apache.org/hive-beeline)
(The Apache Software License, Version 2.0) Hive CLI
(org.spark-project.hive:hive-cli:1.2.1.spark2 - http://hive.apache.org/hive-cli)
(The Apache Software License, Version 2.0) Hive JDBC
(org.spark-project.hive:hive-jdbc:1.2.1.spark2 -
http://hive.apache.org/hive-jdbc)
- (Apache License, Version 2.0) Hive Storage API
(org.apache.hive:hive-storage-api:2.2.1 -
https://www.apache.org/hive-storage-api/)
(Apache License, Version 2.0) Hive Storage API
(org.apache.hive:hive-storage-api:2.6.0 -
https://www.apache.org/hive-storage-api/)
(The Apache Software License, Version 2.0) HPPC Collections
(com.carrotsearch:hppc:0.7.1 - http://labs.carrotsearch.com/hppc.html/hppc)
(The Apache Software License, Version 2.0) htrace-core
(org.htrace:htrace-core:3.0.4 - https://github.com/cloudera/htrace)
@@ -476,7 +469,6 @@ The text of each license is the standard Apache 2.0 license.
(The Apache Software License, Version 2.0) Jackson-core
(com.fasterxml.jackson.core:jackson-core:2.11.0 -
https://github.com/FasterXML/jackson-core)
(The Apache Software License, Version 2.0) Jackson-core
(com.fasterxml.jackson.core:jackson-core:2.6.7 -
https://github.com/FasterXML/jackson-core)
(The Apache Software License, Version 2.0) Jackson-core
(com.fasterxml.jackson.core:jackson-core:2.7.3 -
https://github.com/FasterXML/jackson-core)
- (The Apache Software License, Version 2.0) Jackson-core
(com.fasterxml.jackson.core:jackson-core:2.8.10 -
https://github.com/FasterXML/jackson-core)
(The Apache Software License, Version 2.0) Jackson
(org.codehaus.jackson:jackson-core-asl:1.9.13 - http://jackson.codehaus.org)
(The Apache Software License, Version 2.0) Jackson
(org.codehaus.jackson:jackson-core-asl:1.9.2 - http://jackson.codehaus.org)
(The Apache Software License, Version 2.0) jackson-databind
(com.fasterxml.jackson.core:jackson-databind:2.10.5.1 -
http://github.com/FasterXML/jackson)
@@ -549,7 +541,7 @@ The text of each license is the standard Apache 2.0 license.
(The Apache Software License, Version 2.0) FindBugs-jsr305
(com.google.code.findbugs:jsr305:1.3.9 - http://findbugs.sourceforge.net/)
(The Apache Software License, Version 2.0)
org.gridkit.lab::jvm-attach-api (org.gridkit.lab:jvm-attach-api:1.5 -
http://code.google.com/p/gridkit/jvm-attach-api)
(The Apache Software License, Version 2.0) Apache Kafka
(org.apache.kafka:kafka-clients:2.0.0 - http://kafka.apache.org)
- (The Apache Software License, Version 2.0) Apache Kafka
(org.apache.kafka:kafka-clients:2.2.0 - http://kafka.apache.org)
+ (The Apache Software License, Version 2.0) Apache Kafka
(org.apache.kafka:kafka-clients:2.4.1 - http://kafka.apache.org)
(Apache License, Version 2.0) Kerby-kerb Admin
(org.apache.kerby:kerb-admin:1.0.1 -
http://directory.apache.org/kerby/kerby-kerb/kerb-admin)
(Apache License, Version 2.0) Kerby-kerb Client
(org.apache.kerby:kerb-client:1.0.1 -
http://directory.apache.org/kerby/kerby-kerb/kerb-client)
(Apache License, Version 2.0) Kerby-kerb Common
(org.apache.kerby:kerb-common:1.0.1 -
http://directory.apache.org/kerby/kerby-kerb/kerb-common)
@@ -581,7 +573,6 @@ The text of each license is the standard Apache 2.0 license.
(Apache License, Version 2.0) Apache Log4j Core
(org.apache.logging.log4j:log4j-core:2.8.2 -
https://logging.apache.org/log4j/2.x/log4j-core/)
(Apache License, Version 2.0) Apache Log4j JUL Adapter
(org.apache.logging.log4j:log4j-jul:2.8.2 -
https://logging.apache.org/log4j/2.x/log4j-jul/)
(Apache License, Version 2.0) Apache Log4j SLF4J Binding
(org.apache.logging.log4j:log4j-slf4j-impl:2.8.2 -
https://logging.apache.org/log4j/2.x/log4j-slf4j-impl/)
- (Apache License, Version 2.0) Apache Log4j to SLF4J Adapter
(org.apache.logging.log4j:log4j-to-slf4j:2.9.1 -
https://logging.apache.org/log4j/2.x/log4j-to-slf4j/)
(The Apache Software License, Version 2.0) okhttp-logging-interceptor
(com.squareup.okhttp3:logging-interceptor:4.9.1 -
https://square.github.io/okhttp/)
(Apache 2) Lucene Common Analyzers
(org.apache.lucene:lucene-analyzers-common:7.3.1 -
http://lucene.apache.org/lucene-parent/lucene-analyzers-common)
(Apache 2) Lucene Memory (org.apache.lucene:lucene-backward-codecs:7.3.1
- http://lucene.apache.org/lucene-parent/lucene-backward-codecs)
@@ -601,7 +592,7 @@ The text of each license is the standard Apache 2.0 license.
(The Apache Software License, Version 2.0) LZ4 and xxHash
(net.jpountz.lz4:lz4:1.3.0 - https://github.com/jpountz/lz4-java)
(The Apache Software License, Version 2.0) LZ4 and xxHash
(org.lz4:lz4-java:1.4.0 - https://github.com/lz4/lz4-java)
(The Apache Software License, Version 2.0) LZ4 and xxHash
(org.lz4:lz4-java:1.4.1 - https://github.com/lz4/lz4-java)
- (The Apache Software License, Version 2.0) LZ4 and xxHash
(org.lz4:lz4-java:1.5.0 - https://github.com/lz4/lz4-java)
+ (The Apache Software License, Version 2.0) LZ4 and xxHash
(org.lz4:lz4-java:1.6.0 - https://github.com/lz4/lz4-java)
(The Apache Software License, Version 2.0) LZ4 and xxHash
(org.lz4:lz4-java:1.7.1 - https://github.com/lz4/lz4-java)
(The Apache Software License, Version 2.0) Maven Aether Provider
(org.apache.maven:maven-aether-provider:3.1.1 -
http://maven.apache.org/ref/3.1.1/maven-aether-provider)
(Apache License, Version 2.0) Maven Artifact
(org.apache.maven:maven-artifact:3.6.0 -
https://maven.apache.org/ref/3.6.0/maven-artifact/)
@@ -654,7 +645,6 @@ The text of each license is the standard Apache 2.0 license.
(Apache 2.0) Okio (com.squareup.okio:okio:1.4.0 -
https://github.com/square/okio/okio)
(The Apache Software License, Version 2.0) Okio
(com.squareup.okio:okio:2.8.0 - https://github.com/square/okio/)
(Apache 2) opencsv (com.opencsv:opencsv:4.6 - http://opencsv.sf.net)
- (Apache License, Version 2.0) ORC Core (org.apache.orc:orc-core:1.4.3 -
http://orc.apache.org/orc-core)
(Apache License, Version 2.0) ORC Core (org.apache.orc:orc-core:1.5.6 -
http://orc.apache.org/orc-core)
(Apache License, Version 2.0) ORC Shims (org.apache.orc:orc-shims:1.5.6 -
http://orc.apache.org/orc-shims)
(The Apache Software License, Version 2.0) Jackson module: Paranamer
(com.fasterxml.jackson.module:jackson-module-paranamer:2.7.9 -
https://github.com/FasterXML/jackson-modules-base)
@@ -686,9 +676,9 @@ The text of each license is the standard Apache 2.0 license.
(Apache License, Version 2.0) SnakeYAML (org.yaml:snakeyaml:1.17 -
http://www.snakeyaml.org)
(Apache License, Version 2.0) SnakeYAML (org.yaml:snakeyaml:1.24 -
http://www.snakeyaml.org)
(Apache License 2.0) snappy (org.iq80.snappy:snappy:0.3 -
http://github.com/dain/snappy)
- (The Apache Software License, Version 2.0) snappy-java
(org.xerial.snappy:snappy-java:1.1.2.6 - https://github.com/xerial/snappy-java)
(The Apache Software License, Version 2.0) snappy-java
(org.xerial.snappy:snappy-java:1.1.4 - https://github.com/xerial/snappy-java)
(The Apache Software License, Version 2.0) snappy-java
(org.xerial.snappy:snappy-java:1.1.7.1 - https://github.com/xerial/snappy-java)
+ (The Apache Software License, Version 2.0) snappy-java
(org.xerial.snappy:snappy-java:1.1.8.3 - https://github.com/xerial/snappy-java)
(Apache 2.0 License) Spark Project Catalyst
(org.apache.spark:spark-catalyst_2.11:2.4.0 - http://spark.apache.org/)
(Apache 2.0 License) Spark Project Hive Thrift Server
(org.apache.spark:spark-hive-thriftserver_2.11:2.3.4 - http://spark.apache.org/)
(Apache 2.0 License) Spark Project Sketch
(org.apache.spark:spark-sketch_2.11:2.4.0 - http://spark.apache.org/)
@@ -827,7 +817,7 @@ The text of each license is also included at
licenses/LICENSE-[project].txt.
(The BSD License) Stax2 API (org.codehaus.woodstox:stax2-api:3.1.4 -
http://wiki.fasterxml.com/WoodstoxStax2)
(The BSD License) xmlenc Library (xmlenc:xmlenc:0.52 -
http://xmlenc.sourceforge.net)
(BSD 2-Clause License) zstd-jni (com.github.luben:zstd-jni:1.3.3-1 -
https://github.com/luben/zstd-jni)
- (BSD 2-Clause License) zstd-jni (com.github.luben:zstd-jni:1.3.8-1 -
https://github.com/luben/zstd-jni)
+ (BSD 2-Clause License) zstd-jni (com.github.luben:zstd-jni:1.4.3-1 -
https://github.com/luben/zstd-jni)
(The Go license) re2j (com.google.re2j:re2j:1.1 -
http://github.com/google/re2j)
========================================
diff --git a/seatunnel-examples/seatunnel-flink-examples/pom.xml
b/seatunnel-examples/seatunnel-flink-examples/pom.xml
index 9116147..a0214b7 100644
--- a/seatunnel-examples/seatunnel-flink-examples/pom.xml
+++ b/seatunnel-examples/seatunnel-flink-examples/pom.xml
@@ -58,13 +58,6 @@
</dependency>
<dependency>
<groupId>org.apache.flink</groupId>
-
<artifactId>flink-streaming-scala_${scala.binary.version}</artifactId>
- <version>${flink.version}</version>
- <scope>${flink.scope}</scope>
- </dependency>
-
- <dependency>
- <groupId>org.apache.flink</groupId>
<artifactId>flink-streaming-java_${scala.binary.version}</artifactId>
<version>${flink.version}</version>
<scope>${flink.scope}</scope>
diff --git a/seatunnel-examples/seatunnel-sql-examples/pom.xml
b/seatunnel-examples/seatunnel-sql-examples/pom.xml
index 66258ea..48609bd 100644
--- a/seatunnel-examples/seatunnel-sql-examples/pom.xml
+++ b/seatunnel-examples/seatunnel-sql-examples/pom.xml
@@ -30,7 +30,6 @@
<artifactId>seatunnel-sql-examples</artifactId>
<properties>
<flink.scope>compile</flink.scope>
- <flink.version>1.13.3</flink.version>
</properties>
<dependencies>
<!--Resolve ConfigParser class conflict between Seatunnel and Flink.
diff --git
a/seatunnel-transforms/seatunnel-transform-flink-datastream2table/src/main/java/org/apache/seatunnel/flink/transform/DataStreamToTable.java
b/seatunnel-transforms/seatunnel-transform-flink-datastream2table/src/main/java/org/apache/seatunnel/flink/transform/DataStreamToTable.java
index fffcfbd..852ba27 100644
---
a/seatunnel-transforms/seatunnel-transform-flink-datastream2table/src/main/java/org/apache/seatunnel/flink/transform/DataStreamToTable.java
+++
b/seatunnel-transforms/seatunnel-transform-flink-datastream2table/src/main/java/org/apache/seatunnel/flink/transform/DataStreamToTable.java
@@ -28,7 +28,7 @@ import org.apache.seatunnel.shade.com.typesafe.config.Config;
import org.apache.flink.api.java.DataSet;
import org.apache.flink.streaming.api.datastream.DataStream;
-import org.apache.flink.table.api.java.StreamTableEnvironment;
+import org.apache.flink.table.api.bridge.java.StreamTableEnvironment;
import org.apache.flink.types.Row;
public class DataStreamToTable implements FlinkStreamTransform<Row, Row>,
FlinkBatchTransform<Row, Row> {
diff --git
a/seatunnel-transforms/seatunnel-transform-flink-sql/src/main/java/org/apache/seatunnel/flink/transform/Sql.java
b/seatunnel-transforms/seatunnel-transform-flink-sql/src/main/java/org/apache/seatunnel/flink/transform/Sql.java
index ac350f7..6364a23 100644
---
a/seatunnel-transforms/seatunnel-transform-flink-sql/src/main/java/org/apache/seatunnel/flink/transform/Sql.java
+++
b/seatunnel-transforms/seatunnel-transform-flink-sql/src/main/java/org/apache/seatunnel/flink/transform/Sql.java
@@ -29,8 +29,8 @@ import org.apache.seatunnel.shade.com.typesafe.config.Config;
import org.apache.flink.api.java.DataSet;
import org.apache.flink.streaming.api.datastream.DataStream;
import org.apache.flink.table.api.Table;
-import org.apache.flink.table.api.java.BatchTableEnvironment;
-import org.apache.flink.table.api.java.StreamTableEnvironment;
+import org.apache.flink.table.api.bridge.java.BatchTableEnvironment;
+import org.apache.flink.table.api.bridge.java.StreamTableEnvironment;
import org.apache.flink.types.Row;
public class Sql implements FlinkStreamTransform<Row, Row>,
FlinkBatchTransform<Row, Row> {
diff --git
a/seatunnel-transforms/seatunnel-transform-flink-table2datastream/src/main/java/org/apache/seatunnel/flink/transform/TableToDataStream.java
b/seatunnel-transforms/seatunnel-transform-flink-table2datastream/src/main/java/org/apache/seatunnel/flink/transform/TableToDataStream.java
index 0b3d04d..140745d 100644
---
a/seatunnel-transforms/seatunnel-transform-flink-table2datastream/src/main/java/org/apache/seatunnel/flink/transform/TableToDataStream.java
+++
b/seatunnel-transforms/seatunnel-transform-flink-table2datastream/src/main/java/org/apache/seatunnel/flink/transform/TableToDataStream.java
@@ -30,8 +30,8 @@ import org.apache.seatunnel.shade.com.typesafe.config.Config;
import org.apache.flink.api.java.DataSet;
import org.apache.flink.streaming.api.datastream.DataStream;
import org.apache.flink.table.api.Table;
-import org.apache.flink.table.api.java.BatchTableEnvironment;
-import org.apache.flink.table.api.java.StreamTableEnvironment;
+import org.apache.flink.table.api.bridge.java.BatchTableEnvironment;
+import org.apache.flink.table.api.bridge.java.StreamTableEnvironment;
import org.apache.flink.types.Row;
public class TableToDataStream implements FlinkStreamTransform<Row, Row>,
FlinkBatchTransform<Row, Row> {
diff --git a/tools/dependencies/checkLicense.sh
b/tools/dependencies/checkLicense.sh
old mode 100644
new mode 100755
diff --git a/tools/dependencies/known-dependencies.txt
b/tools/dependencies/known-dependencies.txt
index 1473e49..53b807f 100755
--- a/tools/dependencies/known-dependencies.txt
+++ b/tools/dependencies/known-dependencies.txt
@@ -1,6 +1,3 @@
-HdrHistogram-2.1.9.jar
-RoaringBitmap-0.9.0.jar
-SparseBitSet-1.2.jar
accessors-smart-1.2.jar
activation-1.1.1.jar
activation-1.1.jar
@@ -13,20 +10,19 @@ aether-util-0.9.0.M2.jar
aggdesigner-algorithm-6.0.jar
aggs-matrix-stats-client-6.3.1.jar
aircompressor-0.10.jar
-aircompressor-0.8.jar
airline-0.7.jar
annotations-13.0.jar
-antlr-runtime-3.5.2.jar
antlr4-runtime-4.5.1.jar
antlr4-runtime-4.7.jar
+antlr-runtime-3.5.2.jar
aopalliance-1.0.jar
aopalliance-repackaged-2.4.0-b34.jar
aopalliance-repackaged-2.5.0-b32.jar
apacheds-i18n-2.0.0-M15.jar
apacheds-kerberos-codec-2.0.0-M15.jar
api-asn1-api-1.0.0-M20.jar
-api-util-1.0.0-M20.jar
apiguardian-api-1.1.0.jar
+api-util-1.0.0-M20.jar
asm-3.1.jar
asm-5.0.4.jar
asm-7.1.jar
@@ -53,8 +49,8 @@ calcite-core-1.29.0.jar
calcite-druid-1.29.0.jar
calcite-linq4j-1.29.0.jar
checker-qual-3.10.0.jar
-chill-java-0.9.3.jar
chill_2.11-0.9.3.jar
+chill-java-0.9.3.jar
classmate-1.1.0.jar
clickhouse-jdbc-0.2.jar
commons-beanutils-1.7.0.jar
@@ -74,6 +70,7 @@ commons-compiler-3.0.9.jar
commons-compiler-3.1.6.jar
commons-compress-1.18.jar
commons-compress-1.19.jar
+commons-compress-1.20.jar
commons-compress-1.21.jar
commons-compress-1.4.1.jar
commons-compress-1.8.1.jar
@@ -155,27 +152,18 @@ fastutil-8.5.4.jar
fastutil-core-8.5.4.jar
fastutil-extra-8.5.4.jar
findbugs-annotations-1.3.9-1.jar
-flink-avro-1.13.3.jar
-flink-avro-1.9.0.jar
-flink-connector-elasticsearch-base_2.11-1.9.0.jar
-flink-connector-elasticsearch6_2.11-1.9.0.jar
-flink-connector-kafka-base_2.11-1.9.0.jar
-flink-connector-kafka_2.11-1.9.0.jar
-flink-csv-1.13.3.jar
-flink-csv-1.9.0.jar
-flink-jdbc_2.11-1.9.0.jar
-flink-json-1.13.3.jar
-flink-json-1.9.0.jar
-flink-orc_2.11-1.13.3.jar
-flink-orc_2.11-1.9.0.jar
-flink-parquet_2.11-1.13.3.jar
-flink-parquet_2.11-1.9.0.jar
+flink-avro-1.13.5.jar
+flink-connector-base-1.13.5.jar
+flink-connector-elasticsearch6_2.11-1.13.5.jar
+flink-connector-elasticsearch-base_2.11-1.13.5.jar
+flink-connector-kafka_2.11-1.13.5.jar
+flink-csv-1.13.5.jar
+flink-json-1.13.5.jar
+flink-orc_2.11-1.13.5.jar
+flink-parquet_2.11-1.13.5.jar
flink-shaded-hadoop-2-2.7.5-7.0.jar
-flink-statebackend-rocksdb_2.11-1.13.3.jar
-flink-statebackend-rocksdb_2.11-1.9.0.jar
-force-shading-1.13.3.jar
-force-shading-1.9.0.jar
-frocksdbjni-5.17.2-artisans-1.0.jar
+flink-statebackend-rocksdb_2.11-1.13.5.jar
+force-shading-1.13.5.jar
frocksdbjni-5.17.2-ververica-2.1.jar
google-api-client-1.26.0.jar
google-http-client-1.26.0.jar
@@ -226,13 +214,13 @@ hadoop-yarn-server-common-2.6.5.jar
hbase-annotations-2.0.0.jar
hbase-client-2.0.0.jar
hbase-client-2.1.0.jar
-hbase-common-2.0.0-tests.jar
hbase-common-2.0.0.jar
+hbase-common-2.0.0-tests.jar
hbase-common-2.1.0.jar
-hbase-hadoop-compat-2.0.0.jar
-hbase-hadoop-compat-2.1.0.jar
hbase-hadoop2-compat-2.0.0.jar
hbase-hadoop2-compat-2.1.0.jar
+hbase-hadoop-compat-2.0.0.jar
+hbase-hadoop-compat-2.1.0.jar
hbase-http-2.0.0.jar
hbase-http-2.1.0.jar
hbase-mapreduce-2.0.0.jar
@@ -257,11 +245,11 @@ hbase-shaded-protobuf-2.1.0.jar
hbase-spark-1.0.0.jar
hbase-zookeeper-2.0.0.jar
hbase-zookeeper-2.1.0.jar
+HdrHistogram-2.1.9.jar
hibernate-validator-5.2.5.Final.jar
hive-beeline-1.2.1.spark2.jar
hive-cli-1.2.1.spark2.jar
hive-jdbc-1.2.1.spark2.jar
-hive-storage-api-2.2.1.jar
hive-storage-api-2.6.0.jar
hk2-api-2.4.0-b34.jar
hk2-api-2.5.0-b32.jar
@@ -296,7 +284,6 @@ jackson-core-2.10.5.jar
jackson-core-2.11.0.jar
jackson-core-2.6.7.jar
jackson-core-2.7.3.jar
-jackson-core-2.8.10.jar
jackson-core-asl-1.9.13.jar
jackson-core-asl-1.9.2.jar
jackson-databind-2.10.5.1.jar
@@ -331,7 +318,6 @@ jakarta.xml.bind-api-2.3.2.jar
jamon-runtime-2.4.1.jar
janino-3.0.9.jar
janino-3.1.6.jar
-java-xmlbuilder-0.4.jar
javassist-3.18.1-GA.jar
javassist-3.20.0-GA.jar
javax.activation-1.2.0.jar
@@ -345,6 +331,7 @@ javax.inject-1.jar
javax.inject-2.4.0-b34.jar
javax.inject-2.5.0-b32.jar
javax.mail-1.5.6.jar
+java-xmlbuilder-0.4.jar
javax.servlet-api-3.1.0.jar
javax.servlet.jsp-2.3.2.jar
javax.servlet.jsp-api-2.3.1.jar
@@ -421,8 +408,8 @@ joda-time-1.6.jar
joda-time-2.10.5.jar
joda-time-2.9.9.jar
joni-2.1.11.jar
-joni-2.1.2.jar
joni-2.1.27.jar
+joni-2.1.2.jar
jopt-simple-5.0.2.jar
jpam-1.1.jar
jsch-0.1.54.jar
@@ -433,7 +420,7 @@ jsr305-1.3.9.jar
jsr311-api-1.1.1.jar
jvm-attach-api-1.5.jar
kafka-clients-2.0.0.jar
-kafka-clients-2.2.0.jar
+kafka-clients-2.4.1.jar
kerb-admin-1.0.1.jar
kerb-client-1.0.1.jar
kerb-common-1.0.1.jar
@@ -457,9 +444,9 @@ kudu-spark2_2.11-1.7.0.jar
lang-mustache-client-6.3.1.jar
leveldbjni-all-1.8.jar
libthrift-0.9.0.jar
-log4j-1.2-api-2.15.0.jar
log4j-1.2.14.jar
log4j-1.2.17.jar
+log4j-1.2-api-2.15.0.jar
log4j-api-2.15.0.jar
log4j-api-2.8.1.jar
log4j-api-2.9.1.jar
@@ -467,7 +454,6 @@ log4j-core-2.13.2.jar
log4j-core-2.15.0.jar
log4j-jul-2.15.0.jar
log4j-slf4j-impl-2.15.0.jar
-log4j-to-slf4j-2.9.1.jar
logging-interceptor-4.9.1.jar
lucene-analyzers-common-7.3.1.jar
lucene-backward-codecs-7.3.1.jar
@@ -480,14 +466,14 @@ lucene-misc-7.3.1.jar
lucene-queries-7.3.1.jar
lucene-queryparser-7.3.1.jar
lucene-sandbox-7.3.1.jar
+lucene-spatial3d-7.3.1.jar
lucene-spatial-7.3.1.jar
lucene-spatial-extras-7.3.1.jar
-lucene-spatial3d-7.3.1.jar
lucene-suggest-7.3.1.jar
lz4-1.3.0.jar
lz4-java-1.4.0.jar
lz4-java-1.4.1.jar
-lz4-java-1.5.0.jar
+lz4-java-1.6.0.jar
lz4-java-1.7.1.jar
maven-aether-provider-3.1.1.jar
maven-artifact-3.6.0.jar
@@ -543,7 +529,6 @@ okhttp-4.9.1.jar
okio-1.4.0.jar
okio-2.8.0.jar
opencsv-4.6.jar
-orc-core-1.4.3.jar
orc-core-1.5.6.jar
orc-shims-1.5.6.jar
osgi-resource-locator-1.0.1.jar
@@ -583,17 +568,18 @@ resilience4j-bulkhead-1.3.1.jar
resilience4j-core-1.3.1.jar
retrofit-2.9.0.jar
rhino-1.7.11.jar
+RoaringBitmap-0.9.0.jar
scala-compiler-2.11.12.jar
+scalaj-http_2.11-2.3.0.jar
scala-library-2.11.12.jar
scala-library-2.11.8.jar
+scalap-2.11.12.jar
scala-parser-combinators_2.11-1.0.4.jar
scala-parser-combinators_2.11-1.1.0.jar
scala-reflect-2.11.12.jar
scala-reflect-2.11.8.jar
scala-xml_2.11-1.0.5.jar
scala-xml_2.11-1.3.0.jar
-scalaj-http_2.11-2.3.0.jar
-scalap-2.11.12.jar
servlet-api-2.5.jar
shims-0.9.0.jar
sigar-1.6.5.132.jar
@@ -608,9 +594,9 @@ slf4j-log4j12-1.7.25.jar
snakeyaml-1.17.jar
snakeyaml-1.24.jar
snappy-0.3.jar
-snappy-java-1.1.2.6.jar
snappy-java-1.1.4.jar
snappy-java-1.1.7.1.jar
+snappy-java-1.1.8.3.jar
spark-catalyst_2.11-2.4.0.jar
spark-hive-thriftserver_2.11-2.3.4.jar
spark-redis_2.11-2.6.0.jar
@@ -618,11 +604,12 @@ spark-sketch_2.11-2.4.0.jar
spark-streaming-kafka-0-10_2.11-2.4.0.jar
spark-tags_2.11-2.4.0.jar
spark-unsafe_2.11-2.4.0.jar
+SparseBitSet-1.2.jar
spoiwo_2.11-1.8.0.jar
spymemcached-2.12.3.jar
sqlline-1.2.0.jar
-stax-api-1.0-2.jar
stax2-api-3.1.4.jar
+stax-api-1.0-2.jar
stream-2.7.0.jar
stream-2.9.5.jar
super-csv-2.2.0.jar
@@ -666,4 +653,4 @@ zookeeper-3.4.6.jar
zookeeper-3.5.9.jar
zookeeper-jute-3.5.9.jar
zstd-jni-1.3.3-1.jar
-zstd-jni-1.3.8-1.jar
+zstd-jni-1.4.3-1.jar
