Close MQTTMessageLogger log output in test (#5350)

Author: ericpai

cluster/src/test/resources/logback.xml …ster/src/test/resources/logback-test.xmlcluster/src/test/resources/logback.xml renamed to cluster/src/test/resources/logback-test.xml cluster/src/test/resources/logback.xml renamed to cluster/src/test/resources/logback-test.xml

@@ -34,7 +34,7 @@
     <!--    <logger name="org.apache.iotdb.cluster.log.manage.serializable.SyncLogDequeSerializer" level="DEBUG"/>-->
     <!--    <logger name="org.apache.iotdb.cluster.query.reader.RemoteSimpleSeriesReader" level="DEBUG"/>-->
     <logger name="org.apache.thrift.server.TThreadPoolServer" level="ERROR"/>
-    <root level="warn">
+    <root level="ERROR">
         <appender-ref ref="stdout"/>
     </root>
     <!--    <logger level="info" name="org.apache.iotdb.cluster.log.manage.serializable.SyncLogDequeSerializer"/>-->

cross-tests/src/test/java/org/apache/iotdb/cross/tests/tools/importCsv/ExportCsvTestIT.java

@@ -123,19 +123,26 @@ public void testAggregationQuery()
   }
 
   private void prepareData() throws IoTDBConnectionException, StatementExecutionException {
-    Session session = new Session("127.0.0.1", 6667, "root", "root");
-    session.open();
+    Session session = null;
+    try {
+      session = new Session("127.0.0.1", 6667, "root", "root");
+      session.open();
 
-    String deviceId = "root.test.t1";
-    List<String> measurements = new ArrayList<>();
-    measurements.add("c1");
-    measurements.add("c2");
-    measurements.add("c3");
+      String deviceId = "root.test.t1";
+      List<String> measurements = new ArrayList<>();
+      measurements.add("c1");
+      measurements.add("c2");
+      measurements.add("c3");
 
-    List<String> values = new ArrayList<>();
-    values.add("1.0");
-    values.add("\"abc\",aa");
-    values.add("abbe's");
-    session.insertRecord(deviceId, 1L, measurements, values);
+      List<String> values = new ArrayList<>();
+      values.add("1.0");
+      values.add("\"abc\",aa");
+      values.add("abbe's");
+      session.insertRecord(deviceId, 1L, measurements, values);
+    } finally {
+      if (session != null) {
+        session.close();
+      }
+    }
   }
 }

…tegration/src/test/resources/logback.xml …tion/src/test/resources/logback-test.xmlintegration/src/test/resources/logback.xml renamed to integration/src/test/resources/logback-test.xml integration/src/test/resources/logback.xml renamed to integration/src/test/resources/logback-test.xml

@@ -52,7 +52,7 @@
     <logger name="org.apache.iotdb.db.service.MQTTService" level="INFO"/>
     <logger name="org.apache.iotdb.db.sync.receiver.SyncServerManager" level="INFO"/>
     <logger name="DETAILED_FAILURE_QUERY_TRACE" level="ERROR"/>
-    <root level="WARN">
+    <root level="ERROR">
         <appender-ref ref="stdout"/>
     </root>
 </configuration>

server/src/test/resources/logback.xml …rver/src/test/resources/logback-test.xmlserver/src/test/resources/logback.xml renamed to server/src/test/resources/logback-test.xml server/src/test/resources/logback.xml renamed to server/src/test/resources/logback-test.xml

@@ -51,8 +51,10 @@
     <logger name="org.apache.iotdb.db.service.RPCService" level="INFO"/>
     <logger name="org.apache.iotdb.db.service.MQTTService" level="INFO"/>
     <logger name="org.apache.iotdb.db.sync.receiver.SyncServerManager" level="INFO"/>
+    <logger name="org.apache.iotdb.db.engine.compaction.cross.rewrite.task" level="ERROR"/>
+    <logger name="io.moquette.broker.metrics.MQTTMessageLogger" level="ERROR"/>
     <logger name="DETAILED_FAILURE_QUERY_TRACE" level="ERROR"/>
-    <root level="WARN">
+    <root level="ERROR">
         <appender-ref ref="stdout"/>
     </root>
 </configuration>