- spark-shell --master yarn \ --jars /usr/hdp/3.0.1.0-183/hive_warehouse_connector/hive-warehouse-connector-assembly-1.0.0.3.0.1.0-183.jar \ --conf spark.security.credentials.hiveserver2.enabled=false
import com.hortonworks.hwc.HiveWarehouseSession
val hive =HiveWarehouseSession.session(spark).build()
hive.setDatabase("my_test_db")
hive.executeQuery("SELECT * FROM my_table where code is null and loaddt='mmddyyyy'").show()
this statement is not running at all , it will just hangs
I also tried this way
hive.execute("SELECT * FROM my_table where code is null and loaddt='mmddyyyy'").show()
this would return only 1000 rows even though table has more records .