lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

[HUDI-2366] fix too many logs (#3543)

Browse Source
This commit is contained in:
ayachi_nene
2021-08-26 16:45:52 +08:00
committed by GitHub
parent 486bc7dc3b
commit be57e42200
1 changed files with 0 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
hudi-common/src/main/java/org/apache/hudi/common/table/view/AbstractTableFileSystemView.java
View File

@@ -354,7 +354,6 @@ public abstract class AbstractTableFileSystemView implements SyncableFileSystemV
protected boolean isFileSliceAfterPendingCompaction(FileSlice fileSlice) { protected boolean isFileSliceAfterPendingCompaction(FileSlice fileSlice) {
Option<Pair<String, CompactionOperation>> compactionWithInstantTime = Option<Pair<String, CompactionOperation>> compactionWithInstantTime =
getPendingCompactionOperationWithInstant(fileSlice.getFileGroupId()); getPendingCompactionOperationWithInstant(fileSlice.getFileGroupId());
LOG.info("Pending Compaction instant for (" + fileSlice + ") is :" + compactionWithInstantTime);
return (compactionWithInstantTime.isPresent()) return (compactionWithInstantTime.isPresent())
&& fileSlice.getBaseInstantTime().equals(compactionWithInstantTime.get().getKey()); && fileSlice.getBaseInstantTime().equals(compactionWithInstantTime.get().getKey());
} }