@Override
  public State waitUntilFinish() {
    return State.DONE;
  }
@Test
  public void testWaitUntilFinishReturnsDone() {
    FlinkRunnerResult result = new FlinkRunnerResult(Collections.emptyMap(), 100);
    assertThat(result.waitUntilFinish(), is(PipelineResult.State.DONE));
    assertThat(result.waitUntilFinish(Duration.millis(100)), is(PipelineResult.State.DONE));
  }