This is an automated email from the ASF dual-hosted git repository.
justinchen pushed a commit to branch opc-large-fix
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/opc-large-fix by this push:
new 2a6a33c797b fix
2a6a33c797b is described below
commit 2a6a33c797bc4d498d284e657b915133d3862ab7
Author: Caideyipi <[email protected]>
AuthorDate: Mon Mar 30 17:33:34 2026 +0800
fix
---
.../org/apache/iotdb/db/pipe/sink/protocol/opcua/OpcUaSink.java | 9 +++++++--
1 file changed, 7 insertions(+), 2 deletions(-)
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/opcua/OpcUaSink.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/opcua/OpcUaSink.java
index 91b959b229c..cd016eaed68 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/opcua/OpcUaSink.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/sink/protocol/opcua/OpcUaSink.java
@@ -50,8 +50,8 @@ import
org.apache.iotdb.pipe.api.customizer.parameter.PipeParameters;
import org.apache.iotdb.pipe.api.event.Event;
import org.apache.iotdb.pipe.api.event.dml.insertion.TabletInsertionEvent;
import org.apache.iotdb.pipe.api.exception.PipeException;
-
import org.apache.iotdb.service.rpc.thrift.TSLastDataQueryReq;
+
import org.apache.tsfile.common.conf.TSFileConfig;
import org.apache.tsfile.utils.Pair;
import org.apache.tsfile.write.record.Tablet;
@@ -402,7 +402,12 @@ public class OpcUaSink implements PipeConnector {
try {
initializeSession();
- clientRPCServiceImpl.executeLastDataQueryV2(new
TSLastDataQueryReq(session.getId(), Collections.emptyList(), ));
+ clientRPCServiceImpl.executeLastDataQueryV2(
+ new TSLastDataQueryReq(
+ session.getId(),
+ Collections.emptyList(),
+ Long.MIN_VALUE,
+ SESSION_MANAGER.requestStatementId(session)));
initialized = true;
if (Objects.nonNull(session)) {
