diff --git a/tensnsorflow/multi.py b/tensnsorflow/multi.py index 6980aaccf7319e5347183c36d4427e1fe29eb3c6..9aa0381f7d4a9096c87967f4ec93801c01670d6d 100644 --- a/tensnsorflow/multi.py +++ b/tensnsorflow/multi.py @@ -13,7 +13,7 @@ def test(): sparkConf = SparkConf().set("spark.hive.mapred.supports.subdirectories", "true")\ .set("spark.hadoop.mapreduce.input.fileinputformat.input.dir.recursive", "true")\ .set("spark.tispark.plan.allow_index_double_read", "false") \ - .set("spark.tispark.plan.allow_index_read", "false")\ + .set("spark.tispark.plan.allow_index_read", "true")\ .set("spark.sql.extensions", "org.apache.spark.sql.TiExtensions")\ .set("spark.tispark.pd.addresses", "172.16.40.158:2379").set("spark.io.compression.codec", "lzf")