(iotdb) branch master updated: Pipe: fix legacy receiver's unsafe execution race problem (fix IoTDBPipeDataSinkIT.testLegacyConnector) (#12152)

[rong]

This is an automated email from the ASF dual-hosted git repository.

rong pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/master by this push:
     new a21e2b79cc3 Pipe: fix legacy receiver's unsafe execution race problem 
(fix IoTDBPipeDataSinkIT.testLegacyConnector) (#12152)
a21e2b79cc3 is described below

commit a21e2b79cc37c568c5b92b7f1c3716b4c216152a
Author: Steve Yurong Su <r...@apache.org>
AuthorDate: Mon Mar 11 17:31:17 2024 +0800

    Pipe: fix legacy receiver's unsafe execution race problem (fix 
IoTDBPipeDataSinkIT.testLegacyConnector) (#12152)
---
 .../db/pipe/connector/protocol/legacy/IoTDBLegacyPipeConnector.java  | 5 +----
 1 file changed, 1 insertion(+), 4 deletions(-)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/legacy/IoTDBLegacyPipeConnector.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/legacy/IoTDBLegacyPipeConnector.java
index 257d7746f3b..8975459d79a 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/legacy/IoTDBLegacyPipeConnector.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/legacy/IoTDBLegacyPipeConnector.java
@@ -104,8 +104,6 @@ public class IoTDBLegacyPipeConnector implements 
PipeConnector {
   private String syncConnectorVersion;
 
   private String pipeName;
-  private Long creationTime;
-
   private IoTDBSyncClient client;
 
   private SessionPool sessionPool;
@@ -205,7 +203,6 @@ public class IoTDBLegacyPipeConnector implements 
PipeConnector {
             CONNECTOR_IOTDB_SYNC_CONNECTOR_VERSION_DEFAULT_VALUE);
 
     pipeName = configuration.getRuntimeEnvironment().getPipeName();
-    creationTime = configuration.getRuntimeEnvironment().getCreationTime();
 
     useSSL = parameters.getBooleanOrDefault(SINK_IOTDB_SSL_ENABLE_KEY, false);
     trustStore = parameters.getString(SINK_IOTDB_SSL_TRUST_STORE_PATH_KEY);
@@ -230,7 +227,7 @@ public class IoTDBLegacyPipeConnector implements 
PipeConnector {
               trustStorePwd);
       final TSyncIdentityInfo identityInfo =
           new TSyncIdentityInfo(
-              pipeName, creationTime, syncConnectorVersion, 
IoTDBConstant.PATH_ROOT);
+              pipeName, System.currentTimeMillis(), syncConnectorVersion, 
IoTDBConstant.PATH_ROOT);
       final TSStatus status = client.handshake(identityInfo);
       if (status.code != TSStatusCode.SUCCESS_STATUS.getStatusCode()) {
         String errorMsg =