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() {}
- });
- }
-}