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 14ad2b4a3d46..adfa9bc6b039 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 @@ protected InsertMultiTabletsStatement constructInsertMultiTabletsStatement(boole @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; }