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?


---

Reply via email to