Skip to content

Commit e241748

Browse files
Undo change in tableName setting. Another PR will be opened as suggested in this PR thread
1 parent cb1e922 commit e241748

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

sql/core/src/main/scala/org/apache/spark/sql/execution/columnar/InMemoryRelation.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -216,8 +216,8 @@ case class CachedRDDBuilder(
216216
private val materializedPartitions = cachedPlan.session.sparkContext.longAccumulator
217217

218218
val cachedName = tableName.map(n => s"In-memory table $n")
219-
.getOrElse(cachedPlan.simpleStringWithNodeId())
220-
219+
.getOrElse(StringUtils.abbreviate(cachedPlan.toString, 1024))
220+
221221
val supportsColumnarInput: Boolean = {
222222
cachedPlan.supportsColumnar &&
223223
serializer.supportsColumnarInput(cachedPlan.output)

0 commit comments

Comments
 (0)