From ae48527bcd55e243d92332449a8bc39ab0bcc0be Mon Sep 17 00:00:00 2001 From: Alexey Novakov Date: Sun, 30 Jun 2024 10:34:50 +0200 Subject: [PATCH] Rewrite in Scala --- .../typeutils/DefaultScalaProductFieldAccessorFactory.scala | 4 ---- 1 file changed, 4 deletions(-) diff --git a/src/main/scala/org/apache/flink/streaming/util/typeutils/DefaultScalaProductFieldAccessorFactory.scala b/src/main/scala/org/apache/flink/streaming/util/typeutils/DefaultScalaProductFieldAccessorFactory.scala index 994a494..75169cf 100644 --- a/src/main/scala/org/apache/flink/streaming/util/typeutils/DefaultScalaProductFieldAccessorFactory.scala +++ b/src/main/scala/org/apache/flink/streaming/util/typeutils/DefaultScalaProductFieldAccessorFactory.scala @@ -35,11 +35,7 @@ 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)