From a6ecf8f532a8ce71a01cdfb0d12d6192d84fbdc2 Mon Sep 17 00:00:00 2001 From: "Robert (Bobby) Evans" Date: Wed, 17 Jun 2020 16:32:56 -0500 Subject: [PATCH] Fix name of scan (#201) --- .../org/apache/spark/sql/rapids/GpuFileSourceScanExec.scala | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/sql-plugin/src/main/scala/org/apache/spark/sql/rapids/GpuFileSourceScanExec.scala b/sql-plugin/src/main/scala/org/apache/spark/sql/rapids/GpuFileSourceScanExec.scala index f84364ac7f5..e2c8c976851 100644 --- a/sql-plugin/src/main/scala/org/apache/spark/sql/rapids/GpuFileSourceScanExec.scala +++ b/sql-plugin/src/main/scala/org/apache/spark/sql/rapids/GpuFileSourceScanExec.scala @@ -44,6 +44,10 @@ case class GpuFileSourceScanExec( override val tableIdentifier: Option[TableIdentifier]) extends DataSourceScanExec with GpuExec { + override val nodeName: String = { + s"GpuScan $relation ${tableIdentifier.map(_.unquotedString).getOrElse("")}" + } + private[this] val wrapped: FileSourceScanExec = { val tclass = classOf[org.apache.spark.sql.execution.FileSourceScanExec] val constructors = tclass.getConstructors()