This is an automated email from the ASF dual-hosted git repository.
justinchen pushed a commit to branch air-gap-ttl
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/air-gap-ttl by this push:
new 9f0ee6e42f4 fix
9f0ee6e42f4 is described below
commit 9f0ee6e42f40e6d6642cbd2dc5a255298eaba3a5
Author: Caideyipi <[email protected]>
AuthorDate: Fri Feb 6 12:13:39 2026 +0800
fix
---
.../main/java/org/apache/iotdb/SessionExample.java | 22 +++++++++++-----------
.../protocol/thrift/IoTDBDataNodeReceiver.java | 4 ++--
...leStatementDataTypeConvertExecutionVisitor.java | 12 +++++-------
...eeStatementDataTypeConvertExecutionVisitor.java | 10 ++++------
4 files changed, 22 insertions(+), 26 deletions(-)
diff --git a/example/session/src/main/java/org/apache/iotdb/SessionExample.java
b/example/session/src/main/java/org/apache/iotdb/SessionExample.java
index c9e8d42aacf..bcbf7a61adf 100644
--- a/example/session/src/main/java/org/apache/iotdb/SessionExample.java
+++ b/example/session/src/main/java/org/apache/iotdb/SessionExample.java
@@ -90,24 +90,24 @@ public class SessionExample {
}
// createTemplate();
- createTimeseries();
- createMultiTimeseries();
- createMultiTimeseriesWithNullPartical();
- insertRecord();
- insertTablet();
+ // createTimeseries();
+ // createMultiTimeseries();
+ // createMultiTimeseriesWithNullPartical();
+ // insertRecord();
+ // insertTablet();
// insertTabletWithNullValues();
// insertTablets();
- // insertRecords();
+ insertRecords();
// insertText();
// selectInto();
// createAndDropContinuousQueries();
// nonQuery();
- queryByIterator();
+ // queryByIterator();
// queryWithTimeout();
- rawDataQuery();
- lastDataQuery();
- aggregationQuery();
- groupByQuery();
+ // rawDataQuery();
+ // lastDataQuery();
+ // aggregationQuery();
+ // groupByQuery();
// deleteData();
// deleteTimeseries();
// setTimeout();
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/protocol/thrift/IoTDBDataNodeReceiver.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/protocol/thrift/IoTDBDataNodeReceiver.java
index f0796a3b1a0..f161a249666 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/protocol/thrift/IoTDBDataNodeReceiver.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/protocol/thrift/IoTDBDataNodeReceiver.java
@@ -840,7 +840,7 @@ public class IoTDBDataNodeReceiver extends
IoTDBFileReceiver {
receiverId.get(),
statement.getPipeLoggingString(),
result);
- return statement.accept(STATEMENT_STATUS_VISITOR, result);
+ return STATEMENT_STATUS_VISITOR.process(statement, result);
}
} catch (final Exception e) {
PipeLogger.log(
@@ -849,7 +849,7 @@ public class IoTDBDataNodeReceiver extends
IoTDBFileReceiver {
"Receiver id = %s: Exception encountered while executing statement
%s: ",
receiverId.get(),
statement.getPipeLoggingString());
- return statement.accept(STATEMENT_EXCEPTION_VISITOR, e);
+ return STATEMENT_EXCEPTION_VISITOR.process(statement, e);
} finally {
if (Objects.nonNull(allocatedMemoryBlock)) {
allocatedMemoryBlock.close();
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/visitor/PipeTableStatementDataTypeConvertExecutionVisitor.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/visitor/PipeTableStatementDataTypeConvertExecutionVisitor.java
index d19aa71c234..10d0423e6fe 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/visitor/PipeTableStatementDataTypeConvertExecutionVisitor.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/visitor/PipeTableStatementDataTypeConvertExecutionVisitor.java
@@ -154,9 +154,8 @@ public class
PipeTableStatementDataTypeConvertExecutionVisitor
TSStatus result;
try {
result =
- statement.accept(
- IoTDBDataNodeReceiver.STATEMENT_STATUS_VISITOR,
- statementExecutor.execute(statement, databaseName));
+ IoTDBDataNodeReceiver.STATEMENT_STATUS_VISITOR.process(
+ statement, statementExecutor.execute(statement,
databaseName));
// Retry max 5 times if the write process is rejected
for (int i = 0;
@@ -167,15 +166,14 @@ public class
PipeTableStatementDataTypeConvertExecutionVisitor
i++) {
Thread.sleep(100L * (i + 1));
result =
- statement.accept(
- IoTDBDataNodeReceiver.STATEMENT_STATUS_VISITOR,
- statementExecutor.execute(statement, databaseName));
+ IoTDBDataNodeReceiver.STATEMENT_STATUS_VISITOR.process(
+ statement, statementExecutor.execute(statement,
databaseName));
}
} catch (final Exception e) {
if (e instanceof InterruptedException) {
Thread.currentThread().interrupt();
}
- result =
statement.accept(IoTDBDataNodeReceiver.STATEMENT_EXCEPTION_VISITOR, e);
+ result =
IoTDBDataNodeReceiver.STATEMENT_EXCEPTION_VISITOR.process(statement, e);
}
if (!(result.getCode() == TSStatusCode.SUCCESS_STATUS.getStatusCode()
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/visitor/PipeTreeStatementDataTypeConvertExecutionVisitor.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/visitor/PipeTreeStatementDataTypeConvertExecutionVisitor.java
index 282b378a2d2..ae60b87450a 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/visitor/PipeTreeStatementDataTypeConvertExecutionVisitor.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/visitor/PipeTreeStatementDataTypeConvertExecutionVisitor.java
@@ -114,9 +114,8 @@ public class
PipeTreeStatementDataTypeConvertExecutionVisitor
TSStatus result;
try {
result =
- statement.accept(
- IoTDBDataNodeReceiver.STATEMENT_STATUS_VISITOR,
- statementExecutor.execute(statement));
+ IoTDBDataNodeReceiver.STATEMENT_STATUS_VISITOR.process(
+ statement, statementExecutor.execute(statement));
// Retry max 5 times if the write process is rejected
for (int i = 0;
@@ -127,9 +126,8 @@ public class
PipeTreeStatementDataTypeConvertExecutionVisitor
i++) {
Thread.sleep(100L * (i + 1));
result =
- statement.accept(
- IoTDBDataNodeReceiver.STATEMENT_STATUS_VISITOR,
- statementExecutor.execute(statement));
+ IoTDBDataNodeReceiver.STATEMENT_STATUS_VISITOR.process(
+ statement, statementExecutor.execute(statement));
}
} catch (final Exception e) {
if (e instanceof InterruptedException) {
