Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

[FLINK-35774][cdc-runtime] Fix the cache of transform is not updated after process schema change event #3455

Open
wants to merge 1 commit into
base: master
Choose a base branch
from
Open

[FLINK-35774][cdc-runtime] Fix the cache of transform is not updated after process schema change event #3455

wants to merge 1 commit into from

Conversation

aiwenmo
Copy link
Contributor

@aiwenmo aiwenmo commented Jul 6, 2024

This closes FLINK-35774.
@aiwenmo
[FLINK-35774][cdc-runtime] Fix the cache of transform is not updated …
886a8c6 
…after process schema change event when merging with route
@aiwenmo
Copy link
Contributor Author

aiwenmo commented Jul 6, 2024

@yuxiqian @lvyanquan PTAL
yuxiqian
yuxiqian reviewed Jul 8, 2024
View reviewed changes
...me/src/main/java/org/apache/flink/cdc/runtime/operators/transform/TransformDataOperator.java
Copy link
Contributor

@yuxiqian yuxiqian Jul 8, 2024 •
edited
Loading

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

I'm a bit unsure if transformProjectionProcessorMap and transformFilterProcessorMap will be flushed when upstream schema change event arrives at TransformDataOperator?

Got it, it will be refreshed by updating tableInfo.
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
composer runtime
2 participants
@aiwenmo @yuxiqian