You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ju...@apache.org on 2025/12/16 04:08:46 UTC
(iotdb) 01/02: remove-warn
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 <87...@users.noreply.github.com>
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();
}
}