bimaltandel / hivekudu-handler Goto Github PK

Either by leveraging Hive DDLs or TBLPROPERTIES

Match feature with Impala

Does this version support kudu 1.4.0 and hive 1.1.0 ?

I have this issue.

AILED: Execution Error, return code 1 from org.apache.hadoop.hive.ql.exec.DDLTask. MetaException(message:Error creating Kudu table: test_alias_rut_hivekudu:org.kududb.client.NonRecoverableException: Too many attempts: KuduRpc(method=CreateTable, tablet=null, attempt=6, DeadlineTracker(timeout=10000, elapsed=8044), Deferred@1146919769(state=PENDING, result=null, callback=(continuation of Deferred@2091976938 after retry RPC after error@1976728735) -> (continuation of Deferred@81113478 after retry RPC after error@611542038) -> (continuation of Deferred@1358024234 after retry RPC after error@908162607) -> (continuation of Deferred@533838060 after retry RPC after error@540884180) -> (continuation of Deferred@2120431207 after retry RPC after error@1129228170), errback=(continuation of Deferred@2091976938 after retry RPC after error@1976728735) -> (continuation of Deferred@81113478 after retry RPC after error@611542038) -> (continuation of Deferred@1358024234 after retry RPC after error@908162607) -> (continuation of Deferred@533838060 after retry RPC after error@540884180) -> (continuation of Deferred@2120431207 after retry RPC after error@1129228170))))

Thank you

Regards,
Cristian

Hi Bimal,

Any news on the progress of supporting newer versions of Kudu? Preferably Kudu 1.1.0.

Is there anything we can do to contribute? I've read the JIRA issue where you mention a new upcoming release so I don't know what you've done already.

Thanks,

Vincent

Upgrade dependencies and test with Kudu 0.8 (Client + Server).

Hello! I am trying to create a Kudu table in Hive by following the example in the docs. I issue this command

CREATE TABLE if not exists test_drop (
id INT,
name STRING
)
stored by 'org.apache.hadoop.hive.kududb.KuduHandler.KuduStorageHandler'
TBLPROPERTIES(
  'kudu.table_name' = 'test_drop',
  'kudu.master_addresses' = 'ip-172-31-56-74.ec2.internal:7051',
  'kudu.key_columns' = 'id'
);

in the beeline client, but get this error:

Error: org.apache.spark.sql.execution.QueryExecutionException: FAILED: Execution Error, return code 1 from org.apache.hadoop.hive.ql.exec.DDLTask. MetaException(message:Error creating Kudu table: test_drop:java.lang.IllegalArgumentException: Table partitioning must be specified using setRangePartitionColumns or addHashPartitions) (state=,code=0)

I'm using Kudu 0.10. I suspect this is due to Kudu now requiring an explicit table partitioning method to be provided, and not using a default. However I am very much a beginner :-) Is there a workaround? For what it's worth, I'm using the beeline client (and Hive) bundled with Spark 1.6.2.

Thanks!
Graham

Provide capability to read column names and datatypes directly from Kudu
Provide capability to map and change Column names and data types