paimon
paimon copied to clipboard
apache
Apache Paimon is a lake format that enables building a Realtime Lakehouse Architecture with Flink and Spark for both streaming and batch operations.
### Purpose format table: insert data after commit sync partitions to hms ### Tests ### API and Format ### Documentation
### Purpose For example, lookup with scan MAX_PT(), and the current MAX_PT is 20251111. If overwrite pt 20241110, we don't need to reopen the dim table. ### Tests ### API...
### Search before asking - [x] I searched in the [issues](https://github.com/apache/paimon/issues) and found nothing similar. ### Motivation I'd like to utilize commit.callbacks and call a user callback after all system...
### Purpose Linked issue: close #xxx ### Tests ### API and Format ### Documentation
### Search before asking - [x] I searched in the [issues](https://github.com/apache/paimon/issues) and found nothing similar. ### Paimon version Paimon-1.1.1 ### Compute Engine Flink-1.18.1 ### Minimal reproduce step No recurrence has...
### Search before asking - [x] I searched in the [issues](https://github.com/apache/paimon/issues) and found nothing similar. ### Paimon version paimon version 0.8.2 ### Compute Engine starrocks version 3.3.6 ### Minimal reproduce...
### Purpose Linked issue: close #xxx ### Tests ### API and Format ### Documentation
### Purpose Linked issue: close #6039 As explained in the issue, Flink procedures don't parse delimited identifiers correctly when they contain a dot. This change correctly extract the database and...
[core] Adjust distinct option in FieldListaggAgg operator ### Purpose 1. [Fix] Fix `field.{fieldName}.aggregate-function=listagg` behavior when handling empty strings 2. [Feature] Adjust `field.{fieldName}.distict` behavior when aggregating strings Expected behavior: | case...
### Search before asking - [x] I searched in the [issues](https://github.com/apache/paimon/issues) and found nothing similar. ### Motivation Trivy reports the following **HIGH** vulnerability on `org.apache.httpcomponents.client5:httpclient5` (present in `paimon-flink-2.1-1.3.0.jar`): ### Solution...
