This is an automated email from the ASF dual-hosted git repository. rong pushed a commit to branch fix-pipe-legacy-connector-tests in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit c5f7ba33064494149b1caaa885268f089396100a Author: Steve Yurong Su <[email protected]> AuthorDate: Mon Mar 11 15:49:34 2024 +0800 Pipe: fix legacy receiver's unsafe execution race problem (fix IoTDBPipeDataSinkIT.testLegacyConnector) --- .../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 =
