Xiaojian Sun

问题如下： 1. 建议拆分 SinkRecord 和 SourceRecord， 语义明确，方便区分数据执行阶段，同时方便两部分api独立扩展，以防止出现有些字段在 source中用到，却在 sink中用不到但依然存在的情况，容易对使用上带来疑惑，造成过多的沟通的成本； 2. 显式声明topic / offset / queueId等字段，放到 recordPartition中用map 方式存储，结构较深，且对不熟悉代码的人不易发觉，学习成本较高，且导致代码过于松散 3. Record 绑定 topic, 方便多topic路由发送

[Feature] Kafka debezium json supports automatic discovery of primary keys

1

### Purpose Linked issue: close https://github.com/apache/incubator-paimon/issues/2802 ### Tests ### API and Format ### Documentation

[Feature][Connector-V2]Support tidb cdc connector source

2

### Purpose of this pull request closed https://github.com/apache/seatunnel/issues/7199 ### Does this PR introduce _any_ user-facing change? ### How was this patch tested? ### Check list * [ ] If any...

[Feature] Branch allows for setting expiration times.

1

### Search before asking - [X] I searched in the [issues](https://github.com/apache/paimon/issues) and found nothing similar. ### Motivation Branch supports expiration time ### Solution _No response_ ### Anything else? _No response_...

[Feature][connector-tidbcdc] Support synchronizing multiple tables

1

### Search before asking - [X] I had searched in the [feature](https://github.com/apache/seatunnel/issues?q=is%3Aissue+label%3A%22Feature%22) and found no similar feature requirement. ### Description Support synchronizing multiple tables ### Usage Scenario _No response_ ###...

[#6563] improvement(core) Optimize the configuration iterator in FileSystem provider

3

### What changes were proposed in this pull request? (Please outline the changes and how this PR fixes the issue.) ### Why are the changes needed? Fix: #6563 ### Does...

[ #9047] feat(iceberg):Support submit table scan plan

2

### What changes were proposed in this pull request? Support submit table scan plan. ### Why are the changes needed? Fix: #([9047](https://github.com/apache/gravitino/issues/9047)) ### Does this PR introduce _any_ user-facing change?...

[#8311] feat(iceberg-rest-catalog):Support scan planning endpoint for Iceberg REST server

5

### What changes were proposed in this pull request? Support scan planning endpoint for Iceberg REST server ### Why are the changes needed? Fix: #([8311](https://github.com/apache/gravitino/issues/8311)) ### Does this PR introduce...

### Describe the subtask Add cache for scan planning. ### Parent issue https://github.com/apache/gravitino/issues/8311

### Describe the subtask Support submit table scan plan `/v1/{prefix}/tables/{table}/plan` ### Parent issue https://github.com/apache/gravitino/issues/8311