I get the following:   insert into rhtest_db.val_test_2 values(15, 'testing');   Error while compiling statement: FAILED: SemanticException [Error 10293]: Unable to create temp file for insert values User [hive] is not authorized to perform [DECRYPT_EEK] on key with ACL name [hdfskey]!!   Any Ideas? ... View more

This is pretty well laided out in the documantion...need to stop and read though it though. Now you can build a table in Hive and query the data via Impala and Hue. You'll build this table in 2 steps. First, you'll take advantage of Hive's flexible SerDes (serializers / deserializers) to parse the logs into individual fields using a regular expression. Second, you'll transfer the data from this intermediate table to one that does not require any special SerDe. Once the data is in this table, you can query it much faster and more interactively using Impala. We'll use the Hive Query Editor app in Hue to execute the following queries: ) ... View more

It looks like tempTable is not sticking around: scala> case class rowschema(id:Int, record:String){ | val df = sqlContext.createDataFrame(Seq(rowschema(1,"record1"), rowschema(2,"record2"), rowschema(3,"record3")));{ | df.registerTempTable("tempTable") | } | } defined class rowschema scala> sqlContext.sql("create table newHiveTable as select * from tempTable") org.apache.spark.sql.AnalysisException: Table not found: tempTable; line 1 pos 43 ... View more

This worked well after adding a ; val df = sqlContext.createDataFrame(Seq(rowschema(1,"record1"), rowschema(2,"record2"), rowschema(3,"record3"))); ... View more