You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@drill.apache.org by dz...@apache.org on 2022/12/22 13:05:35 UTC
[drill] 04/13: Access dirModifCheckMap using a Path not a String. (#2697)
This is an automated email from the ASF dual-hosted git repository.
dzamo pushed a commit to branch 1.20
in repository https://gitbox.apache.org/repos/asf/drill.git
commit 11bf6b291ae8dfba7b8f91e992da47e49080b399
Author: James Turton <91...@users.noreply.github.com>
AuthorDate: Wed Nov 2 15:33:32 2022 +0200
Access dirModifCheckMap using a Path not a String. (#2697)
---
.../main/java/org/apache/drill/exec/store/dfs/MetadataContext.java | 4 +---
.../java/org/apache/drill/exec/store/parquet/metadata/Metadata.java | 2 +-
2 files changed, 2 insertions(+), 4 deletions(-)
diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/store/dfs/MetadataContext.java b/exec/java-exec/src/main/java/org/apache/drill/exec/store/dfs/MetadataContext.java
index 5d3c18e920..e629b18d3f 100644
--- a/exec/java-exec/src/main/java/org/apache/drill/exec/store/dfs/MetadataContext.java
+++ b/exec/java-exec/src/main/java/org/apache/drill/exec/store/dfs/MetadataContext.java
@@ -50,7 +50,7 @@ public class MetadataContext {
dirModifCheckMap.put(dir, false);
}
- public boolean getStatus(String dir) {
+ public boolean getStatus(Path dir) {
if (dirModifCheckMap.containsKey(dir)) {
return dirModifCheckMap.get(dir);
}
@@ -101,5 +101,3 @@ public class MetadataContext {
}
}
-
-
diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/metadata/Metadata.java b/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/metadata/Metadata.java
index 92a1adbe38..4e294e5b36 100644
--- a/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/metadata/Metadata.java
+++ b/exec/java-exec/src/main/java/org/apache/drill/exec/store/parquet/metadata/Metadata.java
@@ -575,7 +575,7 @@ public class Metadata {
try (InputStream is = fs.open(path)) {
boolean alreadyCheckedModification;
boolean newMetadata = false;
- alreadyCheckedModification = metaContext.getStatus(metadataParentDirPath);
+ alreadyCheckedModification = metaContext.getStatus(metadataParentDir);
if (dirsOnly) {
parquetTableMetadataDirs = mapper.readValue(is, ParquetTableMetadataDirs.class);