I found the problem and, of course, it was between my desk and my chair.
For side outputs Flink UI correctly reports (S+N) * Slots. Since the
CoProcessFunction late-join was hashed that factored to S+N. Thanks for the
help!
On Tue, Jul 3, 2018 at 3:51 AM, Chesnay Schepler wrote:
> Let's see if i
Let's see if i understood everything correctly:
1)
Let's say that metadata contains N records.
The UI output metrics indicate that /metadata /sends N records.
The UI input metrics for /join /and /late-join/ do each include N
records (i.e N + whatever other data they receive).
You expected tha
