icelake-io/icelake

discussion: let Table can be clone

ZENOTME opened this issue · 2 comments

ZENOTME commented

In risingwave sink, the sink own the table. We create writer or coordinator using table in sink. We need commit in writer or coordinator which means that we also need own table in writer and coordinator.

image

cc @liurenjie1024 @Xuanwo

Xuanwo commented

Perhaps the sink could store all configuration needed to create a new table, instead of relying on the current state of the Table.

  • 👍1
liurenjie1024 commented

Perhaps the sink could store all configuration needed to create a new table, instead of relying on the current state of the Table.

+1, Clone table doesn't work here since sink, writer, committer may exists in different nodes.

  • 👍1