Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/4851#discussion_r146551851
--- Diff:
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskTestHarness.java
---
@@ -370,6 +371,10 @@ public void endInput() {
}
}
+ public StreamConfigChainer setupOpertorChain(OperatorID headOperatorId,
OneInputStreamOperator<?, ?> headOperator) {
--- End diff --
nit: typo, but I'll fix while merging---
