YuriS
New Contributor III

Trigger interval is set to 1 minute; maxOffsetsPerTrigger is set to 20k. That's all.

And once again when i am comparing either offsets (from the StreamingQueryListener events) or actual data in target table (batch_id is in target table, so it is very easy the check what was actually processed) with numInputRows it is x3 times for particular streams:

YuriS_0-1770974536294.png