Skip to content

Commit e8d2d52

Browse files
andygroveclaude
andauthored
fix: remove spurious .flatten call that garbled SortMergeJoin fallback messages (#3968)
Fixes #3967. `flatMap` already returns a `Seq[String]`, so calling `.flatten` on it triggered Scala's implicit String→Iterable[Char] conversion, turning each message into individual characters. Co-authored-by: Claude Sonnet 4.6 <noreply@anthropic.com>
1 parent d9e8ff0 commit e8d2d52

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

spark/src/main/scala/org/apache/spark/sql/comet/operators.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2043,7 +2043,7 @@ object CometSortMergeJoinExec extends CometOperatorSerde[SortMergeJoinExec] {
20432043
}
20442044

20452045
if (errorMsgs.nonEmpty) {
2046-
withInfo(join, errorMsgs.flatten.mkString("\n"))
2046+
withInfo(join, errorMsgs.mkString("\n"))
20472047
return None
20482048
}
20492049

0 commit comments

Comments
 (0)