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 the
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 API.
Hi, all
When I use flink-connector-kafka-0.11 consume Kafka0.11, the Cluster
web's Received Record is always 0. However, the log is not empty. Any one
can help me?
[image: image.png]
