Qishang Zhong

[FLINK-28817] NullPointerException in HybridSource when restoring from checkpoint

2

## What is the purpose of the change This pull request fix NullPointerException in HybridSource when restoring from checkpoint. After the recovery action is triggered, only the source with sourceIndex...

[AMORO-2553] Parallelize reading of EQ delete files and cache them on optimizers

1

## Why are the changes needed? Close #2553. ## Brief change log - ## How was this patch tested? - [ ] Add some test cases that check the changes...

[Improvement]: The optimizer adds a cache of eq delete files to reduce repeated IO cost of eq delete files

6

### Search before asking - [X] I have searched in the [issues](https://github.com/NetEase/amoro/issues?q=is%3Aissue) and found no similar issues. ### What would you like to be improved? For large tables written by...

[Improvement]: Improve the display of `Duration` in the page of `Optimizing>Tables`

5

### Search before asking - [X] I have searched in the [issues](https://github.com/NetEase/amoro/issues?q=is%3Aissue) and found no similar issues. ### What would you like to be improved? Improve the display of `Duration`...

[AMORO-1794] Add cache catalog config for iceberg catalog

5

## Why are the changes needed? Fix #1794 ## Brief change log - *Use CachingCatalog wrap caltalog* - *Add class IcebergCachingCatalogWrapper.java* ## How was this patch tested? - [ ]...

[Improvement]: More detail for table metrics

3

### Search before asking - [X] I have searched in the [issues](https://github.com/NetEase/amoro/issues?q=is%3Aissue) and found no similar issues. ### What would you like to be improved?   Current Base table...

[FLINK-35119][cdc-runtime] Change DataChangeEvent serialization and eserialization

2

Resolve [FLINK-35119](https://issues.apache.org/jira/browse/FLINK-35119). The `before` and `after` of DataChangeEvent participate in serialization in case of null value.

[Improvement]: Remove deprecated code that needs to be removed in 0.7

2

### Search before asking - [X] I have searched in the [issues](https://github.com/apache/amoro/issues?q=is%3Aissue) and found no similar issues. ### What would you like to be improved? Remove `org.apache.amoro.optimizer.common.OptimizerConfig#memorySize` and related code....

Flink: Fix duplicate data in Flink's upsert writer for format V2

16

resolve #10431

Flink: Backport PR #10526 to v1.18 and v1.20

2

Backport PR #10526