Details
-
Sub-task
-
Status: Closed
-
Major
-
Resolution: Fixed
-
None
Description
This is a pre-step of FLINK-16996. We will refactor BaseRow#get/setHeader to get/setRowKind first. And update all the existing code to send "insert/delete/update_before/update_after" messages instead of "+/-" messages. This is possible now since FLINK-16887 is supported.
Attachments
Issue Links
- links to