You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pinot.apache.org by xi...@apache.org on 2021/01/19 08:13:54 UTC
[incubator-pinot] branch fixing_hadoopfs_isDirectory created (now
2050c21)
This is an automated email from the ASF dual-hosted git repository.
xiangfu pushed a change to branch fixing_hadoopfs_isDirectory
in repository https://gitbox.apache.org/repos/asf/incubator-pinot.git.
at 2050c21 Fixing pinot hadoop fs isDirectory method
This branch includes the following new commits:
new 2050c21 Fixing pinot hadoop fs isDirectory method
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pinot.apache.org
For additional commands, e-mail: commits-help@pinot.apache.org
[incubator-pinot] 01/01: Fixing pinot hadoop fs isDirectory method
Posted by xi...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
xiangfu pushed a commit to branch fixing_hadoopfs_isDirectory
in repository https://gitbox.apache.org/repos/asf/incubator-pinot.git
commit 2050c219972f8785a7721bd403ed28f19470e661
Author: Xiang Fu <fx...@gmail.com>
AuthorDate: Tue Jan 19 00:13:32 2021 -0800
Fixing pinot hadoop fs isDirectory method
---
.../org/apache/pinot/plugin/filesystem/HadoopPinotFS.java | 11 +++++++----
1 file changed, 7 insertions(+), 4 deletions(-)
diff --git a/pinot-plugins/pinot-file-system/pinot-hdfs/src/main/java/org/apache/pinot/plugin/filesystem/HadoopPinotFS.java b/pinot-plugins/pinot-file-system/pinot-hdfs/src/main/java/org/apache/pinot/plugin/filesystem/HadoopPinotFS.java
index 4024929..b1948bd 100644
--- a/pinot-plugins/pinot-file-system/pinot-hdfs/src/main/java/org/apache/pinot/plugin/filesystem/HadoopPinotFS.java
+++ b/pinot-plugins/pinot-file-system/pinot-hdfs/src/main/java/org/apache/pinot/plugin/filesystem/HadoopPinotFS.java
@@ -202,9 +202,12 @@ public class HadoopPinotFS extends PinotFS {
@Override
public boolean isDirectory(URI uri) {
- FileStatus fileStatus = new FileStatus();
- fileStatus.setPath(new Path(uri));
- return fileStatus.isDirectory();
+ try {
+ _hadoopFS.isDirectory(new Path(uri));
+ } catch (IOException e) {
+ LOGGER.error("Could not check isDirectory for {}", uri, e);
+ throw new RuntimeException(e);
+ }
}
@Override
@@ -212,7 +215,7 @@ public class HadoopPinotFS extends PinotFS {
try {
return _hadoopFS.getFileStatus(new Path(uri)).getModificationTime();
} catch (IOException e) {
- LOGGER.error("Could not get file status for {}", uri);
+ LOGGER.error("Could not get file status for {}", uri, e);
throw new RuntimeException(e);
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pinot.apache.org
For additional commands, e-mail: commits-help@pinot.apache.org