You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ma...@apache.org on 2022/12/31 07:45:27 UTC
[iotdb] branch rel/0.13 updated: [To rel/0.13][IOTDB-5307] Failed to get TsFile input of file: NoSuchFileException (#8640)
This is an automated email from the ASF dual-hosted git repository.
marklau99 pushed a commit to branch rel/0.13
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/rel/0.13 by this push:
new 38942c4359 [To rel/0.13][IOTDB-5307] Failed to get TsFile input of file: NoSuchFileException (#8640)
38942c4359 is described below
commit 38942c4359decbc0f6da8da7eca2e0582d7fb0a8
Author: Pengfei Liu <46...@users.noreply.github.com>
AuthorDate: Sat Dec 31 15:45:20 2022 +0800
[To rel/0.13][IOTDB-5307] Failed to get TsFile input of file: NoSuchFileException (#8640)
---
.../cross/rewrite/RewriteCrossSpaceCompactionSelector.java | 4 +---
.../fileSystem/fileInputFactory/FileInputFactory.java | 4 +++-
.../fileSystem/fileInputFactory/HDFSInputFactory.java | 11 ++++++-----
.../fileSystem/fileInputFactory/LocalFSInputFactory.java | 14 ++------------
4 files changed, 12 insertions(+), 21 deletions(-)
diff --git a/server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/rewrite/RewriteCrossSpaceCompactionSelector.java b/server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/rewrite/RewriteCrossSpaceCompactionSelector.java
index 9599296f15..fea895ae6d 100644
--- a/server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/rewrite/RewriteCrossSpaceCompactionSelector.java
+++ b/server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/rewrite/RewriteCrossSpaceCompactionSelector.java
@@ -30,13 +30,11 @@ import org.apache.iotdb.db.engine.compaction.inner.utils.InnerSpaceCompactionUti
import org.apache.iotdb.db.engine.compaction.task.AbstractCompactionTask;
import org.apache.iotdb.db.engine.storagegroup.TsFileManager;
import org.apache.iotdb.db.engine.storagegroup.TsFileResource;
-import org.apache.iotdb.db.exception.MergeException;
import org.apache.iotdb.db.rescon.SystemInfo;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-import java.io.IOException;
import java.util.ArrayList;
import java.util.Iterator;
import java.util.List;
@@ -137,7 +135,7 @@ public class RewriteCrossSpaceCompactionSelector extends AbstractCrossSpaceCompa
mergeResource.getUnseqFiles().size());
}
- } catch (MergeException | IOException | InterruptedException e) {
+ } catch (Exception e) {
LOGGER.error("{} cannot select file for cross space compaction", logicalStorageGroupName, e);
}
}
diff --git a/tsfile/src/main/java/org/apache/iotdb/tsfile/fileSystem/fileInputFactory/FileInputFactory.java b/tsfile/src/main/java/org/apache/iotdb/tsfile/fileSystem/fileInputFactory/FileInputFactory.java
index 7f63a0b390..d4ae9744e1 100644
--- a/tsfile/src/main/java/org/apache/iotdb/tsfile/fileSystem/fileInputFactory/FileInputFactory.java
+++ b/tsfile/src/main/java/org/apache/iotdb/tsfile/fileSystem/fileInputFactory/FileInputFactory.java
@@ -21,7 +21,9 @@ package org.apache.iotdb.tsfile.fileSystem.fileInputFactory;
import org.apache.iotdb.tsfile.read.reader.TsFileInput;
+import java.io.IOException;
+
public interface FileInputFactory {
- TsFileInput getTsFileInput(String filePath);
+ TsFileInput getTsFileInput(String filePath) throws IOException;
}
diff --git a/tsfile/src/main/java/org/apache/iotdb/tsfile/fileSystem/fileInputFactory/HDFSInputFactory.java b/tsfile/src/main/java/org/apache/iotdb/tsfile/fileSystem/fileInputFactory/HDFSInputFactory.java
index 900ecf350b..6cd1c54050 100644
--- a/tsfile/src/main/java/org/apache/iotdb/tsfile/fileSystem/fileInputFactory/HDFSInputFactory.java
+++ b/tsfile/src/main/java/org/apache/iotdb/tsfile/fileSystem/fileInputFactory/HDFSInputFactory.java
@@ -24,6 +24,7 @@ import org.apache.iotdb.tsfile.read.reader.TsFileInput;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
+import java.io.IOException;
import java.lang.reflect.Constructor;
import java.lang.reflect.InvocationTargetException;
@@ -44,15 +45,15 @@ public class HDFSInputFactory implements FileInputFactory {
}
@Override
- public TsFileInput getTsFileInput(String filePath) {
+ public TsFileInput getTsFileInput(String filePath) throws IOException {
try {
return (TsFileInput) constructor.newInstance(filePath);
} catch (InstantiationException | InvocationTargetException | IllegalAccessException e) {
- logger.error(
- "Failed to get TsFile input of file: {}. Please check your dependency of Hadoop module.",
- filePath,
+ throw new IOException(
+ String.format(
+ "Failed to get TsFile input of file: %s. Please check your dependency of Hadoop module.",
+ filePath),
e);
- return null;
}
}
}
diff --git a/tsfile/src/main/java/org/apache/iotdb/tsfile/fileSystem/fileInputFactory/LocalFSInputFactory.java b/tsfile/src/main/java/org/apache/iotdb/tsfile/fileSystem/fileInputFactory/LocalFSInputFactory.java
index 354cd24cc6..55483d1e25 100644
--- a/tsfile/src/main/java/org/apache/iotdb/tsfile/fileSystem/fileInputFactory/LocalFSInputFactory.java
+++ b/tsfile/src/main/java/org/apache/iotdb/tsfile/fileSystem/fileInputFactory/LocalFSInputFactory.java
@@ -22,23 +22,13 @@ package org.apache.iotdb.tsfile.fileSystem.fileInputFactory;
import org.apache.iotdb.tsfile.read.reader.LocalTsFileInput;
import org.apache.iotdb.tsfile.read.reader.TsFileInput;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
import java.io.IOException;
import java.nio.file.Paths;
public class LocalFSInputFactory implements FileInputFactory {
- private static final Logger logger = LoggerFactory.getLogger(LocalFSInputFactory.class);
-
@Override
- public TsFileInput getTsFileInput(String filePath) {
- try {
- return new LocalTsFileInput(Paths.get(filePath));
- } catch (IOException e) {
- logger.error("Failed to get TsFile input of file: {}, ", filePath, e);
- return null;
- }
+ public TsFileInput getTsFileInput(String filePath) throws IOException {
+ return new LocalTsFileInput(Paths.get(filePath));
}
}