This is an automated email from the ASF dual-hosted git repository. justinchen pushed a commit to branch internalSession in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 2f8b33cdaae75ca7fe95f941f95a64f84374a7fb Author: Caideyipi <[email protected]> AuthorDate: Tue Dec 16 10:37:42 2025 +0800 remove-warn --- .../org/apache/iotdb/db/protocol/session/InternalClientSession.java | 4 ++-- .../java/org/apache/iotdb/db/protocol/session/MqttClientSession.java | 3 +-- 2 files changed, 3 insertions(+), 4 deletions(-) diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/session/InternalClientSession.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/session/InternalClientSession.java index ed87d0b0ee3..975cbb09437 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/session/InternalClientSession.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/session/InternalClientSession.java @@ -21,6 +21,7 @@ package org.apache.iotdb.db.protocol.session; import org.apache.iotdb.service.rpc.thrift.TSConnectionType; +import java.util.Collections; import java.util.Map; import java.util.Set; import java.util.concurrent.ConcurrentHashMap; @@ -109,7 +110,6 @@ public class InternalClientSession extends IClientSession { @Override public Set<String> getPreparedStatementNames() { - throw new UnsupportedOperationException( - "InternalClientSession should never call PREPARE statement methods."); + return Collections.emptySet(); } } diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/session/MqttClientSession.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/session/MqttClientSession.java index c0b68e885a1..41fc6447c23 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/session/MqttClientSession.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/session/MqttClientSession.java @@ -97,7 +97,6 @@ public class MqttClientSession extends IClientSession { @Override public Set<String> getPreparedStatementNames() { - throw new UnsupportedOperationException( - "MQTT client session does not support PREPARE statement."); + return Collections.emptySet(); } }
