fix datasource error (#680)

Co-authored-by: “v_kkhuang” <“[email protected]”>
WeDataSphere · Dec 18, 2024 · 6d23d7c · 6d23d7c
1 parent 84df21e
commit 6d23d7c
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...linkis-metadata/src/main/java/org/apache/linkis/metadata/service/impl/MdqServiceImpl.java b/...linkis-metadata/src/main/java/org/apache/linkis/metadata/service/impl/MdqServiceImpl.java
@@ -376,7 +376,7 @@ public String getTableLocation(MetadataQueryParam queryParam) {
 
   private int getTableFileNum(String tableLocation) throws IOException {
     int tableFileNum = 0;
-    if (StringUtils.isNotBlank(tableLocation)) {
+    if (StringUtils.isNotBlank(tableLocation) && getRootHdfs().exists(new Path(tableLocation))) {
       FileStatus tableFile = getFileStatus(tableLocation);
       tableFileNum = (int) getRootHdfs().getContentSummary(tableFile.getPath()).getFileCount();
     }