Flink CDC这个语句为什么使用不等于会报错？not in也一样，怎么改？使用＝是正确的。

Flink CDC 在使用不等于（<>）或者NOT IN操作符时报错的原因可能是因为 Flink CDC 目前的版本（包括 Flink 1.17）在某些情况下对这些操作符的支持有限。

Flink CDC 的查询过程中会将 SQL 解析成底层的数据源查询，然后使用相应的连接器获取变化数据。由于不等于和 NOT IN 操作符的实现比较复杂，并且需要进行全量扫描或者大规模数据匹配，这些操作符可能无法直接转换为底层连接器所支持的查询。

如果你想使用不等于或 NOT IN 操作符进行数据过滤，可以尝试以下替代方案：

1. 使用等于（=）操作符和取反：将不等于或 NOT IN 的条件改写成等于和取反的形式。例如，将 column_name <> value 改为 column_name = value，然后在 Flink SQL 查询中使用 WHERE NOT(column_name = value) 来实现不等于的功能。

2. 使用其他过滤条件：根据具体的需求，考虑使用其他逻辑运算符（如 >、<、BETWEEN 等）或使用子查询来实现相似的过滤效果。

3. 应用自定义函数：如果需要更复杂的过滤操作，可以通过自定义函数（UDF）来实现。编写一个自定义函数，将其应用于 Flink CDC 查询中的过滤条件，以达到所需的结果。

请注意，在使用替代方案之前，确保你理解不等于或 NOT IN 操作符可能存在的性能和语义差异，并根据实际情况进行评估。

link CDC 中使用 not in 或者 != 语句在某些情况下可能会导致错误，原因是 Flink CDC 会将这些语句转换为等价的语句，但是在某些情况下转换可能不正确，导致执行错误。
例如，在使用 CDC 的 MySQL Source 时，如果在 CDC 配置中指定了 debezium.mysql.column.blacklist 参数来排除某些列，那么在使用 != 或者 not in 语句时可能会出现错误，因为 Flink CDC 会将其转换为 is not null 或者 not(col1 in (val1, val2, ...)) 等语句，但是这些转换可能会与 debezium.mysql.column.blacklist 参数的配置冲突，导致无法正确执行。
为了解决这个问题，可以尝试使用其他等价的语句来代替 not in 或者 !=。例如，可以使用 not(col1 = val1 or col1 = val2 or ...) 来代替 not in，使用 is null 或者 col1 <> val 来代替 !=。
另外，需要注意的是，使用 not in 或者 != 语句时需要考虑到性能问题，因为这些语句可能会导致全表扫描。如果条件允许，尽量使用 in 或者 = 语句来代替 not in 或者 !=，以提高查询性能。
Share
Like

问题出在那个不等于。此回答整理至钉群“Flink CDC 社区”。