Github user fhueske commented on a diff in the pull request:

    https://github.com/apache/flink/pull/5961#discussion_r186527277
  
    --- Diff: 
flink-streaming-java/src/main/java/org/apache/flink/streaming/util/typeutils/FieldAccessor.java
 ---
    @@ -197,7 +196,7 @@ public T set(T record, F fieldValue) {
                        checkNotNull(typeInfo, "typeInfo must not be null.");
                        checkNotNull(innerAccessor, "innerAccessor must not be 
null.");
     
    -                   int arity = ((TupleTypeInfo) typeInfo).getArity();
    +                   int arity = typeInfo.getArity();
    --- End diff --
    
    Same as for `SimpleTupleFieldAccessor`.


---

Reply via email to