Details
-
Bug
-
Status: Resolved
-
Critical
-
Resolution: Fixed
-
None
-
None
-
None
Description
val rdd = sc.parallelize((1 to 10).map(i => s"""{"a":$i, "b":"str${i}"}""")) sqlContext.jsonRDD(rdd).registerTempTable("jt") sqlContext.sql("CACHE TABLE foo AS SELECT * FROM jt") sqlContext.sql("CACHE TABLE foo AS SELECT a FROM jt")
After the second CACHE TABLE command, the RDD for the first table still remains in the cache.
Attachments
Issue Links
- links to