xiangyu0xf

In our usage, we found the performance bottleneck of relay is transaction writer thread. It takes most cpu time on generating schema md5 for each DbChangeEntry. It is better to...

[FLINK-33932][checkpointing] Add retry mechanism in RocksDBStateUploader

3

## What is the purpose of the change Add retry mechanism in RocksDBStateUploader ## Brief change log - Introduce RetryStrategy in RocksDBStateUploader when uploadFilesToCheckpointFs ## Verifying this change This change...

[Feature] Improve the tryCommitOnce behavior in FileStoreCommitImpl

2

### Search before asking - [X] I searched in the [issues](https://github.com/apache/paimon/issues) and found nothing similar. ### Motivation When using dedicated compactions in production, we've found the write only job and...

WIP:[core] Support async refresh for PrimaryKeyPartialLookupTable

12

### Purpose Linked issue: close #3386 Support async refresh for PrimaryKeyPartialLookupTable. Async refresh files generated by new snapshots which are intervened with expired cached files. The total size of new...

### Search before asking - [X] I searched in the [issues](https://github.com/apache/paimon/issues) and found nothing similar. ### Motivation We need sourceIdleTime metric to get the right currentFetchEventTimeLag metric. User also need...

### Search before asking - [X] I searched in the [issues](https://github.com/apache/paimon/issues) and found nothing similar. ### Paimon version master(8ac121a) ### Compute Engine Flink ### Minimal reproduce step Check the Flink...

[FLINK-35780] Support state migration between disabling and enabling State TTL for RocksDBState

5

[FLINK-35780][state] Support state migration between disabling and enabling State TTL in RocksDBState ## What is the purpose of the change Support state migration between disabling and enabling state for RocksDBState....

[core] Support MULTI_WRITE mode for KeyValueFileStoreWrite when multiple jobs are writing to one table simultaneously…

1

### Purpose Linked issue: close #5214 ### Tests MergeTreeCompactManagerTest#testSyncOrphanFiles() KeyValueFileStoreWriteTest#testMultiWriteModeEnabled() KeyValueFileStoreWriteTest#testMultiWriteModeDisabled() ### API and Format ### Documentation

[core] Support refresh L0 files for MergeTreeCompactManager before compaction

1

### Purpose Linked issue: close #5214 ### Tests MergeTreeCompactManagerTest#testRefresh() KeyValueFileStoreWriteTest#testRefreshL0FilesEnabled() KeyValueFileStoreWriteTest#testRefreshL0FilesDisabled() ### API and Format ### Documentation

### Purpose Linked issue: close #5215 ### Tests BucketedAppendCompactManagerTest#testToCompactRefresh AppendOnlyFixedBucketFileStoreWriteTest#testRefreshCompactFilesEnabled AppendOnlyFixedBucketFileStoreWriteTest#testRefreshCompactFilesDisabled ### API and Format ### Documentation