Re: [PR] [Feature-2932][Pipeline] Flink CDC pipeline supports transform [flink-cdc]

leonardBang commented on code in PR #2937: URL: https://github.com/apache/flink-cdc/pull/2937#discussion_r1514480625 ## flink-cdc-common/src/main/java/com/ververica/cdc/common/utils/ThreadLocalCache.java: ## @@ -0,0 +1,86 @@ +/* + * Copyright 2023 Ververica Inc. + * + * Licensed

Re: [PR] [Feature-2932][Pipeline] Flink CDC pipeline supports transform [flink-cdc]

leonardBang commented on code in PR #2937: URL: https://github.com/apache/flink-cdc/pull/2937#discussion_r1512676160 ## flink-cdc-runtime/src/main/java/com/ververica/cdc/runtime/operators/transform/TransformFilterProcessor.java: ## @@ -0,0 +1,127 @@ +/* + * Copyright 2023 Verver