[ https://issues.apache.org/jira/browse/FLINK-6416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15989121#comment-15989121 ]
Greg Hogan commented on FLINK-6416: ----------------------------------- Wouldn't this produce {{NaN}}? > Potential divide by zero issue in InputGateMetrics#refreshAndGetAvg() > --------------------------------------------------------------------- > > Key: FLINK-6416 > URL: https://issues.apache.org/jira/browse/FLINK-6416 > Project: Flink > Issue Type: Bug > Reporter: Ted Yu > Priority: Minor > > {code} > int count = 0; > for (InputChannel channel : inputGate.getInputChannels().values()) { > if (channel instanceof RemoteInputChannel) { > RemoteInputChannel rc = (RemoteInputChannel) channel; > int size = rc.unsynchronizedGetNumberOfQueuedBuffers(); > total += size; > ++count; > } > } > return total / (float) count; > {code} > If count is zero at the end of the loop, the division would produce exception. -- This message was sent by Atlassian JIRA (v6.3.15#6346)