Thanks for the tip!
May be call env.disableOperatorChaining() can show the received on the
dashborad
Chesnay Schepler 于2020年3月25日周三 下午5:56写道：
> This is a known limitation, see
> https://issues.apache.org/jira/browse/FLINK-7286 .
>
> As a crude workaround you may either break the chain after
This is a known limitation, see
https://issues.apache.org/jira/browse/FLINK-7286 .
As a crude workaround you may either break the chain after the source /
before the sink, or query the numRecordsOut metric for the source /
numRecordsIn metric for the sink via the WebUI metrics tab or REST
