This is an automated email from the ASF dual-hosted git repository.
rong pushed a commit to branch dev/1.3
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/dev/1.3 by this push:
new c1c2f5e26a7 Fixed the wrong "maxRowNumber" in OPC DA Sink null value
judgement (#15066)
c1c2f5e26a7 is described below
commit c1c2f5e26a78efcc2ffb9b567db8c9be10aba170
Author: Caideyipi <[email protected]>
AuthorDate: Fri Mar 14 14:29:08 2025 +0800
Fixed the wrong "maxRowNumber" in OPC DA Sink null value judgement (#15066)
---
.../iotdb/db/pipe/connector/protocol/opcda/OpcDaServerHandle.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/opcda/OpcDaServerHandle.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/opcda/OpcDaServerHandle.java
index f22379737d0..3560bd26d3f 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/opcda/OpcDaServerHandle.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/opcda/OpcDaServerHandle.java
@@ -191,7 +191,7 @@ public class OpcDaServerHandle implements Closeable {
if (!serverHandleMap.containsKey(itemId)) {
addItem(itemId, schemas.get(i).getType());
}
- for (int j = tablet.getMaxRowNumber() - 1; j >= 0; --j) {
+ for (int j = tablet.rowSize - 1; j >= 0; --j) {
if (Objects.isNull(tablet.bitMaps)
|| Objects.isNull(tablet.bitMaps[i])
|| !tablet.bitMaps[i].isMarked(j)) {
