Skip to content

Better use of RowTypeInfo

Use the corresponding RowTypeInfo of the Row object being manipulated to ensure some type validation during flink serialization between operators.

Errors are routed to a side output.

Made some dependency cleanups.

@dcausse I accidentally merged !13 (merged) into main, whereas the destination should have been T311084-consume-page-change-stream. I reverted !13 (merged) because it brought in the whole T311084-consume-page-change-stream (it branched off it).

Edited by Gmodena

Merge request reports