sd4324530 opened a new pull request, #4578:
URL: https://github.com/apache/flink-cdc/pull/4578
## What is the purpose of this pull request?
Upgrades the `com.starrocks:flink-connector-starrocks` dependency from
`1.2.14_flink-1.20` to `1.2.16_flink-1.20` in the StarRocks pipeline
connector.
The upstream 1.2.15/1.2.16 releases bring in several stability fixes and
improvements, notably:
- Transaction stream load: recover from lost commit responses instead of
hanging or failing (#501)
- Fix shared-state race in the query plan visitor (#499)
- Skip host probing when only a single load URL is configured (#502)
- Auto-derive JSON columns header from Flink schema (#510)
- Multi-table transaction stream load support (#487, introduced in 1.2.15
and hardened by #500/#506/#512 in 1.2.16) — groundwork only, not enabled
in this PR; In the future, we can consider supporting the ability to
perform multi-table transactions
Related JIRA:
[FLINK-41006](https://issues.apache.org/jira/browse/FLINK-41006)
## Brief change log
-
`flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/pom.xml`:
bump `starrocks.connector.version` from `1.2.14_flink-1.20` to
`1.2.16_flink-1.20`
- `flink-cdc-e2e-tests/flink-cdc-pipeline-e2e-tests/pom.xml`: keep the e2e
module's `starrocks.connector.version` property in sync
No code changes are required. An API diff between the 1.2.14 and 1.2.16
sources confirmed that all APIs used by this repository are source/binary
compatible: `SinkFunctionFactory.createSink(...)`,
`RecordSerializationSchema`,
`StarRocksRowData`/`DefaultStarRocksRowData`, `StarRocksCatalog`, and the
`StarRocksSinkOptions` constructor and consumed constants. The new
`StarRocksRowData#isTransactionEnd()`/`#getSourcePartition()` methods are
default methods.
## Verifying this change
This change is a trivial rework / code cleanup without any test coverage.
## Documentation
- Does this pull request introduce a new feature? (yes / no): **no**
- If yes, how is the feature documented? (not applicable / docs / JavaDocs /
not documented): not applicable
---
##### Was generative AI tooling used to co-author this PR?
- [X] Yes (please specify the tool below)
Generated-by: CodeBuddy (GLM-5.3)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
