This is an automated email from the ASF dual-hosted git repository. rong pushed a commit to branch remove-sync-entry in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 15377f69bd24310b2828bb4c48223d8350da224d Author: Steve Yurong Su <[email protected]> AuthorDate: Sat Jun 17 04:45:27 2023 +0800 fix comp --- .../java/org/apache/iotdb/db/pipe/connector/legacy/loader/ILoader.java | 3 +-- .../org/apache/iotdb/db/pipe/connector/legacy/loader/TsFileLoader.java | 3 +-- 2 files changed, 2 insertions(+), 4 deletions(-) diff --git a/server/src/main/java/org/apache/iotdb/db/pipe/connector/legacy/loader/ILoader.java b/server/src/main/java/org/apache/iotdb/db/pipe/connector/legacy/loader/ILoader.java index 0639dd50ead..8c5a4dd81cb 100644 --- a/server/src/main/java/org/apache/iotdb/db/pipe/connector/legacy/loader/ILoader.java +++ b/server/src/main/java/org/apache/iotdb/db/pipe/connector/legacy/loader/ILoader.java @@ -22,7 +22,6 @@ import org.apache.iotdb.db.mpp.plan.analyze.ClusterPartitionFetcher; import org.apache.iotdb.db.mpp.plan.analyze.IPartitionFetcher; import org.apache.iotdb.db.mpp.plan.analyze.schema.ClusterSchemaFetcher; import org.apache.iotdb.db.mpp.plan.analyze.schema.ISchemaFetcher; -import org.apache.iotdb.db.pipe.connector.legacy.exception.SyncDataLoadException; /** * This interface is used to load files, including tsFile, syncTask, schema, modsFile and @@ -34,5 +33,5 @@ public interface ILoader { ISchemaFetcher SCHEMA_FETCHER = ClusterSchemaFetcher.getInstance(); - void load() throws SyncDataLoadException; + void load(); } diff --git a/server/src/main/java/org/apache/iotdb/db/pipe/connector/legacy/loader/TsFileLoader.java b/server/src/main/java/org/apache/iotdb/db/pipe/connector/legacy/loader/TsFileLoader.java index 6d0be5ab785..10b9aa5e95d 100644 --- a/server/src/main/java/org/apache/iotdb/db/pipe/connector/legacy/loader/TsFileLoader.java +++ b/server/src/main/java/org/apache/iotdb/db/pipe/connector/legacy/loader/TsFileLoader.java @@ -25,7 +25,6 @@ import org.apache.iotdb.db.exception.LoadFileException; import org.apache.iotdb.db.mpp.plan.Coordinator; import org.apache.iotdb.db.mpp.plan.execution.ExecutionResult; import org.apache.iotdb.db.mpp.plan.statement.crud.LoadTsFileStatement; -import org.apache.iotdb.db.pipe.connector.legacy.exception.SyncDataLoadException; import org.apache.iotdb.db.query.control.SessionManager; import org.apache.iotdb.pipe.api.exception.PipeException; import org.apache.iotdb.rpc.TSStatusCode; @@ -49,7 +48,7 @@ public class TsFileLoader implements ILoader { } @Override - public void load() throws SyncDataLoadException { + public void load() { try { LoadTsFileStatement statement = new LoadTsFileStatement(tsFile.getAbsolutePath()); statement.setDeleteAfterLoad(true);
