spotless

Author: Caideyipi

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/realtime/disruptor/RingBuffer.java

@@ -220,9 +220,7 @@ public <A> void publishEvent(EventTranslator<E, A> translator, A arg0) {
    * @return {@code true} if the event is published, {@code false} if the publish is aborted
    */
   public <A> boolean publishEvent(
-      final EventTranslator<E, A> translator,
-      final A arg0,
-      final BooleanSupplier abortCondition) {
+      final EventTranslator<E, A> translator, final A arg0, final BooleanSupplier abortCondition) {
     final long sequence = sequencer.next(1, abortCondition);
     if (sequence == Sequence.INITIAL_VALUE) {
       return false;

iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/source/dataregion/realtime/disruptor/DisruptorShutdownTest.java

@@ -119,8 +119,7 @@ public void testUnexpectedInterruptDoesNotStopProcessor() throws Exception {
     final AtomicReference<Thread> processorThreadReference = new AtomicReference<>();
     final ThreadFactory threadFactory =
         runnable -> {
-          final Thread thread =
-              new Thread(runnable, "pipe-disruptor-unexpected-interrupt-test");
+          final Thread thread = new Thread(runnable, "pipe-disruptor-unexpected-interrupt-test");
           processorThreadReference.set(thread);
           return thread;
         };