Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/5447
---
Github user zhangminglei commented on a diff in the pull request:
https://github.com/apache/flink/pull/5447#discussion_r167746607
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/OperatorChain.java
---
@@ -591,16 +591,28 @@ public void
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5447#discussion_r167633643
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/OperatorChain.java
---
@@ -591,16 +591,28 @@ public void
Github user zhangminglei commented on a diff in the pull request:
https://github.com/apache/flink/pull/5447#discussion_r167395827
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/OperatorChain.java
---
@@ -591,16 +591,18 @@ public void
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5447#discussion_r167395295
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/OperatorChain.java
---
@@ -591,16 +591,18 @@ public void
Github user zhangminglei commented on a diff in the pull request:
https://github.com/apache/flink/pull/5447#discussion_r167393568
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/OperatorChain.java
---
@@ -591,16 +591,18 @@ public void
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/5447#discussion_r167392891
--- Diff:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/OperatorChain.java
---
@@ -591,16 +591,18 @@ public void
GitHub user zhangminglei opened a pull request:
https://github.com/apache/flink/pull/5447
[FLINK-8423] OperatorChain#pushToOperator catch block may fail with NPE
## What is the purpose of the change
Fix the NPE when outputTag is null.
## Brief change log
Add
