[
https://issues.apache.org/jira/browse/SPARK-19131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dongjoon Hyun closed SPARK-19131.
---------------------------------
Resolution: Invalid
Hi, [~licl].
I'm closing this issue because it's already supported feature. Please try the
following.
{code}
scala> spark.version
res0: String = 2.1.0
scala> sql("create table t(a int) partitioned by (p int)")
res1: org.apache.spark.sql.DataFrame = []
scala> sql("alter table t drop if exists partition (p=1)")
res2: org.apache.spark.sql.DataFrame = []
{code}
> Support "alter table drop partition [if exists]"
> ------------------------------------------------
>
> Key: SPARK-19131
> URL: https://issues.apache.org/jira/browse/SPARK-19131
> Project: Spark
> Issue Type: New Feature
> Affects Versions: 2.1.0
> Reporter: lichenglin
>
> {code}
> val parts = client.getPartitions(hiveTable, s.asJava).asScala
> if (parts.isEmpty && !ignoreIfNotExists) {
> throw new AnalysisException(
> s"No partition is dropped. One partition spec '$s' does not exist
> in table '$table' " +
> s"database '$db'")
> }
> parts.map(_.getValues)
> {code}
> Until 2.1.0,drop partition will throw a exception when no partition to drop.
> I notice there is a param named ignoreIfNotExists.
> But I don't know how to set it.
> May be we can implement "alter table drop partition [if exists] "
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
