remove commented-out code

sryza · sryza · commit ad8078a69768 · 2025-07-02T13:37:53.000-07:00
diff --git a/sql/pipelines/src/main/scala/org/apache/spark/sql/pipelines/graph/DatasetManager.scala b/sql/pipelines/src/main/scala/org/apache/spark/sql/pipelines/graph/DatasetManager.scala
@@ -181,7 +181,6 @@ object DatasetManager extends Logging {
     val dropTable = (isFullRefresh || !table.isStreamingTable) && existingTableOpt.isDefined
     if (dropTable) {
       catalog.dropTable(identifier)
-//      context.spark.sql(s"DROP TABLE ${table.identifier.quotedString}")
     }
 
     // Alter the table if we need to

Original file line number	Diff line number	Diff line change
`@@ -181,7 +181,6 @@ object DatasetManager extends Logging {`
`181`	`181`	`val dropTable = (isFullRefresh \|\| !table.isStreamingTable) && existingTableOpt.isDefined`
`182`	`182`	`if (dropTable) {`
`183`	`183`	`catalog.dropTable(identifier)`
`184`		`-// context.spark.sql(s"DROP TABLE ${table.identifier.quotedString}")`
`185`	`184`	`}`
`186`	`185`
`187`	`186`	`// Alter the table if we need to`