Sona:add space before package path and fix 9 bugs(close stmt) in IoTDBDatabaseMetadata (#10377)

example/flink/src/main/java/org/apache/iotdb/flink/FlinkIoTDBSink.java

@@ -15,6 +15,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
+
 package org.apache.iotdb.flink;
 
 import org.apache.iotdb.flink.options.IoTDBSinkOptions;

example/flink/src/main/java/org/apache/iotdb/flink/FlinkTsFileBatchSink.java

@@ -15,6 +15,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
+
 package org.apache.iotdb.flink;
 
 import org.apache.iotdb.flink.tsfile.RowTSRecordConverter;

example/flink/src/main/java/org/apache/iotdb/flink/FlinkTsFileBatchSource.java

@@ -15,6 +15,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
+
 package org.apache.iotdb.flink;
 
 import org.apache.iotdb.flink.tsfile.RowRowRecordParser;

example/flink/src/main/java/org/apache/iotdb/flink/FlinkTsFileStreamSink.java

@@ -15,6 +15,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
+
 package org.apache.iotdb.flink;
 
 import org.apache.iotdb.flink.tsfile.RowTSRecordConverter;

example/flink/src/main/java/org/apache/iotdb/flink/FlinkTsFileStreamSource.java

@@ -15,6 +15,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
+
 package org.apache.iotdb.flink;
 
 import org.apache.iotdb.flink.tsfile.RowRowRecordParser;

example/flink/src/main/java/org/apache/iotdb/flink/TsFileUtils.java

@@ -15,6 +15,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
+
 package org.apache.iotdb.flink;
 
 import org.apache.iotdb.tsfile.file.metadata.enums.TSDataType;

example/hadoop/src/main/java/org/apache/iotdb/hadoop/tsfile/TSFMRReadExample.java

@@ -16,6 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
+
 package org.apache.iotdb.hadoop.tsfile;
 
 import org.apache.hadoop.conf.Configuration;

example/hadoop/src/main/java/org/apache/iotdb/hadoop/tsfile/TSMRWriteExample.java

@@ -16,6 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
+
 package org.apache.iotdb.hadoop.tsfile;
 
 import org.apache.iotdb.hadoop.tsfile.record.HDFSTSRecord;

example/hadoop/src/main/java/org/apache/iotdb/hadoop/tsfile/TsFileHelper.java

@@ -16,6 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
+
 package org.apache.iotdb.hadoop.tsfile;
 
 import org.apache.iotdb.tsfile.file.metadata.enums.TSDataType;

example/jdbc/src/main/java/org/apache/iotdb/JDBCExample.java

@@ -16,6 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
+
 package org.apache.iotdb;
 
 import org.apache.iotdb.jdbc.IoTDBSQLException;

example/jdbc/src/main/java/org/apache/iotdb/PrepareStatementDemo.java

@@ -16,6 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
+
 package org.apache.iotdb;
 
 import org.slf4j.Logger;

example/jdbc/src/main/java/org/apache/iotdb/SyntaxConventionRelatedExample.java

@@ -16,6 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
+
 package org.apache.iotdb;
 
 import org.apache.iotdb.jdbc.IoTDBSQLException;

example/kafka/src/main/java/org/apache/iotdb/kafka/Constant.java

@@ -16,6 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
+
 package org.apache.iotdb.kafka;
 
 public class Constant {

example/kafka/src/main/java/org/apache/iotdb/kafka/Consumer.java

@@ -16,6 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
+
 package org.apache.iotdb.kafka;
 
 import org.apache.iotdb.rpc.IoTDBConnectionException;

example/kafka/src/main/java/org/apache/iotdb/kafka/ConsumerThread.java

@@ -16,6 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
+
 package org.apache.iotdb.kafka;
 
 import org.apache.iotdb.rpc.IoTDBConnectionException;

example/kafka/src/main/java/org/apache/iotdb/kafka/Producer.java

@@ -16,6 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
+
 package org.apache.iotdb.kafka;
 
 import org.apache.kafka.clients.producer.KafkaProducer;

example/mqtt-customize/src/main/java/org/apache/iotdb/mqtt/server/CustomizedJsonPayloadFormatter.java

@@ -16,6 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
+
 package org.apache.iotdb.mqtt.server;
 
 import org.apache.iotdb.db.protocol.mqtt.Message;

example/mqtt/src/main/java/org/apache/iotdb/mqtt/MQTTClient.java

@@ -15,6 +15,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
+
 package org.apache.iotdb.mqtt;
 
 import org.fusesource.mqtt.client.BlockingConnection;

example/pulsar/src/main/java/org/apache/iotdb/pulsar/Constant.java

@@ -16,6 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
+
 package org.apache.iotdb.pulsar;
 
 @SuppressWarnings("squid:S2068")

example/pulsar/src/main/java/org/apache/iotdb/pulsar/PulsarConsumer.java

@@ -16,6 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
+
 package org.apache.iotdb.pulsar;
 
 import org.apache.iotdb.rpc.IoTDBConnectionException;

example/pulsar/src/main/java/org/apache/iotdb/pulsar/PulsarConsumerThread.java

@@ -16,6 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
+
 package org.apache.iotdb.pulsar;
 
 import org.apache.iotdb.rpc.IoTDBConnectionException;

example/pulsar/src/main/java/org/apache/iotdb/pulsar/PulsarProducer.java

@@ -16,6 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
+
 package org.apache.iotdb.pulsar;
 
 import org.apache.pulsar.client.api.BatcherBuilder;

example/rocketmq/src/main/java/org/apache/iotdb/rocketmq/Constant.java

@@ -16,6 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
+
 package org.apache.iotdb.rocketmq;
 
 public class Constant {

example/rocketmq/src/main/java/org/apache/iotdb/rocketmq/RocketMQConsumer.java

@@ -16,6 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
+
 package org.apache.iotdb.rocketmq;
 
 import org.apache.iotdb.rpc.IoTDBConnectionException;

example/rocketmq/src/main/java/org/apache/iotdb/rocketmq/RocketMQProducer.java

@@ -16,6 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
+
 package org.apache.iotdb.rocketmq;
 
 import org.apache.rocketmq.client.exception.MQBrokerException;

example/rocketmq/src/main/java/org/apache/iotdb/rocketmq/Utils.java

@@ -16,6 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
+
 package org.apache.iotdb.rocketmq;
 
 public class Utils {

example/session/src/main/java/org/apache/iotdb/DataMigrationExample.java

@@ -16,6 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
+
 package org.apache.iotdb;
 
 import org.apache.iotdb.commons.path.PartialPath;

example/session/src/main/java/org/apache/iotdb/HybridTimeseriesSessionExample.java

@@ -16,6 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
+
 package org.apache.iotdb;
 
 import org.apache.iotdb.isession.SessionDataSet;

example/session/src/main/java/org/apache/iotdb/SessionPoolExample.java

@@ -16,6 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
+
 package org.apache.iotdb;
 
 import org.apache.iotdb.isession.SessionDataSet.DataIterator;

example/session/src/main/java/org/apache/iotdb/SyntaxConventionRelatedExample.java

@@ -16,6 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
+
 package org.apache.iotdb;
 
 import org.apache.iotdb.isession.SessionDataSet;

example/session/src/main/java/org/apache/iotdb/TabletExample.java

@@ -16,6 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
+
 package org.apache.iotdb;
 
 import org.apache.iotdb.session.Session;

example/tsfile/src/main/java/org/apache/iotdb/tsfile/TsFileForceAppendWrite.java

@@ -16,6 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
+
 package org.apache.iotdb.tsfile;
 
 import org.apache.iotdb.tsfile.file.metadata.enums.TSDataType;

example/tsfile/src/main/java/org/apache/iotdb/tsfile/TsFileRead.java

@@ -16,6 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
+
 package org.apache.iotdb.tsfile;
 
 import org.apache.iotdb.tsfile.read.TsFileReader;

example/tsfile/src/main/java/org/apache/iotdb/tsfile/TsFileSequenceRead.java

@@ -16,6 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
+
 package org.apache.iotdb.tsfile;
 
 import org.apache.iotdb.tsfile.common.conf.TSFileConfig;

example/tsfile/src/main/java/org/apache/iotdb/tsfile/TsFileWriteAlignedWithTSRecord.java

@@ -16,6 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
+
 package org.apache.iotdb.tsfile;
 
 import org.apache.iotdb.tsfile.exception.write.WriteProcessException;

example/tsfile/src/main/java/org/apache/iotdb/tsfile/TsFileWriteAlignedWithTablet.java

@@ -16,6 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
+
 package org.apache.iotdb.tsfile;
 
 import org.apache.iotdb.tsfile.exception.write.WriteProcessException;

iotdb-client/cli/src/main/java/org/apache/iotdb/cli/Cli.java

@@ -16,6 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
+
 package org.apache.iotdb.cli;
 
 import org.apache.iotdb.cli.utils.JlineUtils;

iotdb-client/cli/src/main/java/org/apache/iotdb/cli/utils/IoTPrinter.java

@@ -16,6 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
+
 package org.apache.iotdb.cli.utils;
 
 import org.apache.commons.lang3.StringUtils;

iotdb-client/cli/src/main/java/org/apache/iotdb/exception/ArgsErrorException.java

@@ -16,6 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
+
 package org.apache.iotdb.exception;
 
 public class ArgsErrorException extends Exception {

iotdb-client/cli/src/main/java/org/apache/iotdb/tool/AbstractTsFileTool.java

@@ -16,6 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
+
 package org.apache.iotdb.tool;
 
 import org.apache.iotdb.cli.utils.IoTPrinter;

iotdb-client/cli/src/test/java/org/apache/iotdb/cli/AbstractCliIT.java

@@ -16,6 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
+
 package org.apache.iotdb.cli;
 
 import org.apache.iotdb.cli.AbstractCli.OperationResult;

iotdb-client/cli/src/test/java/org/apache/iotdb/cli/AbstractScript.java

@@ -16,6 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
+
 package org.apache.iotdb.cli;
 
 import org.apache.thrift.annotation.Nullable;

iotdb-client/cli/src/test/java/org/apache/iotdb/tool/integration/ExportCsvTestIT.java

@@ -16,6 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
+
 package org.apache.iotdb.tool.integration;
 
 import org.apache.iotdb.cli.AbstractScript;

iotdb-client/cli/src/test/java/org/apache/iotdb/tool/integration/ImportCsvTestIT.java

@@ -16,6 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
+
 package org.apache.iotdb.tool.integration;
 
 import org.apache.iotdb.cli.AbstractScript;

iotdb-client/isession/src/main/java/org/apache/iotdb/isession/ISession.java

@@ -16,6 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
+
 package org.apache.iotdb.isession;
 
 import org.apache.iotdb.common.rpc.thrift.TAggregationType;

iotdb-client/isession/src/main/java/org/apache/iotdb/isession/SessionConfig.java

@@ -16,6 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
+
 package org.apache.iotdb.isession;
 
 import org.apache.iotdb.isession.util.Version;

iotdb-client/isession/src/main/java/org/apache/iotdb/isession/SessionDataSet.java

@@ -16,6 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
+
 package org.apache.iotdb.isession;
 
 import org.apache.iotdb.rpc.IoTDBConnectionException;

iotdb-client/isession/src/main/java/org/apache/iotdb/isession/pool/ISessionPool.java

@@ -16,6 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
+
 package org.apache.iotdb.isession.pool;
 
 import org.apache.iotdb.common.rpc.thrift.TAggregationType;

iotdb-client/isession/src/main/java/org/apache/iotdb/isession/pool/SessionDataSetWrapper.java

@@ -16,6 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
+
 package org.apache.iotdb.isession.pool;
 
 import org.apache.iotdb.isession.ISession;

iotdb-client/isession/src/main/java/org/apache/iotdb/isession/template/Template.java

@@ -16,6 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
+
 package org.apache.iotdb.isession.template;
 
 import org.apache.iotdb.rpc.StatementExecutionException;

iotdb-client/isession/src/main/java/org/apache/iotdb/isession/template/TemplateNode.java

@@ -16,6 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
+
 package org.apache.iotdb.isession.template;
 
 import org.apache.iotdb.rpc.StatementExecutionException;

iotdb-client/isession/src/main/java/org/apache/iotdb/isession/util/SystemStatus.java

@@ -16,6 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
+
 package org.apache.iotdb.isession.util;
 
 /** Status of current system */

iotdb-client/jdbc/src/main/java/org/apache/iotdb/jdbc/Activator.java

@@ -14,6 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
+
 package org.apache.iotdb.jdbc;
 
 import org.osgi.framework.BundleActivator;

iotdb-client/jdbc/src/main/java/org/apache/iotdb/jdbc/Config.java

@@ -16,6 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
+
 package org.apache.iotdb.jdbc;
 
 import org.apache.iotdb.jdbc.Constant.Version;

iotdb-client/jdbc/src/main/java/org/apache/iotdb/jdbc/Constant.java

@@ -16,6 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
+
 package org.apache.iotdb.jdbc;
 
 public class Constant {

iotdb-client/jdbc/src/main/java/org/apache/iotdb/jdbc/Field.java

@@ -16,6 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
+
 package org.apache.iotdb.jdbc;
 
 public class Field {

iotdb-client/jdbc/src/main/java/org/apache/iotdb/jdbc/GroupedLSBWatermarkEncoder.java

@@ -16,6 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
+
 package org.apache.iotdb.jdbc;
 
 import org.apache.iotdb.tsfile.file.metadata.enums.TSDataType;

iotdb-client/jdbc/src/main/java/org/apache/iotdb/jdbc/IoTDBConnection.java

@@ -16,6 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
+
 package org.apache.iotdb.jdbc;
 
 import org.apache.iotdb.common.rpc.thrift.TSStatus;

iotdb-client/jdbc/src/main/java/org/apache/iotdb/jdbc/IoTDBConnectionParams.java

@@ -16,6 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
+
 package org.apache.iotdb.jdbc;
 
 import org.apache.iotdb.rpc.RpcUtils;

iotdb-client/jdbc/src/main/java/org/apache/iotdb/jdbc/IoTDBDataSource.java

@@ -14,6 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
+
 package org.apache.iotdb.jdbc;
 
 import org.apache.thrift.transport.TTransportException;

iotdb-client/jdbc/src/main/java/org/apache/iotdb/jdbc/IoTDBDataSourceFactory.java

@@ -14,6 +14,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
+
 package org.apache.iotdb.jdbc;
 
 import org.ops4j.pax.jdbc.common.BeanConfig;

iotdb-client/jdbc/src/main/java/org/apache/iotdb/jdbc/IoTDBDatabaseMetadata.java

@@ -16,6 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
+
 package org.apache.iotdb.jdbc;
 
 import org.apache.iotdb.rpc.RpcUtils;
@@ -724,7 +725,13 @@ public class IoTDBDatabaseMetadata implements DatabaseMetaData {
   @Override
   public ResultSet getCatalogs() throws SQLException {
     Statement stmt = this.connection.createStatement();
-    ResultSet rs = stmt.executeQuery(SHOW_DATABASES_SQL);
+    ResultSet rs;
+    try {
+      rs = stmt.executeQuery(SHOW_DATABASES_SQL);
+    } catch (SQLException e) {
+      stmt.close();
+      throw e;
+    }
 
     List<String> columnNameList = new ArrayList<>();
     List<String> columnTypeList = new ArrayList<>();
@@ -812,8 +819,13 @@ public class IoTDBDatabaseMetadata implements DatabaseMetaData {
   @Override
   public ResultSet getClientInfoProperties() throws SQLException {
     Statement stmt = this.connection.createStatement();
-    ResultSet rs = stmt.executeQuery(SHOW_DATABASES_SQL);
-
+    ResultSet rs;
+    try {
+      rs = stmt.executeQuery(SHOW_DATABASES_SQL);
+    } catch (SQLException e) {
+      stmt.close();
+      throw e;
+    }
     Field[] fields = new Field[4];
     fields[0] = new Field("", "NAME", "TEXT");
     fields[1] = new Field("", "MAX_LEN", INT32);
@@ -902,7 +914,13 @@ public class IoTDBDatabaseMetadata implements DatabaseMetaData {
         && columnNamePattern.length() > 0) {
       sql = sql + "." + columnNamePattern;
     }
-    ResultSet rs = stmt.executeQuery(sql);
+    ResultSet rs;
+    try {
+      rs = stmt.executeQuery(sql);
+    } catch (SQLException e) {
+      stmt.close();
+      throw e;
+    }
     Field[] fields = new Field[8];
     fields[0] = new Field("", TABLE_CAT, "TEXT");
     fields[1] = new Field("", TABLE_SCHEM, "TEXT");
@@ -1158,7 +1176,13 @@ public class IoTDBDatabaseMetadata implements DatabaseMetaData {
       java.lang.String columnNamePattern)
       throws SQLException {
     Statement stmt = connection.createStatement();
-    ResultSet rs = stmt.executeQuery(SHOW_FUNCTIONS);
+    ResultSet rs;
+    try {
+      rs = stmt.executeQuery(SHOW_FUNCTIONS);
+    } catch (SQLException e) {
+      stmt.close();
+      throw e;
+    }
     Field[] fields = new Field[17];
     fields[0] = new Field("", "FUNCTION_CAT ", "TEXT");
     fields[1] = new Field("", "FUNCTION_SCHEM", "TEXT");
@@ -1250,7 +1274,13 @@ public class IoTDBDatabaseMetadata implements DatabaseMetaData {
   public ResultSet getFunctions(String catalog, String schemaPattern, String functionNamePattern)
       throws SQLException {
     Statement stmt = connection.createStatement();
-    ResultSet rs = stmt.executeQuery(SHOW_FUNCTIONS);
+    ResultSet rs;
+    try {
+      rs = stmt.executeQuery(SHOW_FUNCTIONS);
+    } catch (SQLException e) {
+      stmt.close();
+      throw e;
+    }
     Field[] fields = new Field[6];
     fields[0] = new Field("", "FUNCTION_CAT ", "TEXT");
     fields[1] = new Field("", "FUNCTION_SCHEM", "TEXT");
@@ -1828,7 +1858,13 @@ public class IoTDBDatabaseMetadata implements DatabaseMetaData {
   @Override
   public ResultSet getSchemas() throws SQLException {
     Statement stmt = this.connection.createStatement();
-    ResultSet rs = stmt.executeQuery(SHOW_DATABASES_SQL);
+    ResultSet rs;
+    try {
+      rs = stmt.executeQuery(SHOW_DATABASES_SQL);
+    } catch (SQLException e) {
+      stmt.close();
+      throw e;
+    }
     Field[] fields = new Field[2];
     fields[0] = new Field("", TABLE_SCHEM, "TEXT");
     fields[1] = new Field("", "TABLE_CATALOG", "TEXT");
@@ -2026,8 +2062,13 @@ public class IoTDBDatabaseMetadata implements DatabaseMetaData {
       }
       sql = sql + "." + tableNamePattern;
     }
-
-    ResultSet rs = stmt.executeQuery(sql);
+    ResultSet rs;
+    try {
+      rs = stmt.executeQuery(sql);
+    } catch (SQLException e) {
+      stmt.close();
+      throw e;
+    }
     Field[] fields = new Field[8];
     fields[0] = new Field("", TABLE_CAT, "TEXT");
     fields[1] = new Field("", TABLE_SCHEM, "TEXT");
@@ -2184,7 +2225,13 @@ public class IoTDBDatabaseMetadata implements DatabaseMetaData {
       }
       sql = sql + "." + columnNamePattern;
     }
-    ResultSet rs = stmt.executeQuery(sql);
+    ResultSet rs;
+    try {
+      rs = stmt.executeQuery(sql);
+    } catch (SQLException e) {
+      stmt.close();
+      throw e;
+    }
     Field[] fields = new Field[24];
     fields[0] = new Field("", TABLE_CAT, "TEXT");
     fields[1] = new Field("", TABLE_SCHEM, "TEXT");
@@ -2439,7 +2486,13 @@ public class IoTDBDatabaseMetadata implements DatabaseMetaData {
       }
       sql = sql + "." + tableNamePattern;
     }
-    ResultSet rs = stmt.executeQuery(sql);
+    ResultSet rs;
+    try {
+      rs = stmt.executeQuery(sql);
+    } catch (SQLException e) {
+      stmt.close();
+      throw e;
+    }
     Field[] fields = new Field[10];
     fields[0] = new Field("", TABLE_CAT, "TEXT");
     fields[1] = new Field("", TABLE_SCHEM, "TEXT");

iotdb-client/jdbc/src/main/java/org/apache/iotdb/jdbc/IoTDBDriver.java

@@ -16,6 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
+
 package org.apache.iotdb.jdbc;
 
 import org.apache.thrift.transport.TTransportException;

iotdb-client/jdbc/src/main/java/org/apache/iotdb/jdbc/IoTDBPreparedStatement.java

@@ -16,6 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
+
 package org.apache.iotdb.jdbc;
 
 import org.apache.iotdb.service.rpc.thrift.IClientRPCService.Iface;

iotdb-client/jdbc/src/main/java/org/apache/iotdb/jdbc/IoTDBResultMetadata.java

@@ -16,6 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
+
 package org.apache.iotdb.jdbc;
 
 import java.sql.ResultSetMetaData;

iotdb-client/jdbc/src/main/java/org/apache/iotdb/jdbc/IoTDBURLException.java

@@ -16,6 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
+
 package org.apache.iotdb.jdbc;
 
 import java.sql.SQLException;

iotdb-client/jdbc/src/main/java/org/apache/iotdb/jdbc/StringUtils.java

@@ -16,6 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
+
 package org.apache.iotdb.jdbc;
 
 import org.slf4j.Logger;

iotdb-client/jdbc/src/main/java/org/apache/iotdb/jdbc/Utils.java

@@ -16,6 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
+
 package org.apache.iotdb.jdbc;
 
 import java.time.DateTimeException;

iotdb-client/jdbc/src/main/java/org/apache/iotdb/jdbc/WatermarkEncoder.java

@@ -16,6 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
+
 package org.apache.iotdb.jdbc;
 
 import org.apache.iotdb.tsfile.read.common.RowRecord;

iotdb-client/jdbc/src/test/java/org/apache/iotdb/jdbc/BatchTest.java

@@ -16,6 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
+
 package org.apache.iotdb.jdbc;
 
 import org.apache.iotdb.common.rpc.thrift.TSStatus;

iotdb-client/jdbc/src/test/java/org/apache/iotdb/jdbc/IoTDBConnectionTest.java

@@ -16,6 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
+
 package org.apache.iotdb.jdbc;
 
 import org.apache.iotdb.common.rpc.thrift.TSStatus;

iotdb-client/jdbc/src/test/java/org/apache/iotdb/jdbc/IoTDBDatabaseMetadataTest.java

@@ -16,6 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
+
 package org.apache.iotdb.jdbc;
 
 import org.apache.iotdb.common.rpc.thrift.TSStatus;

iotdb-client/jdbc/src/test/java/org/apache/iotdb/jdbc/IoTDBJDBCResultSetTest.java

@@ -16,6 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
+
 package org.apache.iotdb.jdbc;
 
 import org.apache.iotdb.common.rpc.thrift.TSStatus;

iotdb-client/jdbc/src/test/java/org/apache/iotdb/jdbc/IoTDBPreparedStatementTest.java

@@ -16,6 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
+
 package org.apache.iotdb.jdbc;
 
 import org.apache.iotdb.common.rpc.thrift.TSStatus;

iotdb-client/jdbc/src/test/java/org/apache/iotdb/jdbc/IoTDBResultMetadataTest.java

@@ -16,6 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
+
 package org.apache.iotdb.jdbc;
 
 import org.junit.After;

iotdb-client/jdbc/src/test/java/org/apache/iotdb/jdbc/IoTDBStatementTest.java

@@ -16,6 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
+
 package org.apache.iotdb.jdbc;
 
 import org.apache.iotdb.rpc.RpcUtils;

iotdb-client/jdbc/src/test/java/org/apache/iotdb/jdbc/UtilsTest.java

@@ -16,6 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
+
 package org.apache.iotdb.jdbc;
 
 import org.apache.iotdb.common.rpc.thrift.TSStatus;

iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/AutoResizingBuffer.java

@@ -16,6 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
+
 package org.apache.iotdb.rpc;
 
 import java.util.Arrays;

iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/BatchExecutionException.java

@@ -16,6 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
+
 package org.apache.iotdb.rpc;
 
 import org.apache.iotdb.common.rpc.thrift.TSStatus;

iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/ConfigNodeConnectionException.java

@@ -16,6 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
+
 package org.apache.iotdb.rpc;
 
 public class ConfigNodeConnectionException extends Exception {

iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/IoTDBConnectionException.java

@@ -16,6 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
+
 package org.apache.iotdb.rpc;
 
 public class IoTDBConnectionException extends Exception {

iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/NoValidValueException.java

@@ -16,6 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
+
 package org.apache.iotdb.rpc;
 
 public class NoValidValueException extends RuntimeException {

iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/RpcUtils.java

@@ -16,6 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
+
 package org.apache.iotdb.rpc;
 
 import org.apache.iotdb.common.rpc.thrift.TEndPoint;

iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/StatementExecutionException.java

@@ -16,6 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
+
 package org.apache.iotdb.rpc;
 
 import org.apache.iotdb.common.rpc.thrift.TSStatus;

iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/SynchronizedHandler.java

@@ -16,6 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
+
 package org.apache.iotdb.rpc;
 
 import org.apache.iotdb.service.rpc.thrift.IClientRPCService;

iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/TCompressedElasticFramedTransport.java

@@ -16,6 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
+
 package org.apache.iotdb.rpc;
 
 import org.apache.thrift.transport.TTransport;

iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/TElasticFramedTransport.java

@@ -16,6 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
+
 package org.apache.iotdb.rpc;
 
 import org.apache.thrift.TConfiguration;

iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/TSnappyElasticFramedTransport.java

@@ -16,6 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
+
 package org.apache.iotdb.rpc;
 
 import org.apache.thrift.transport.TTransport;

iotdb-client/session/src/main/java/org/apache/iotdb/session/Session.java

@@ -16,6 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
+
 package org.apache.iotdb.session;
 
 import org.apache.iotdb.common.rpc.thrift.TAggregationType;

iotdb-client/session/src/main/java/org/apache/iotdb/session/pool/SessionPool.java

@@ -16,6 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
+
 package org.apache.iotdb.session.pool;
 
 import org.apache.iotdb.common.rpc.thrift.TAggregationType;
@@ -70,6 +71,10 @@ import java.util.concurrent.ConcurrentMap;
  * <p>Another case that you have to manually call closeResultSet() is that when there is exception
  * when you call SessionDataSetWrapper.hasNext() or next()
  */
+
+// ignore Generic exceptions & Throwable should never be throw, ignore Either log or rethrow this
+// exception.
+@SuppressWarnings({"squid:S112", "java:S1181", "java:S2139"})
 public class SessionPool implements ISessionPool {
 
   private static final Logger logger = LoggerFactory.getLogger(SessionPool.class);

iotdb-client/session/src/main/java/org/apache/iotdb/session/template/InternalNode.java

@@ -16,6 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
+
 package org.apache.iotdb.session.template;
 
 import org.apache.iotdb.isession.template.TemplateNode;

iotdb-client/session/src/main/java/org/apache/iotdb/session/template/MeasurementNode.java

@@ -16,6 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
+
 package org.apache.iotdb.session.template;
 
 import org.apache.iotdb.isession.template.TemplateNode;

iotdb-client/session/src/main/java/org/apache/iotdb/session/util/SessionUtils.java

@@ -16,6 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
+
 package org.apache.iotdb.session.util;
 
 import org.apache.iotdb.common.rpc.thrift.TEndPoint;

iotdb-client/session/src/test/java/org/apache/iotdb/session/TabletTest.java

@@ -16,6 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
+
 package org.apache.iotdb.session;
 
 import org.apache.iotdb.tsfile.file.metadata.enums.TSDataType;

iotdb-client/session/src/test/java/org/apache/iotdb/session/pool/SessionPoolTest.java

@@ -16,6 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
+
 package org.apache.iotdb.session.pool;
 
 import org.apache.iotdb.isession.util.Version;

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/basic/BasicOpenSessionResp.java

@@ -16,6 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
+
 package org.apache.iotdb.db.protocol.basic;
 
 import org.apache.iotdb.common.rpc.thrift.TSStatus;

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/mqtt/BrokerAuthenticator.java

@@ -15,6 +15,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
+
 package org.apache.iotdb.db.protocol.mqtt;
 
 import org.apache.iotdb.commons.auth.AuthException;

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/mqtt/JSONPayloadFormatter.java

@@ -15,6 +15,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
+
 package org.apache.iotdb.db.protocol.mqtt;
 
 import com.google.common.collect.Lists;

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/mqtt/MPPPublishHandler.java

@@ -15,6 +15,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
+
 package org.apache.iotdb.db.protocol.mqtt;
 
 import org.apache.iotdb.common.rpc.thrift.TSStatus;

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/mqtt/PayloadFormatManager.java

@@ -15,6 +15,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
+
 package org.apache.iotdb.db.protocol.mqtt;
 
 import org.apache.iotdb.commons.file.SystemFileFactory;