1. On Flink 1.10 when I look at the topology overview, the AsyncFunctions
show non-zero values for Bytes Received; Records Received; Bytes Sent but
Records Sent is always 0... yet the next step in the topology shows approx
the same Bytes Received as the async sent (modulo minor delays) and a
non-zero Records Received. Is the “Records Sent of an AsyncFunction is
always displayed as zero” a bug?

2. Is there an Async Sink? Or do I just rewrite my Sink as an AsyncFunction
followed by a dummy sink? What’s the recommendation if the sink performing
blocking I/O is proven to be the root cause of back pressure?

Thanks in advance for your help
-- 
Sent from my phone

Reply via email to