yux created FLINK-36514:
---------------------------
Summary: Unable to override include/exclude schema types in
lenient mode
Key: FLINK-36514
URL: https://issues.apache.org/jira/browse/FLINK-36514
Project: Flink
Issue Type: Bug
Components: Flink CDC
Reporter: yux
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.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
