This is an automated email from the ASF dual-hosted git repository.
haonan pushed a commit to branch branch-fixsonarbug202405
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/branch-fixsonarbug202405 by
this push:
new f8b78b30e51 fix compile
f8b78b30e51 is described below
commit f8b78b30e5179b290fa018b0cc1895f58c8c5486
Author: HTHou <[email protected]>
AuthorDate: Tue May 21 15:39:45 2024 +0800
fix compile
---
.../iotdb/db/pipe/receiver/protocol/thrift/IoTDBDataNodeReceiver.java | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
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 9c14c074178..9abfbab7e5b 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
@@ -307,8 +307,7 @@ public class IoTDBDataNodeReceiver extends
IoTDBFileReceiver {
// Clear to avoid previous exceptions
batchVisitor.clear();
final List<TSStatus> results = new ArrayList<>();
- while (generator.hasNext()) {
- final Statement originalStatement = generator.next();
+ for (Statement originalStatement : generator) {
if (!executionTypes.contains(originalStatement.getType())) {
continue;
}