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 <9107319+jntur...@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);