FlinkCheckpointDuration implements FlinkHeuristic { @Override public void exportHeuristicsResults() { countersByAppId.keySet().forEach(this::doExportHeuristicsResults); } FlinkCheckpointDuration(HeuristicsResultDB heuristicsResultDB); @Override void onAppCompleted(String applicationId, String attemptId); @Override String getHelp(); @Override void process(Long timestamp, String applicationId, FlinkEventProtos.JobManagerEvent event); @Override void process(Long timestamp, String applicationId, FlinkEventProtos.JobEvent event); @Override void exportHeuristicsResults();  }
@Test public void exportHeuristicsResults_do_nothing_when_no_events_received() { heuristic.exportHeuristicsResults(); verify(db, never()).createHeuristicResult(any()); }