This is an automated email from the ASF dual-hosted git repository.
lzljs3620320 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git
The following commit(s) were added to refs/heads/master by this push:
new 9a4111f44d [hotfix] Fix compile error in AppendOnlyWriterTest
9a4111f44d is described below
commit 9a4111f44d4d1af11b77242e9c813c4560a3149e
Author: JingsongLi <[email protected]>
AuthorDate: Tue Oct 21 22:00:34 2025 +0800
[hotfix] Fix compile error in AppendOnlyWriterTest
---
.../apache/paimon/append/AppendOnlyWriterTest.java | 48 ----------------------
1 file changed, 48 deletions(-)
diff --git
a/paimon-core/src/test/java/org/apache/paimon/append/AppendOnlyWriterTest.java
b/paimon-core/src/test/java/org/apache/paimon/append/AppendOnlyWriterTest.java
index b593cf0ef7..56426fce2e 100644
---
a/paimon-core/src/test/java/org/apache/paimon/append/AppendOnlyWriterTest.java
+++
b/paimon-core/src/test/java/org/apache/paimon/append/AppendOnlyWriterTest.java
@@ -763,52 +763,4 @@ public class AppendOnlyWriterTest {
private InternalRow createBlobRow(int id, String name, byte[] blobData) {
return GenericRow.of(id, BinaryString.fromString(name), new
BlobData(blobData));
}
-
- private AppendOnlyWriter createWriterWithBlobSchema(
- RowType schema, long targetFileSize, boolean spillable) {
- FileFormat fileFormat = FileFormat.fromIdentifier(AVRO, new Options());
- LinkedList<DataFileMeta> toCompact = new LinkedList<>();
- BucketedAppendCompactManager compactManager =
- new BucketedAppendCompactManager(
- Executors.newSingleThreadScheduledExecutor(
- new
ExecutorThreadFactory("compaction-thread")),
- toCompact,
- null,
- MIN_FILE_NUM,
- targetFileSize,
- false,
- compactBefore -> Collections.emptyList(),
- null);
- CoreOptions options =
- new
CoreOptions(Collections.singletonMap("metadata.stats-mode", "truncate(16)"));
- AppendOnlyWriter writer =
- new AppendOnlyWriter(
- LocalFileIO.create(),
- IOManager.create(tempDir.toString()),
- SCHEMA_ID,
- fileFormat,
- targetFileSize,
- schema,
- null,
- getMaxSequenceNumber(toCompact),
- compactManager,
- files -> {
- throw new RuntimeException("Can't read back in
blob mode");
- },
- false,
- pathFactory,
- null,
- false,
- spillable,
- CoreOptions.FILE_COMPRESSION.defaultValue(),
- CompressOptions.defaultOptions(),
- new StatsCollectorFactories(options),
- MemorySize.MAX_VALUE,
- new FileIndexOptions(),
- true,
- false);
- writer.setMemoryPool(
- new HeapMemorySegmentPool(options.writeBufferSize(),
options.pageSize()));
- return writer;
- }
}