File tree Expand file tree Collapse file tree 2 files changed +3
-4
lines changed
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/session Expand file tree Collapse file tree 2 files changed +3
-4
lines changed Original file line number Diff line number Diff line change 2121
2222import org .apache .iotdb .service .rpc .thrift .TSConnectionType ;
2323
24+ import java .util .Collections ;
2425import java .util .Map ;
2526import java .util .Set ;
2627import java .util .concurrent .ConcurrentHashMap ;
@@ -109,7 +110,6 @@ public PreparedStatementInfo getPreparedStatement(String statementName) {
109110
110111 @ Override
111112 public Set <String > getPreparedStatementNames () {
112- throw new UnsupportedOperationException (
113- "InternalClientSession should never call PREPARE statement methods." );
113+ return Collections .emptySet ();
114114 }
115115}
Original file line number Diff line number Diff line change @@ -97,7 +97,6 @@ public PreparedStatementInfo getPreparedStatement(String statementName) {
9797
9898 @ Override
9999 public Set <String > getPreparedStatementNames () {
100- throw new UnsupportedOperationException (
101- "MQTT client session does not support PREPARE statement." );
100+ return Collections .emptySet ();
102101 }
103102}
You can’t perform that action at this time.
0 commit comments