Update HiveMetastoreCatalog.scala

seayi · seayi · commit a277120b5c67 · 2015-01-11T23:25:35.000+08:00
diff --git a/sql/hive/src/main/scala/org/apache/spark/sql/hive/HiveMetastoreCatalog.scala b/sql/hive/src/main/scala/org/apache/spark/sql/hive/HiveMetastoreCatalog.scala
@@ -428,11 +428,11 @@ private[hive] case class MetastoreRelation
     }
   )
   override def sameResult(plan: LogicalPlan): Boolean = {
-    val new_plan = plan.asInstanceOf[MetastoreRelation];
-    plan.getClass == this.getClass &&
-    plan.children.size == children.size &&
-    databaseName == new_plan.databaseName &&
-    tableName == new_plan.tableName
+      plan match {
+           case mr: MetastoreRelation =>
+                    mr.databaseName == databaseName && mr.tableName == tableName
+           case _ => false
+      }
   }
 
   val tableDesc = HiveShim.getTableDesc(

Original file line number	Diff line number	Diff line change
`@@ -428,11 +428,11 @@ private[hive] case class MetastoreRelation`
`428`	`428`	`}`
`429`	`429`	`)`
`430`	`430`	`override def sameResult(plan: LogicalPlan): Boolean = {`
`431`		`- val new_plan = plan.asInstanceOf[MetastoreRelation];`
`432`		`- plan.getClass == this.getClass &&`
`433`		`- plan.children.size == children.size &&`
`434`		`- databaseName == new_plan.databaseName &&`
`435`		`- tableName == new_plan.tableName`
	`431`	`+ plan match {`
	`432`	`+ case mr: MetastoreRelation =>`
	`433`	`+ mr.databaseName == databaseName && mr.tableName == tableName`
	`434`	`+ case _ => false`
	`435`	`+ }`
`436`	`436`	`}`
`437`	`437`
`438`	`438`	`val tableDesc = HiveShim.getTableDesc(`