flink-cdc icon indicating copy to clipboard operation
flink-cdc copied to clipboard
verified publisher icon apache

[BP-3.1][FLINK-35323][runtime] Fix transform failure when one rule matches multiple schemas

Open yuxiqian opened this issue 1 year ago • 2 comments

This closes FLINK-35323.

Currently, Transform module doesn’t support handling multiple tables with different schema within one projection / filtering rule. This is not intended and turns out to be related to incorrectly handled processor caching strategy. Fixing the cache key should resolve this problem.

yuxiqian avatar May 10 '24 12:05 yuxiqian

cc @aiwenmo

yuxiqian avatar May 10 '24 12:05 yuxiqian

Could @PatrickRen help take a look? Thanks!

yuxiqian avatar May 20 '24 02:05 yuxiqian