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