You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "yux (Jira)" <ji...@apache.org> on 2024/10/12 03:26:00 UTC
[jira] [Created] (FLINK-36514) Unable to override include/exclude schema types in lenient mode
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)