yux created FLINK-36183:
---------------------------
Summary: Lenient mode doesn't work with route blocks
Key: FLINK-36183
URL: https://issues.apache.org/jira/browse/FLINK-36183
Project: Flink
Issue Type: Bug
Components: Flink CDC
Affects Versions: cdc-3.2.0, cdc-3.3.0
Reporter: yux
We should applySchemaChange (where the route rule works) first and lenientize
its result then, or we may not be able to get evolved schema since tableId
isn't routed:
Caused by: java.lang.IllegalStateException: Evolved schema does not exist, not
ready for schema change event AddColumnEvent{tableId=kunni_test.customers,
addedColumns=[ColumnWithPosition{column=`newCol2` VARCHAR(100), position=AFTER,
existedColumnName=newCol}]}
at
org.apache.flink.cdc.runtime.operators.schema.coordinator.SchemaRegistryRequestHandler.lambda$lenientizeSchemaChangeEvent$3(SchemaRegistryRequestHandler.java:378)
at java.util.Optional.orElseThrow(Optional.java:290)
at
org.apache.flink.cdc.runtime.operators.schema.coordinator.SchemaRegistryRequestHandler.lenientizeSchemaChangeEvent(SchemaRegistryRequestHandler.java:376)
at
org.apache.flink.cdc.runtime.operators.schema.coordinator.SchemaRegistryRequestHandler.calculateDerivedSchemaChangeEvents(SchemaRegistryRequestHandler.java:360)
at
org.apache.flink.cdc.runtime.operators.schema.coordinator.SchemaRegistryRequestHandler.handleSchemaChangeRequest(SchemaRegistryRequestHandler.java:184)
at
org.apache.flink.cdc.runtime.operators.schema.coordinator.SchemaRegistry.lambda$handleCoordinationRequest$3(SchemaRegistry.java:273)
... 4 more
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
