Thu Dec 1 19:36:07 PST 2016

ericl · ericl · commit a9f9710b7e06 · 2016-12-01T19:36:07.000-08:00
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/DataSourceStrategy.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/DataSourceStrategy.scala
@@ -217,7 +217,7 @@ case class DataSourceAnalysis(conf: CatalystConf) extends Rule[LogicalPlan] {
             if (deletedPartitions.nonEmpty) {
               AlterTableDropPartitionCommand(
                 l.catalogTable.get.identifier, deletedPartitions.toSeq,
-                ifExists = true, purge = true,
+                ifExists = true, purge = false,
                 retainData = true /* already deleted */).run(t.sparkSession)
             }
           }

Original file line number	Diff line number	Diff line change
`@@ -217,7 +217,7 @@ case class DataSourceAnalysis(conf: CatalystConf) extends Rule[LogicalPlan] {`
`217`	`217`	`if (deletedPartitions.nonEmpty) {`
`218`	`218`	`AlterTableDropPartitionCommand(`
`219`	`219`	`l.catalogTable.get.identifier, deletedPartitions.toSeq,`
`220`		`- ifExists = true, purge = true,`
	`220`	`+ ifExists = true, purge = false,`
`221`	`221`	`retainData = true /* already deleted */).run(t.sparkSession)`
`222`	`222`	`}`
`223`	`223`	`}`