Skip to content

Commit 2d1eaf7

Browse files
baisui1981baisui1981
committed
make threadCacheTabCols.plugin private
1 parent 5c826fd commit 2d1eaf7

File tree

8 files changed

+23
-1394
lines changed

8 files changed

+23
-1394
lines changed

‎pom.xml.versionBackup‎

Lines changed: 0 additions & 1371 deletions
This file was deleted.

‎tis-datax/executor/dolphinscheduler-task-tis-datasync/dependency-reduced-pom.xml‎

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -3,13 +3,13 @@
33
<parent>
44
<artifactId>tis-datax</artifactId>
55
<groupId>com.qlangtech.tis.plugins</groupId>
6-
<version>5.0.0-SNAPSHOT</version>
6+
<version>5.0.0</version>
77
<relativePath>../../pom.xml</relativePath>
88
</parent>
99
<modelVersion>4.0.0</modelVersion>
1010
<groupId>com.qlangtech.tis.plugins</groupId>
1111
<artifactId>dolphinscheduler-task-tis-datasync</artifactId>
12-
<version>5.0.0-SNAPSHOT</version>
12+
<version>5.0.0</version>
1313
<licenses>
1414
<license>
1515
<name>GNU Affero General Public License</name>
@@ -68,7 +68,7 @@
6868
<dependency>
6969
<groupId>com.qlangtech.tis</groupId>
7070
<artifactId>tis-base-test</artifactId>
71-
<version>5.0.0-SNAPSHOT</version>
71+
<version>5.0.0</version>
7272
<scope>test</scope>
7373
<exclusions>
7474
<exclusion>
@@ -96,7 +96,7 @@
9696
<dependency>
9797
<groupId>com.alibaba.datax</groupId>
9898
<artifactId>datax-common</artifactId>
99-
<version>5.0.0-SNAPSHOT</version>
99+
<version>5.0.0</version>
100100
<scope>provided</scope>
101101
</dependency>
102102
<dependency>

‎tis-datax/tis-aliyun-jindo-sdk-extends/tis-aliyun-jindo-sdk-extends-impl/dependency-reduced-pom.xml‎

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -3,12 +3,12 @@
33
<parent>
44
<artifactId>tis-aliyun-jindo-sdk-extends</artifactId>
55
<groupId>com.qlangtech.tis.plugins</groupId>
6-
<version>5.0.0-SNAPSHOT</version>
6+
<version>5.0.0</version>
77
</parent>
88
<modelVersion>4.0.0</modelVersion>
99
<groupId>com.qlangtech.tis.plugins</groupId>
1010
<artifactId>tis-aliyun-jindo-sdk-extends-impl</artifactId>
11-
<version>5.0.0-SNAPSHOT</version>
11+
<version>5.0.0</version>
1212
<licenses>
1313
<license>
1414
<name>GNU Affero General Public License</name>
@@ -46,7 +46,7 @@
4646
<dependency>
4747
<groupId>com.alibaba.datax</groupId>
4848
<artifactId>datax-common</artifactId>
49-
<version>5.0.0-SNAPSHOT</version>
49+
<version>5.0.0</version>
5050
<scope>provided</scope>
5151
</dependency>
5252
<dependency>
@@ -64,7 +64,7 @@
6464
<dependency>
6565
<groupId>com.qlangtech.tis</groupId>
6666
<artifactId>tis-plugin</artifactId>
67-
<version>5.0.0-SNAPSHOT</version>
67+
<version>5.0.0</version>
6868
<scope>provided</scope>
6969
</dependency>
7070
<dependency>

‎tis-incr/tis-flink-cdc-kingbase-shade-4-debezium-connector-postgresql/dependency-reduced-pom.xml‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -3,12 +3,12 @@
33
<parent>
44
<artifactId>tis-incr</artifactId>
55
<groupId>com.qlangtech.tis.plugins</groupId>
6-
<version>5.0.0-SNAPSHOT</version>
6+
<version>5.0.0</version>
77
</parent>
88
<modelVersion>4.0.0</modelVersion>
99
<groupId>com.qlangtech.tis.plugins</groupId>
1010
<artifactId>tis-flink-cdc-kingbase-shade-4-debezium-connector-postgresql</artifactId>
11-
<version>5.0.0-SNAPSHOT</version>
11+
<version>5.0.0</version>
1212
<licenses>
1313
<license>
1414
<name>GNU Affero General Public License</name>
@@ -69,7 +69,7 @@
6969
<dependency>
7070
<groupId>com.qlangtech.tis</groupId>
7171
<artifactId>tis-plugin</artifactId>
72-
<version>5.0.0-SNAPSHOT</version>
72+
<version>5.0.0</version>
7373
<scope>provided</scope>
7474
</dependency>
7575
<dependency>

