[Bug] flink-cdc-3.0 Unable to apply SchemaChangeEvent for table "xxx" without existing schema #3014
Closed
1 of 2 tasks
Labels
bug
Something isn't working
Search before asking
Flink version
1.18
Flink CDC version
3.0
Database and its version
source: mysql 5.7.40
sink: starrocks 3.2.2
Minimal reproduce step
source:
table: app_db.ord.*
...
some log:
2024-01-19 17:53:14,206 INFO com.ververica.cdc.runtime.operators.schema.coordinator.SchemaRegistryRequestHandler [] - Received schema change event request from table app_db.ttt. Start to buffer requests for others.
...
Caused by: java.util.concurrent.ExecutionException: java.lang.IllegalArgumentException: Unable to apply SchemaChangeEvent for table "app_db.ttt" without existing schema
at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:395) ~[?:?]
at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1999) ~[?:?]
at com.ververica.cdc.runtime.operators.schema.SchemaOperator.sendRequestToCoordinator(SchemaOperator.java:123) ~[?:?]
What did you expect to see?
should not capture table ttt
What did you see instead?
ttt table schema change is send to starrocks
Anything else?
No response
Are you willing to submit a PR?
The text was updated successfully, but these errors were encountered: