Skip to content

Commit 0bbff59

Browse files
author
Venu Reddy
committed
Rework of comments
1 parent c64d0b7 commit 0bbff59

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

ql/src/java/org/apache/hadoop/hive/ql/txn/compactor/handler/CompactionCleaner.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -158,7 +158,6 @@ private void clean(CompactionInfo ci, long minOpenTxn, boolean metricsEnabled) t
158158
cleanUsingAcidDir(ci, t, path, cleanerWaterMark);
159159
}
160160
} else {
161-
ci.setSoftDelete(true);
162161
cleanUsingLocation(ci, location, false);
163162
}
164163
} catch (Exception e) {
@@ -177,6 +176,7 @@ private void clean(CompactionInfo ci, long minOpenTxn, boolean metricsEnabled) t
177176

178177
private void cleanUsingLocation(CompactionInfo ci, String path, boolean requiresLock) throws MetaException {
179178
List<Path> deleted;
179+
ci.setSoftDelete(true);
180180
if (requiresLock) {
181181
LockRequest lockRequest = createLockRequest(ci);
182182
LockResponse res = null;

0 commit comments

Comments
 (0)