Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4612#discussion_r139149693
--- Diff:
flink-examples/flink-examples-batch/src/main/scala/org/apache/flink/examples/scala/wordcount/WordCount.scala
---
@@ -49,6 +51,8 @@ object WordCount {
val params: ParameterTool = ParameterTool.fromArgs(args)
+ val t = Types.of[Either[String, Nothing]]
--- End diff --
What's the purpose of this change?---
