Member since
10-30-2017
2
Posts
0
Kudos Received
0
Solutions
10-30-2017
09:13 PM
org.apache.hive.hcatalog.streaming.TransactionError: Unable to
acquire lock on {metaStoreUri='thrift://sandbox-hdf.hortonworks.com:9083',
database='default', table='usage', partitionVals=[UA, 201702] }: null at
org.apache.hive.hcatalog.streaming.HiveEndPoint$TransactionBatchImpl.beginNextTransactionImpl(HiveEndPoint.java:636) at
org.apache.hive.hcatalog.streaming.HiveEndPoint$TransactionBatchImpl.beginNextTransaction(HiveEndPoint.java:603) at com.rudram.bigdata.hivestruct.StructWriter.struct(StructWriter.java:127) at
com.rudram.bigdata.hivestruct.StructWriter.main(StructWriter.java:192) at
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at
java.lang.reflect.Method.invoke(Method.java:498) at org.codehaus.mojo.exec.ExecJavaMojo$1.run(ExecJavaMojo.java:297) at
java.lang.Thread.run(Thread.java:748) Caused by: org.apache.thrift.transport.TTransportException at
org.apache.thrift.transport.TIOStreamTransport.read(TIOStreamTransport.java:132) at org.apache.thrift.transport.TTransport.readAll(TTransport.java:86) at
org.apache.thrift.protocol.TBinaryProtocol.readAll(TBinaryProtocol.java:429) at
org.apache.thrift.protocol.TBinaryProtocol.readI32(TBinaryProtocol.java:318) at org.apache.thrift.protocol.TBinaryProtocol.readMessageBegin(TBinaryProtocol.java:219) at
org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:69) at
org.apache.hadoop.hive.metastore.api.ThriftHiveMetastore$Client.recv_lock(ThriftHiveMetastore.java:3910) at
org.apache.hadoop.hive.metastore.api.ThriftHiveMetastore$Client.lock(ThriftHiveMetastore.java:3897) at
org.apache.hadoop.hive.metastore.HiveMetaStoreClient.lock(HiveMetaStoreClient.java:1869) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native
Method) at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:498) at
org.apache.hadoop.hive.metastore.RetryingMetaStoreClient.invoke(RetryingMetaStoreClient.java:152) at com.sun.proxy.$Proxy26.lock(Unknown
Source) at
org.apache.hive.hcatalog.streaming.HiveEndPoint$TransactionBatchImpl.beginNextTransactionImpl(HiveEndPoint.java:631) ... 9 more
... View more
10-30-2017
09:01 PM
I am working on HDP Cluster and we are using StrictJsonWriter. We are getting below error while transaction commit. Can Anyone help us why it is giving error? writer = new StrictJsonWriter(hiveEP, hiveConf); transactionBatch = connection.fetchTransactionBatch(10,
writer); transactionBatch.beginNextTransaction(); transactionBatch.write(inputFile.getBytes(Charsets.UTF_8)); writer.flush(); transactionBatch.commit(); transactionBatch.close(); connection.close(); Appreciate help in advance. Thanks
... View more
