andystenhe

[BugFix] Resolve Delete Semantics Data Loss in Flink SQL for StarRocks 3.1

1

In the 3.1 storage-computation separated version, using the INSERT INTO statement in Flink SQL will lose data with Delete semantics. ## What type of PR is this： - [v] BugFix...

I am using the upsert Kafka connector to read Kafka messages and then write them to the primary key table in StarRocks, but I noticed that the data with row...

[Bug]Error while trying to split key and value in configuration

3

## What changes were proposed in this pull request Issue Number: close #4199 ## Brief change log fix Flink config.yaml Parsing Error​ ## Verifying this change This change is already...

### Search before asking - [x] I had searched in the [issues](https://github.com/apache/streampark/issues?q=is%3Aissue+label%3A%22bug%22) and found no similar issues. ### Java Version 11 ### Scala Version 2.12.x ### StreamPark Version 2.1.5 ###...