Skip to content

Commit 3e58ed7

Browse files
authored
feat: update jdbc version (#26)
* feat: update jdbc version * feat: update jdbc version
1 parent c076d00 commit 3e58ed7

4 files changed

Lines changed: 6 additions & 6 deletions

File tree

deploy-pom.xml

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@
66

77
<groupId>com.taosdata.flink</groupId>
88
<artifactId>flink-connector-tdengine</artifactId>
9-
<version>2.1.3</version>
9+
<version>2.1.4</version>
1010
<packaging>jar</packaging>
1111

1212
<name>flink-connector-tdengine</name>
@@ -48,7 +48,7 @@
4848
<hamcrest.version>1.3</hamcrest.version>
4949
<powermock.version>2.0.9</powermock.version>
5050
<jackson.version>2.18.0</jackson.version>
51-
<taos.jdbcdriver.version>3.6.3</taos.jdbcdriver.version>
51+
<taos.jdbcdriver.version>3.7.3</taos.jdbcdriver.version>
5252
</properties>
5353

5454
<dependencyManagement>

pom.xml

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@
66

77
<groupId>com.taosdata.flink</groupId>
88
<artifactId>flink-connector-tdengine</artifactId>
9-
<version>2.1.3</version>
9+
<version>2.1.4</version>
1010
<packaging>jar</packaging>
1111
<name>flink-connector-tdengine</name>
1212
<url>https://github.com/taosdata/flink-connect-tdengine</url>
@@ -90,7 +90,7 @@
9090
<dependency>
9191
<groupId>com.taosdata.jdbc</groupId>
9292
<artifactId>taos-jdbcdriver</artifactId>
93-
<version>3.6.3</version>
93+
<version>3.7.3</version>
9494
</dependency>
9595

9696
<!-- Core -->

src/test/java/com/taosdata/flink/entity/ResultSoureDeserialization.java renamed to src/test/java/com/taosdata/flink/entity/ResultSourceDeserialization.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -9,7 +9,7 @@
99
import java.sql.Timestamp;
1010
import java.util.List;
1111

12-
public class ResultSoureDeserialization implements TDengineRecordDeserialization<ResultBean> {
12+
public class ResultSourceDeserialization implements TDengineRecordDeserialization<ResultBean> {
1313
/**
1414
* @param splitResultRecord A record of information containing an object list
1515
* @return Data format after data conversion

src/test/java/com/taosdata/flink/source/TDFlinkSourceTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -257,7 +257,7 @@ void testCustomTypeTDengineSource() throws Exception {
257257
connProps.setProperty(TSDBDriver.PROPERTY_KEY_ENABLE_AUTO_RECONNECT, "true");
258258
connProps.setProperty(TSDBDriver.PROPERTY_KEY_CHARSET, "UTF-8");
259259
connProps.setProperty(TSDBDriver.PROPERTY_KEY_TIME_ZONE, "UTC-8");
260-
connProps.setProperty(TDengineConfigParams.VALUE_DESERIALIZER, "com.taosdata.flink.entity.ResultSoureDeserialization");
260+
connProps.setProperty(TDengineConfigParams.VALUE_DESERIALIZER, "com.taosdata.flink.entity.ResultSourceDeserialization");
261261
connProps.setProperty(TDengineConfigParams.TD_JDBC_URL, "jdbc:TAOS-WS://localhost:6041/power?user=root&password=taosdata");
262262
SourceSplitSql splitSql = new SourceSplitSql();
263263
splitSql.setSql("select ts, `current`, voltage, phase, groupid, location, tbname from meters")

0 commit comments

Comments
 (0)