sp

Author: Caideyipi

iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/cq/CreateCQProcedure.java

@@ -188,8 +188,7 @@ void recoverScheduledTask(ConfigNodeProcedureEnv env) throws ConsensusException
     submitScheduleTask(env, new CQScheduleTask(cqEntry.get(), executor, env.getConfigManager()));
   }
 
-  Optional<CQInfo.CQEntry> getCurrentCQEntry(ConfigNodeProcedureEnv env)
-      throws ConsensusException {
+  Optional<CQInfo.CQEntry> getCurrentCQEntry(ConfigNodeProcedureEnv env) throws ConsensusException {
     ShowCQResp response =
         (ShowCQResp) env.getConfigManager().getConsensusManager().read(new ShowCQPlan());
     return response.getCqList().stream()

iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/persistence/CQInfoTest.java

@@ -125,14 +125,12 @@ public void testOldCallbackCannotTouchRecreatedCQ() throws Exception {
 
     Assert.assertEquals(
         TSStatusCode.NO_SUCH_CQ.getStatusCode(),
-        cqInfo
-            .updateCQLastExecutionTime(
+        cqInfo.updateCQLastExecutionTime(
                 new UpdateCQLastExecTimePlan("testCq3", executionTime + 1000, "oldMd5"))
             .code);
     Assert.assertEquals(
         TSStatusCode.SUCCESS_STATUS.getStatusCode(),
-        cqInfo
-            .updateCQLastExecutionTime(
+        cqInfo.updateCQLastExecutionTime(
                 new UpdateCQLastExecTimePlan("testCq3", executionTime + 1000, "newMd5"))
             .code);
   }

iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/cq/CreateCQProcedureRecoveryTest.java

@@ -19,11 +19,11 @@
 
 package org.apache.iotdb.confignode.procedure.impl.cq;
 
-import org.apache.iotdb.confignode.consensus.request.write.cq.AddCQPlan;
 import org.apache.iotdb.confignode.consensus.request.read.cq.ShowCQPlan;
+import org.apache.iotdb.confignode.consensus.request.write.cq.AddCQPlan;
 import org.apache.iotdb.confignode.manager.ConfigManager;
-import org.apache.iotdb.confignode.manager.cq.CQManager;
 import org.apache.iotdb.confignode.manager.consensus.ConsensusManager;
+import org.apache.iotdb.confignode.manager.cq.CQManager;
 import org.apache.iotdb.confignode.persistence.cq.CQInfo;
 import org.apache.iotdb.confignode.procedure.env.ConfigNodeProcedureEnv;
 import org.apache.iotdb.confignode.rpc.thrift.TCreateCQReq;