Junbo Wang

[docs][pipeline-connector][paimon] fix example bug for `Paimon 'wareh…

1

fix example bug for `Paimon 'warehouse' path must be set`

Users need console sink to make simple attempts, add documents for console(values) pipeline connector.

[KYUUBI #6265] Resource isolation in Spark Scala mode

5

# :mag: Description ## Issue References 🔗 This pull request fixes #6265 ## Describe Your Solution 🔧 Please include a summary of the change and which issue is fixed. Please...

# :mag: Description ## Issue References 🔗 This pull request fixes #6236 ## Describe Your Solution 🔧 Please include a summary of the change and which issue is fixed. Please...

[FLINK-35373][cdc-connector][paimon] Simplify Flink CDC Paimon Sink web ui

1

fix [#FLINK-35373](https://issues.apache.org/jira/browse/FLINK-35373) And example code. https://github.com/apache/paimon/blob/3b006fe1bb8d70b640f3c4c8033133698a7f668e/paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/sink/cdc/CdcMultiplexRecordChannelComputer.java#L97-L99

[FLINK-35391][cdc-connector][paimon] Bump dependency of Paimon Pipeline connector to 0.8.0

6

fix [FLINK-35391](https://issues.apache.org/jira/browse/FLINK-35391)

Flink cdc ci `compile_and_test` miss pipeline connector paimon. And test ci https://github.com/beryllw/flink-cdc/actions/runs/9183968055

[FLINK-35360] Submit Flink CDC pipeline job yarn Application mode

4

Support yarn application mode submit.

[FLINK-35894][Follow] fix Elasticsearch dependency version

1

Fix elasticsearch dependency version by use `${project.version}`. When executing `mvn versions:set -DnewVersion=xxx`, compilation fails.

[FLINK-36517][cdc-connect][paimon] use filterAndCommit API for Avoid commit the same datafile duplicate

4

https://issues.apache.org/jira/browse/FLINK-35938 problem still persists. `storeMultiCommitter.commit` API may cause the same datafile commit twice when job restart from failure.