Skip to content

Commit 82b5e2b

Browse files
committed
[core] Fix blob compaction test after rebase
1 parent 68d2d73 commit 82b5e2b

1 file changed

Lines changed: 3 additions & 2 deletions

File tree

paimon-core/src/test/java/org/apache/paimon/append/BlobTableTest.java

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -210,9 +210,10 @@ public void testArrayBlobField() throws Exception {
210210
assertArrayBlobRows(blob0, blob1, updatedBlob1, blob2);
211211

212212
DataEvolutionCompactCoordinator coordinator =
213-
new DataEvolutionCompactCoordinator(table, true, false);
213+
new DataEvolutionCompactCoordinator(
214+
table, true, false, table.latestSnapshot().get());
214215
List<DataEvolutionCompactTask> tasks = coordinator.plan();
215-
assertThat(tasks.stream().anyMatch(DataEvolutionCompactTask::isBlobTask)).isTrue();
216+
assertThat(tasks.stream().anyMatch(task -> task.type() == BLOB)).isTrue();
216217

217218
List<CommitMessage> compactMessages = new ArrayList<>();
218219
for (DataEvolutionCompactTask task : tasks) {

0 commit comments

Comments
 (0)