[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… #414
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
[BugFix]Fixed an issue where table names were printed incorrectly after creating a table in StarRocksCatalog.
What type of PR is this:
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: