This is an automated email from the ASF dual-hosted git repository. shuwenwei pushed a commit to branch optimizeFindWritten-1.3 in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit ace24a6beade00208a4ddba30eab536f673a59bd Author: shuwenwei <[email protected]> AuthorDate: Fri Jan 9 15:55:02 2026 +0800 Optimize DeviceViewIntoOperator.findWritten(String device, String measurement) --- .../queryengine/execution/operator/process/DeviceViewIntoOperator.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/DeviceViewIntoOperator.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/DeviceViewIntoOperator.java index 14ad2b4a3d4..adfa9bc6b03 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/DeviceViewIntoOperator.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/DeviceViewIntoOperator.java @@ -259,7 +259,8 @@ public class DeviceViewIntoOperator extends AbstractIntoOperator { @Override protected int findWritten(String device, String measurement) { - for (InsertTabletStatementGenerator generator : insertTabletStatementGenerators) { + for (int i = insertTabletStatementGenerators.size() - 1; i >= 0; i--) { + InsertTabletStatementGenerator generator = insertTabletStatementGenerators.get(i); if (!Objects.equals(generator.getDevice(), device)) { continue; }
