paimon

paimon copied to clipboard

### Search before asking - [x] I searched in the [issues](https://github.com/apache/paimon/issues) and found nothing similar. ### Paimon version paimon 1.2 ### Compute Engine Flink ### Minimal reproduce step We plan...

hz-git

[Feature] [core] Iceberg: createMetadataWithoutBase should include full history of Paimon snapshots

3

### Search before asking - [x] I searched in the [issues](https://github.com/apache/paimon/issues) and found nothing similar. ### Motivation Code path: https://github.com/apache/paimon/blob/ff02f6bf3ceccf8dcac38bc58cf6db390509bd46/paimon-core/src/main/java/org/apache/paimon/iceberg/IcebergCommitCallback.java#L305C49-L305C59 createMetadataWithoutBase is called under certain conditions like - enabling Iceberg...

nickdelnano

### Search before asking - [x] I searched in the [issues](https://github.com/apache/paimon/issues) and found nothing similar. ### Paimon version paimon 1.1.0 1.1.1 The downloaded paimon-cosn JAR from https://repo.maven.apache.org/maven2/org/apache/paimon/paimon-cosn/ has an issue:...

andybj0228

[core] Don't allow full compaction with lookup changelog producer

1

- Currently there is no check against full compaction on lookup changelog producer. - User reported unexpected behaviour in #6183 - Disable setting both the properties together instead of the...

ArnavBalyan

[Bug] full-compaction.delta-commits

1

### Search before asking - [x] I searched in the [issues](https://github.com/apache/paimon/issues) and found nothing similar. ### Paimon version 77f130bde03381e3b26b86e4f0e95cff5c1dc622 ### Compute Engine Flink ### Minimal reproduce step I created a...

junmuz

[Bug] The `paimon-s3-1.0.1.jar` and the flink plugins `flink-s3-fs-hadoop-1.20.1.jar` conflict with each other, resulting in the shutdown of the S3 connection pool.

1

### Search before asking - [x] I searched in the [issues](https://github.com/apache/paimon/issues) and found nothing similar. ### Paimon version 1.0.1 ### Compute Engine flink 1.20.1 ### Minimal reproduce step The official...

yl-yue

[flink] Fail fast validation for delete with write-only mode enabled

1

- DeleteAction now checks CoreOptions.writeOnly() at the start of run. - If 'write-only' = 'true', it throws a clear UnsupportedOperationException. - avoids deep FileStoreCommitImpl manifest conflict errors. - Added testDeleteActionWriteOnlyRejected...

ArnavBalyan

[core] Standardize flink versions across the modules

1

- Users building Paimon with Flink 1.18.1 encountered "Implementing class" errors due to version mismatches between modules - This patch standardizes the same flink version across modules, with a common...

ArnavBalyan

### Purpose Currently, streaming compact job does not deal with schema change. If the user adds a column, it will be ignored by the compact job and this column will...

tsreaper

### Purpose Linked issue: close #xxx ### Tests ### API and Format ### Documentation

yuzelin