Skip to content

Commit 64ccfb1

Browse files
committed
Move testMultiTableLock To TestLockFactoryBase.
1 parent 2468e52 commit 64ccfb1

File tree

2 files changed

+1
-5
lines changed

2 files changed

+1
-5
lines changed

flink/v2.0/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/DeleteFilesProcessor.java

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,6 @@
3232
import org.apache.iceberg.io.BulkDeletionFailureException;
3333
import org.apache.iceberg.io.FileIO;
3434
import org.apache.iceberg.io.SupportsBulkOperations;
35-
import org.apache.iceberg.relocated.com.google.common.annotations.VisibleForTesting;
3635
import org.apache.iceberg.relocated.com.google.common.base.Preconditions;
3736
import org.apache.iceberg.relocated.com.google.common.collect.Sets;
3837
import org.slf4j.Logger;
@@ -133,17 +132,14 @@ private void deleteFiles() {
133132
}
134133
}
135134

136-
@VisibleForTesting
137135
public Counter getFailedCounter() {
138136
return failedCounter;
139137
}
140138

141-
@VisibleForTesting
142139
public Counter getSucceededCounter() {
143140
return succeededCounter;
144141
}
145142

146-
@VisibleForTesting
147143
public Histogram getDeleteFileTimeMsHistogram() {
148144
return deleteFileTimeMsHistogram;
149145
}

flink/v2.0/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/TestDeleteFilesProcessor.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -204,7 +204,7 @@ void testConcurrentDelete() throws Exception {
204204
try {
205205
testHarness.processElement(file, System.currentTimeMillis());
206206
} catch (Exception e) {
207-
e.printStackTrace();
207+
// do nothing
208208
}
209209
});
210210
}

0 commit comments

Comments
 (0)