Hi,
Flink 1.15 has developed a new feature to support different sink pre- and
post-topologies[1]. New metrics e.g. NumRecordsSend has been developed to
measure records sent to the external system. Metrics like "Bytes Sent" and
"Records Sent" measure records sent to the next task. So, in your cas
Hi Peter,
Have you compared the DAT topologies in 1.15 / 1.14?
I think it's expected that "Records Received", "Bytes Sent" and "Records
Sent" are 0. These metrics trace the internal data exchanges between Flink
tasks. External data changes, i.e., source reading / sink writing data from
/ to exter
