hk__lrzy created FLINK-35436: -------------------------------- Summary: Job can't launch when setting the option schema.change.behavior to IGNORE Key: FLINK-35436 URL: https://issues.apache.org/jira/browse/FLINK-35436 Project: Flink Issue Type: Improvement Components: Flink CDC Reporter: hk__lrzy
Now in the 3.0 pipeline, *SchemaOperator* already was necessary operator in the Flink DAG, both *PrePartitionOperator* and *DataSinkWriterOperator* have connection with the *SchemaRegister* according the *schemaEvolutionClient,* but when we set the option schema.change.behavior to ignore or exception, the pipeline will add a filter operator instead of the *Schema Operator,* final cause the job fail. I think we still need keep the option for the schema.change.behavior to meet the difference cases, so i advice to move schema.change.behavior to the *SchemaRegister* to let *SchemaOperator* will be always in the DAG, and let to *SchemaRegister* decided to apply the schema change or not.{*}{*} -- This message was sent by Atlassian Jira (v8.20.10#820010)