diff --git a/flink-scala/src/main/scala/org/apache/flink/api/scala/codegen/TypeAnalyzer.scala b/flink-scala/src/main/scala/org/apache/flink/api/scala/codegen/TypeAnalyzer.scala index e025192066df3fb07a991bc2e710e1415fbcdcbb..31218154d38c9995603154bc2c2fd154c912b9ec 100644 --- a/flink-scala/src/main/scala/org/apache/flink/api/scala/codegen/TypeAnalyzer.scala +++ b/flink-scala/src/main/scala/org/apache/flink/api/scala/codegen/TypeAnalyzer.scala @@ -65,8 +65,6 @@ private[flink] trait TypeAnalyzer[C <: Context] { this: MacroContextHolder[C] case NothingType() => NothingDesciptor(id, tpe) - case TraversableType(elemTpe) => analyzeTraversable(id, tpe, elemTpe) - case EitherType(leftTpe, rightTpe) => analyzeEither(id, tpe, leftTpe, rightTpe) case TryType(elemTpe) => analyzeTry(id, tpe, elemTpe) @@ -75,6 +73,8 @@ private[flink] trait TypeAnalyzer[C <: Context] { this: MacroContextHolder[C] case CaseClassType() => analyzeCaseClass(id, tpe) + case TraversableType(elemTpe) => analyzeTraversable(id, tpe, elemTpe) + case ValueType() => ValueDescriptor(id, tpe) case WritableType() => WritableDescriptor(id, tpe)