You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ro...@apache.org on 2023/05/09 16:55:05 UTC

[iotdb] 02/08: mvn spotless:apply

This is an automated email from the ASF dual-hosted git repository.

rong pushed a commit to branch IOTDB-5848
in repository https://gitbox.apache.org/repos/asf/iotdb.git

commit c353c197a0adc0fa57415e4625d85037362519f1
Author: Steve Yurong Su <ro...@apache.org>
AuthorDate: Mon May 8 22:43:30 2023 +0800

    mvn spotless:apply
---
 .../db/pipe/task/subtask/PipeConnectorSubtask.java |  4 +--
 .../executor/PipeAssignerSubtaskExecutorTest.java  | 40 ----------------------
 2 files changed, 1 insertion(+), 43 deletions(-)

diff --git a/server/src/main/java/org/apache/iotdb/db/pipe/task/subtask/PipeConnectorSubtask.java b/server/src/main/java/org/apache/iotdb/db/pipe/task/subtask/PipeConnectorSubtask.java
index c7ab2bd58e..c07f83632c 100644
--- a/server/src/main/java/org/apache/iotdb/db/pipe/task/subtask/PipeConnectorSubtask.java
+++ b/server/src/main/java/org/apache/iotdb/db/pipe/task/subtask/PipeConnectorSubtask.java
@@ -43,9 +43,7 @@ public class PipeConnectorSubtask extends PipeSubtask {
   // output
   private final PipeConnector pipeConnector;
 
-  /**
-   * @param taskID connectorAttributeSortedString
-   */
+  /** @param taskID connectorAttributeSortedString */
   public PipeConnectorSubtask(String taskID, PipeConnector pipeConnector) {
     super(taskID);
     // TODO: make the size of the queue size reasonable and configurable
diff --git a/server/src/test/java/org/apache/iotdb/db/pipe/execution/executor/PipeAssignerSubtaskExecutorTest.java b/server/src/test/java/org/apache/iotdb/db/pipe/execution/executor/PipeAssignerSubtaskExecutorTest.java
deleted file mode 100644
index c3c5aedb86..0000000000
--- a/server/src/test/java/org/apache/iotdb/db/pipe/execution/executor/PipeAssignerSubtaskExecutorTest.java
+++ /dev/null
@@ -1,40 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements.  See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership.  The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License.  You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied.  See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-
-package org.apache.iotdb.db.pipe.execution.executor;
-
-import org.apache.iotdb.db.pipe.task.subtask.PipeAssignerSubtask;
-
-import org.junit.Before;
-import org.mockito.Mockito;
-
-public class PipeAssignerSubtaskExecutorTest extends PipeSubtaskExecutorTest {
-
-  @Before
-  public void setUp() throws Exception {
-    executor = new PipeAssignerSubtaskExecutor();
-
-    subtask =
-        Mockito.spy(
-            new PipeAssignerSubtask("PipeAssignerSubtaskExecutorTest") {
-              @Override
-              public void executeForAWhile() {}
-            });
-  }
-}