We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 96424a7 commit a51bc8bCopy full SHA for a51bc8b
1 file changed
common/src/main/scala/org/apache/spark/sql/comet/util/Utils.scala
@@ -279,7 +279,7 @@ object Utils extends CometTypeShim with Logging {
279
// since merging dictionaries across batches is not supported.
280
if (hasDictionary) {
281
logInfo(
282
- s"Broadcast coalesce falling back to per-batch serialization due to " +
+ "Broadcast coalesce falling back to per-batch serialization due to " +
283
s"dictionary-encoded vectors (${decoded.length} batches)")
284
return decoded.flatMap { batch =>
285
serializeBatches(Iterator(batch)).map(_._2)
0 commit comments