[FLINK-6416] Potential divide by zero issue in InputGateMetrics#refreshAndGetAvg()

• Type: Bug
• Status: Closed
• Priority: Minor
• Resolution: Fixed
• Affects Version/s: 1.3.0, 1.4.0
• Fix Version/s: 1.3.0, 1.4.0
• Component/s: Runtime / Metrics, Runtime / Network
• Assignee: Chesnay Schepler
• Reporter: Ted Yu
• Created: 28/Apr/17 15:45
• Updated: 18/May/17 19:06
• Resolved: 18/May/17 19:06

Description

    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;

If count is zero at the end of the loop, the division would produce exception.

Issue Links

• links to: GitHub Pull Request #3906