why LocalProducerSink.output(SyncData data) need put same data to hold queue and toFilter queue?

Open hy0619 opened this issue 9 months ago • 1 comments

why are LocalProducerSink#output(SyncData data) need put data to hold queue ,also put the same data to toFilter queue(in LocalConsumerSource.class) ? when coldstart finnish , the data in hold queue is always handle to toFilter queue ,So isn't this data being processed repeatedly?

Mar 05 '25 05:03 hy0619

Sorry, but it's a long time and I don't remember well. As I can see now, It seems no need to put into consumerSource if it hold for coldStart. seems like a bug.

Mar 12 '25 03:03 zzt93