[FLINK-4631] Prevent NPE in TwoInputStreamTask

Check that the input processor has been created before cleaning it up.
fullcontact · Dec 7, 2016 · 13150a4 · 13150a4
1 parent 4410c04
commit 13150a4
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/...aming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/TwoInputStreamTask.java b/...aming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/TwoInputStreamTask.java
@@ -91,7 +91,9 @@ protected void run() throws Exception {
 
  @Override
  protected void cleanup() throws Exception {
- inputProcessor.cleanup();
+ if (inputProcessor != null) {
+ inputProcessor.cleanup();
+ }
  }
 
  @Override