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