Support Questions
Find answers, ask questions, and share your expertise
Announcements
Alert: Welcome to the Unified Cloudera Community. Former HCC members be sure to read and learn how to activate your account here.

Query using Hive Warehouse Connector gives NullPointerException, HDP 3.0

Highlighted

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?

Don't have an account?
Coming from Hortonworks? Activate your account here