Beam: NPE after execution has finished
@@ -495,7 +495,7 @@ public abstract class BeamPipelineEngine extends Variables implements IPipelineE
// This seems to be the most reliable way of checking the state...
//
PipelineResult.State pipelineState = beamPipelineResults.waitUntilFinish( Duration.millis( 1 ) );
-
+ if (pipelineState != null) {
boolean cancelPipeline = false;
switch (pipelineState) {
case DONE:
@@ -549,6 +549,7 @@ public abstract class BeamPipelineEngine extends Variables implements IPipelineE
}
}
}
+ }
@Override public String getStatusDescription() {
return statusDescription;