‎tis-incr/tis-flink-cdc-mysql-shade-4-debezium-connector-mysql/dependency-reduced-pom.xml‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -3,12 +3,12 @@
33
<parent>
44
<artifactId>tis-incr</artifactId>
55
<groupId>com.qlangtech.tis.plugins</groupId>
6-
<version>5.0.0-SNAPSHOT</version>
6+
<version>5.0.0</version>
77
</parent>
88
<modelVersion>4.0.0</modelVersion>
99
<groupId>com.qlangtech.tis.plugins</groupId>
1010
<artifactId>tis-flink-cdc-shade-4-debezium-connector-mysql</artifactId>
11-
<version>5.0.0-SNAPSHOT</version>
11+
<version>5.0.0</version>
1212
<licenses>
1313
<license>
1414
<name>GNU Affero General Public License</name>
@@ -66,7 +66,7 @@
6666
<dependency>
6767
<groupId>com.qlangtech.tis</groupId>
6868
<artifactId>tis-plugin</artifactId>
69-
<version>5.0.0-SNAPSHOT</version>
69+
<version>5.0.0</version>
7070
<scope>provided</scope>
7171
</dependency>
7272
<dependency>

‎tis-incr/tis-flink-cdc-postgresql-shade-4-debezium-connector-postgresql/dependency-reduced-pom.xml‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -3,12 +3,12 @@
33
<parent>
44
<artifactId>tis-incr</artifactId>
55
<groupId>com.qlangtech.tis.plugins</groupId>
6-
<version>5.0.0-SNAPSHOT</version>
6+
<version>5.0.0</version>
77
</parent>
88
<modelVersion>4.0.0</modelVersion>
99
<groupId>com.qlangtech.tis.plugins</groupId>
1010
<artifactId>tis-flink-cdc-postgresql-shade-4-debezium-connector-postgresql</artifactId>
11-
<version>5.0.0-SNAPSHOT</version>
11+
<version>5.0.0</version>
1212
<licenses>
1313
<license>
1414
<name>GNU Affero General Public License</name>
@@ -68,7 +68,7 @@
6868
<dependency>
6969
<groupId>com.qlangtech.tis</groupId>
7070
<artifactId>tis-plugin</artifactId>
71-
<version>5.0.0-SNAPSHOT</version>
71+
<version>5.0.0</version>
7272
<scope>provided</scope>
7373
</dependency>
7474
<dependency>

‎tis-incr/tis-sink-elasticsearch7/dependency-reduced-pom.xml‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -3,12 +3,12 @@
33
<parent>
44
<artifactId>tis-incr</artifactId>
55
<groupId>com.qlangtech.tis.plugins</groupId>
6-
<version>5.0.0-SNAPSHOT</version>
6+
<version>5.0.0</version>
77
</parent>
88
<modelVersion>4.0.0</modelVersion>
99
<groupId>com.qlangtech.tis.plugins</groupId>
1010
<artifactId>tis-sink-elasticsearch7</artifactId>
11-
<version>5.0.0-SNAPSHOT</version>
11+
<version>5.0.0</version>
1212
<licenses>
1313
<license>
1414
<name>GNU Affero General Public License</name>
@@ -63,7 +63,7 @@
6363
<dependency>
6464
<groupId>com.qlangtech.tis</groupId>
6565
<artifactId>tis-plugin</artifactId>
66-
<version>5.0.0-SNAPSHOT</version>
66+
<version>5.0.0</version>
6767
<scope>provided</scope>
6868
</dependency>
6969
<dependency>

‎tis-transformer/src/main/java/com/qlangtech/tis/plugin/datax/transformer/impl/CopyValUDF.java‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,6 @@
2020

2121
import com.alibaba.datax.common.element.ColumnAwareRecord;
2222
import com.google.common.collect.Lists;
23-
import com.qlangtech.tis.datax.IDataxReader;
2423
import com.qlangtech.tis.extension.TISExtension;
2524
import com.qlangtech.tis.plugin.annotation.FormField;
2625
import com.qlangtech.tis.plugin.annotation.FormFieldType;
@@ -66,8 +65,9 @@ public List<OutputParameter> outParameters() {
6665
public static List<CMeta> fromColsCandidate() {
6766
List<CMeta> colsCandidate = SelectedTab.getSelectedCols();
6867
ThreadCacheTableCols threadCacheTabCols = SelectedTab.getContextTableColsStream();
69-
IDataxReader reader = threadCacheTabCols.plugin;
70-
Map<String, ContextParamConfig> dbContextParams = reader.getDBContextParams();
68+
// IDataxReader reader //
69+
// = Objects.requireNonNull(threadCacheTabCols.plugin, "threadCacheTabCols.plugin can not be null");
70+
Map<String, ContextParamConfig> dbContextParams = threadCacheTabCols.getDBContextParams();
7171
if (MapUtils.isNotEmpty(dbContextParams)) {
7272
colsCandidate = Lists.newArrayList(colsCandidate);
7373
for (Map.Entry<String, ContextParamConfig> entry : dbContextParams.entrySet()) {

0 commit comments

Comments
 (0)