Hi Daniel,
> The changelog type needs to be
insert-only to invoke the correct streaming planner rules.
I mean that we can read all kind of data from mysql(insert, upsert,
delete) as +I[optype, xxx] in flink (such as +I[insert, 1,
'a'], +I[delete, 2, null]). If downstream only needs +[insert, xx
Unfortunately no, this would not be helpful. The changelog type needs to be
insert-only to invoke the correct streaming planner rules.
On Wed, Aug 21, 2024 at 9:01 PM Hongshun Wang
wrote:
> Hi Daniel，
> >
> > There's no way to convert a different changelog stream to an insertonly
> > stream so
Hi Daniel，
>
> There's no way to convert a different changelog stream to an insertonly
> stream so I'm pushing this upstream to the connector.
I wonder whether you just want the insert type changelog and ignore other
kinds of changelog, or just want to read all kinds of changelog as insert
in fli
