diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/encoders/ExpressionEncoder.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/encoders/ExpressionEncoder.scala index 3757eccfa2dd81d03f05f273e2955413aeab5bb1..0782143d465b3dbefad1636301ae4fc48d2564c3 100644 --- a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/encoders/ExpressionEncoder.scala +++ b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/encoders/ExpressionEncoder.scala @@ -288,7 +288,7 @@ case class ExpressionEncoder[T]( } catch { case e: Exception => throw new RuntimeException( - s"Error while encoding: $e\n${serializer.map(_.treeString).mkString("\n")}", e) + s"Error while encoding: $e\n${serializer.map(_.simpleString).mkString("\n")}", e) } /** @@ -300,7 +300,7 @@ case class ExpressionEncoder[T]( constructProjection(row).get(0, ObjectType(clsTag.runtimeClass)).asInstanceOf[T] } catch { case e: Exception => - throw new RuntimeException(s"Error while decoding: $e\n${deserializer.treeString}", e) + throw new RuntimeException(s"Error while decoding: $e\n${deserializer.simpleString}", e) } /**