File tree Expand file tree Collapse file tree 1 file changed +4
-1
lines changed
sql/hive/src/main/scala/org/apache/spark/sql/hive/test Expand file tree Collapse file tree 1 file changed +4
-1
lines changed Original file line number Diff line number Diff line change @@ -21,6 +21,7 @@ import java.io.File
2121import java .util .{Set => JavaSet }
2222
2323import org .apache .hadoop .hive .conf .HiveConf
24+ import org .apache .hadoop .hive .conf .HiveConf .ConfVars
2425import org .apache .hadoop .hive .ql .exec .FunctionRegistry
2526import org .apache .hadoop .hive .ql .io .avro .{AvroContainerInputFormat , AvroContainerOutputFormat }
2627import org .apache .hadoop .hive .ql .metadata .Table
@@ -87,7 +88,9 @@ class TestHiveContext(sc: SparkContext) extends HiveContext(sc) {
8788
8889 /** Sets up the system initially or after a RESET command */
8990 protected override def configure (): Map [String , String ] =
90- temporaryConfig ++ Map (" hive.metastore.warehouse.dir" -> warehousePath.toString)
91+ temporaryConfig ++ Map (
92+ ConfVars .METASTOREWAREHOUSE .varname -> warehousePath.toString,
93+ ConfVars .METASTORE_INTEGER_JDO_PUSHDOWN .varname -> " true" )
9194
9295 val testTempDir = Utils .createTempDir()
9396
You can’t perform that action at this time.
0 commit comments