Rewrite in Scala

flink-extended · Jun 30, 2024 · 17a5d6d · 17a5d6d
1 parent 40fa161
commit 17a5d6d
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/...a/org/apache/flink/streaming/util/typeutils/DefaultScalaProductFieldAccessorFactory.scala b/...a/org/apache/flink/streaming/util/typeutils/DefaultScalaProductFieldAccessorFactory.scala
@@ -35,7 +35,11 @@ class DefaultScalaProductFieldAccessorFactory extends ScalaProductFieldAccessorF
 
     if (pos < 0 || pos >= arity)
       throw new CompositeType.InvalidFieldReferenceException(
+<<<<<<< HEAD
         s"Tried to select $pos. field on \"$typeInfo\", which is an invalid index."
+=======
+        s"""Tried to select $pos. field on "$typeInfo", which is an invalid index."""
+>>>>>>> d5aec93 (Rewrite in Scala)
       )
 
     fieldType = typeInfo.asInstanceOf[TupleTypeInfoBase[T]].getTypeAt(pos)
@@ -71,7 +75,7 @@ class DefaultScalaProductFieldAccessorFactory extends ScalaProductFieldAccessorF
 
     if (pos < 0 || pos >= arity)
       throw new CompositeType.InvalidFieldReferenceException(
-        s"Tried to select ${pos.asInstanceOf[Integer]}. field on \"$typeInfo\", which is an invalid index."
+        s"""Tried to select ${pos.asInstanceOf[Integer]}. field on "$typeInfo", which is an invalid index."""
       )
     checkNotNull(innerAccessor, "innerAccessor must not be null.")