Support Questions
Find answers, ask questions, and share your expertise

Query using Hive Warehouse Connector gives NullPointerException, HDP 3.0

New Contributor

Code:

val sqlstring = "CREATE TABLE IF NOT EXISTS test_table (col1 int , col2 string) STORED AS ORC"
val df = hive.executeQuery(sqlstring)

Output:

java.lang.RuntimeException: java.io.IOException: shadehive.org.apache.hive.service.cli.HiveSQLException: java.io.IOException: java.lang.NullPointerException
  at com.hortonworks.spark.sql.hive.llap.HiveWarehouseDataSourceReader.readSchema(HiveWarehouseDataSourceReader.java:130)
  at org.apache.spark.sql.execution.datasources.v2.DataSourceV2Relation$.apply(DataSourceV2Relation.scala:6)
  at org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:224)
  at org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:164)
  at com.hortonworks.spark.sql.hive.llap.HiveWarehouseSessionImpl.executeQuery(HiveWarehouseSessionImpl.java:62)
  ... 161 elided

But this works:

hive.createTable("test_table").column("col1", "string")

If you need more information please comment

I would like to execute queries, what is this problem?

0 REPLIES 0