[FLINK-36514] Unable to override include/exclude schema types in lenient mode

• Type: Bug
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Affects Version/s: cdc-3.2.0
• Fix Version/s: cdc-3.3.0
• Component/s: Flink CDC
• Labels: pull-request-available
• Assignee: yux
• Reporter: yux
• Created: 12/Oct/24 03:25
• Updated: 20/Nov/24 02:28

Description

If schema evolution behavior is set to LENIENT, Truncate / Drop table events will be ignored by default. However, there's currently no way for users to override this behavior due to the following code:

```java
if (excludedSETypes.isEmpty()
&& SchemaChangeBehavior.LENIENT.equals(schemaChangeBehavior))

{ // In lenient mode, we exclude DROP_TABLE and TRUNCATE_TABLE by default. This could be // overridden by manually specifying excluded types. Stream.of(SchemaChangeEventType.DROP_TABLE, SchemaChangeEventType.TRUNCATE_TABLE) .map(SchemaChangeEventType::getTag) .forEach(excludedSETypes::add); }

```
 
If one wants to exclude no types, it's actually not possible since passing `[]` is equivalent to passing nothing, and `DROP` and `TRUNCATE` events will still be ignored.

Issue Links

• links to: GitHub Pull Request #3637