FlinkRunnerResult implements PipelineResult { @Override public State getState() { return State.DONE; } FlinkRunnerResult(Map<String, Object> accumulators, long runtime); @Override State getState(); @Override String toString(); @Override State cancel(); @Override State waitUntilFinish(); @Override State waitUntilFinish(Duration duration); @Override MetricResults metrics();  }
@Test public void testPipelineResultReturnsDone() { FlinkRunnerResult result = new FlinkRunnerResult(Collections.emptyMap(), 100); assertThat(result.getState(), is(PipelineResult.State.DONE)); }