metastore concurrency fix.

marmbrus · marmbrus · commit 93d0f642aa3c · 2014-08-19T01:07:17.000-07: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
@@ -265,9 +265,9 @@ private[hive] case class MetastoreRelation
   // org.apache.hadoop.hive.ql.metadata.Partition will cause a NotSerializableException
   // which indicates the SerDe we used is not Serializable.
 
-  @transient lazy val hiveQlTable = new Table(table)
+  @transient val hiveQlTable = new Table(table)
 
-  def hiveQlPartitions = partitions.map { p =>
+  @transient val hiveQlPartitions = partitions.map { p =>
     new Partition(hiveQlTable, p)
   }
 

Original file line number	Diff line number	Diff line change
`@@ -265,9 +265,9 @@ private[hive] case class MetastoreRelation`
`265`	`265`	`// org.apache.hadoop.hive.ql.metadata.Partition will cause a NotSerializableException`
`266`	`266`	`// which indicates the SerDe we used is not Serializable.`
`267`	`267`
`268`		`- @transient lazy val hiveQlTable = new Table(table)`
	`268`	`+ @transient val hiveQlTable = new Table(table)`
`269`	`269`
`270`		`- def hiveQlPartitions = partitions.map { p =>`
	`270`	`+ @transient val hiveQlPartitions = partitions.map { p =>`
`271`	`271`	`new Partition(hiveQlTable, p)`
`272`	`272`	`}`
`273`	`273`