starrocks-connector-for-apache-flink
starrocks-connector-for-apache-flink copied to clipboard
[BugFix]Fixed an issue where[BugFix]Fixed an issue where table names were printed incorrectly after creating a table in StarRocksCatalog. table names were printed incorrectly aft…
[BugFix]Fixed an issue where table names were printed incorrectly after creating a table in StarRocksCatalog.
What type of PR is this:
- [x] BugFix
- [ ] Feature
- [ ] Enhancement
- [ ] Refactor
- [ ] UT
- [ ] Doc
- [ ] Tool
Which issues of this PR fixes :
Fixes #
Problem Summary(Required) :
Caused by: org.apache.flink.cdc.common.exceptions.SchemaEvolveException: com.starrocks.connector.flink.catalog.StarRocksCatalogException: Failed to create table origin_ennovation_ods_wzd_laiu8_sr.origin_ennovation_ods_wzd_laiu8_sr at org.apache.flink.cdc.connectors.starrocks.sink.StarRocksMetadataApplier.applyCreateTable(StarRocksMetadataApplier.java:130) ~[?:?] at org.apache.flink.cdc.connectors.starrocks.sink.StarRocksMetadataApplier.applySchemaChange(StarRocksMetadataApplier.java:101) ~[?:?] at org.apache.flink.cdc.runtime.operators.schema.coordinator.SchemaRegistryRequestHandler.applySchemaChange(SchemaRegistryRequestHandler.java:238) ~[?:?] at org.apache.flink.cdc.runtime.operators.schema.coordinator.SchemaRegistryRequestHandler.lambda$flushSuccess$0(SchemaRegistryRequestHandler.java:306) ~[?:?] at java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source) ~[?:?] at java.util.concurrent.FutureTask.run(Unknown Source) ~[?:?] at java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) ~[?:?] at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) ~[?:?] at java.lang.Thread.run(Unknown Source) ~[?:?]
Failed to create table origin_ennovation_ods_wzd_laiu8_sr. origin_ennovation_ods_wzd_laiu8_sr, as seen in this passage, the library name and table name are the same when printed.
Checklist:
- [ ] I have added test cases for my bug fix or my new feature
- [ ] This pr will affect users' behaviors
- [ ] This pr needs user documentation (for new or modified features or behaviors)
- [ ] I have added documentation for my new feature or new function
Thank you for your submission! We really appreciate it. Like many open source projects, we ask that you sign our Contributor License Agreement before we can accept your contribution.
You have signed the CLA already but the status is still pending? Let us recheck it.