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`.
---