[jira] [Resolved] (FLINK-36183) Lenient mode doesn't work with route blocks

["Ruan Hang (Jira)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/FLINK-36183?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Ruan Hang resolved FLINK-36183.
-------------------------------
    Fix Version/s: cdc-3.2.0
       Resolution: Fixed

fix via master(3.3-SNAPSHOT): 73977c127b867a6412d176dd21323d7845a0b6fe

release-3.2: 316ea9c6ab411e2d806f1e8e1146920f38f99cfe

> 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
>            Assignee: yux
>            Priority: Blocker
>              Labels: pull-request-available
>             Fix For: cdc-3.2.0
>
>
> 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)