Anyone????? On Sun, Dec 27, 2015 at 11:30 AM, Dasun Hegoda <dasunheg...@gmail.com> wrote:
> I was able to figure out where the problem is exactly. It's spark. because > when I start the hiveserver2 manually and run query it work fine. but when > I try to access the hive through spark's thrift port it does not work. > throws the above mentioned error. > > Please help me to fix this. > > On Sun, Dec 27, 2015 at 11:15 AM, Dasun Hegoda <dasunheg...@gmail.com> > wrote: > >> Yes, didn't work for me >> >> >> On Sun, Dec 27, 2015 at 10:56 AM, Ted Yu <yuzhih...@gmail.com> wrote: >> >>> Have you seen this ? >>> >>> >>> http://stackoverflow.com/questions/30705576/python-cannot-connect-hiveserver2 >>> >>> On Sat, Dec 26, 2015 at 9:09 PM, Dasun Hegoda <dasunheg...@gmail.com> >>> wrote: >>> >>>> I'm running apache-hive-1.2.1-bin and spark-1.5.1-bin-hadoop2.6. spark >>>> as the hive engine. When I try to connect through JasperStudio using thrift >>>> port I get below error. I'm running ubuntu 14.04. >>>> >>>> 15/12/26 23:36:20 ERROR server.TThreadPoolServer: Error occurred >>>> during processing of message. >>>> java.lang.RuntimeException: >>>> org.apache.thrift.transport.TSaslTransportException: No data or no sasl >>>> data in the stream >>>> at >>>> org.apache.thrift.transport.TSaslServerTransport$Factory.getTransport(TSaslServerTransport.java:219) >>>> at >>>> org.apache.thrift.server.TThreadPoolServer$WorkerProcess.run(TThreadPoolServer.java:268) >>>> at >>>> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) >>>> at >>>> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) >>>> at java.lang.Thread.run(Thread.java:745) >>>> Caused by: org.apache.thrift.transport.TSaslTransportException: No >>>> data or no sasl data in the stream >>>> at >>>> org.apache.thrift.transport.TSaslTransport.open(TSaslTransport.java:328) >>>> at >>>> org.apache.thrift.transport.TSaslServerTransport.open(TSaslServerTransport.java:41) >>>> at >>>> org.apache.thrift.transport.TSaslServerTransport$Factory.getTransport(TSaslServerTransport.java:216) >>>> ... 4 more >>>> 15/12/26 23:36:20 INFO thrift.ThriftCLIService: Client protocol >>>> version: HIVE_CLI_SERVICE_PROTOCOL_V5 >>>> 15/12/26 23:36:20 INFO session.SessionState: Created local >>>> directory: /tmp/c670ff55-01bb-4f6f-a375-d22a13c44eaf_resources >>>> 15/12/26 23:36:20 INFO session.SessionState: Created HDFS >>>> directory: /tmp/hive/anonymous/c670ff55-01bb-4f6f-a375-d22a13c44eaf >>>> 15/12/26 23:36:20 INFO session.SessionState: Created local >>>> directory: /tmp/hduser/c670ff55-01bb-4f6f-a375-d22a13c44eaf >>>> 15/12/26 23:36:20 INFO session.SessionState: Created HDFS >>>> directory: >>>> /tmp/hive/anonymous/c670ff55-01bb-4f6f-a375-d22a13c44eaf/_tmp_space.db >>>> 15/12/26 23:36:20 INFO thriftserver.SparkExecuteStatementOperation: >>>> Running query 'use default' with d842cd88-2fda-42b2-b943-468017e95f37 >>>> 15/12/26 23:36:20 INFO parse.ParseDriver: Parsing command: use >>>> default >>>> 15/12/26 23:36:20 INFO parse.ParseDriver: Parse Completed >>>> 15/12/26 23:36:20 INFO log.PerfLogger: <PERFLOG method=Driver.run >>>> from=org.apache.hadoop.hive.ql.Driver> >>>> 15/12/26 23:36:20 INFO log.PerfLogger: <PERFLOG method=TimeToSubmit >>>> from=org.apache.hadoop.hive.ql.Driver> >>>> 15/12/26 23:36:20 INFO log.PerfLogger: <PERFLOG method=compile >>>> from=org.apache.hadoop.hive.ql.Driver> >>>> 15/12/26 23:36:20 INFO log.PerfLogger: <PERFLOG method=parse >>>> from=org.apache.hadoop.hive.ql.Driver> >>>> 15/12/26 23:36:20 INFO parse.ParseDriver: Parsing command: use >>>> default >>>> 15/12/26 23:36:20 INFO parse.ParseDriver: Parse Completed >>>> 15/12/26 23:36:20 INFO log.PerfLogger: </PERFLOG method=parse >>>> start=1451190980590 end=1451190980591 duration=1 >>>> from=org.apache.hadoop.hive.ql.Driver> >>>> 15/12/26 23:36:20 INFO log.PerfLogger: <PERFLOG >>>> method=semanticAnalyze from=org.apache.hadoop.hive.ql.Driver> >>>> 15/12/26 23:36:20 INFO metastore.HiveMetaStore: 2: get_database: >>>> default >>>> 15/12/26 23:36:20 INFO HiveMetaStore.audit: ugi=hduser >>>> ip=unknown-ip-addr cmd=get_database: default >>>> 15/12/26 23:36:20 INFO metastore.HiveMetaStore: 2: Opening raw >>>> store with implemenation class:org.apache.hadoop.hive.metastore.ObjectStore >>>> 15/12/26 23:36:20 INFO metastore.ObjectStore: ObjectStore, >>>> initialize called >>>> 15/12/26 23:36:20 INFO DataNucleus.Query: Reading in results for >>>> query "org.datanucleus.store.rdbms.query.SQLQuery@0" since the >>>> connection used is closing >>>> 15/12/26 23:36:20 INFO metastore.MetaStoreDirectSql: Using direct >>>> SQL, underlying DB is DERBY >>>> 15/12/26 23:36:20 INFO metastore.ObjectStore: Initialized >>>> ObjectStore >>>> 15/12/26 23:36:20 INFO ql.Driver: Semantic Analysis Completed >>>> 15/12/26 23:36:20 INFO log.PerfLogger: </PERFLOG >>>> method=semanticAnalyze start=1451190980592 end=1451190980620 duration=28 >>>> from=org.apache.hadoop.hive.ql.Driver> >>>> 15/12/26 23:36:20 INFO ql.Driver: Returning Hive schema: >>>> Schema(fieldSchemas:null, properties:null) >>>> 15/12/26 23:36:20 INFO log.PerfLogger: </PERFLOG method=compile >>>> start=1451190980588 end=1451190980621 duration=33 >>>> from=org.apache.hadoop.hive.ql.Driver> >>>> 15/12/26 23:36:20 INFO ql.Driver: Concurrency mode is disabled, not >>>> creating a lock manager >>>> 15/12/26 23:36:20 INFO log.PerfLogger: <PERFLOG >>>> method=Driver.execute from=org.apache.hadoop.hive.ql.Driver> >>>> 15/12/26 23:36:20 INFO ql.Driver: Starting >>>> command(queryId=hduser_20151226233620_6bc633ef-5c6f-49e4-9300-f79fdf0c357b): >>>> use default >>>> 15/12/26 23:36:20 INFO log.PerfLogger: </PERFLOG >>>> method=TimeToSubmit start=1451190980588 end=1451190980622 duration=34 >>>> from=org.apache.hadoop.hive.ql.Driver> >>>> 15/12/26 23:36:20 INFO log.PerfLogger: <PERFLOG method=runTasks >>>> from=org.apache.hadoop.hive.ql.Driver> >>>> 15/12/26 23:36:20 INFO log.PerfLogger: <PERFLOG >>>> method=task.DDL.Stage-0 from=org.apache.hadoop.hive.ql.Driver> >>>> 15/12/26 23:36:20 INFO ql.Driver: Starting task [Stage-0:DDL] in >>>> serial mode >>>> 15/12/26 23:36:20 INFO metastore.HiveMetaStore: 2: get_database: >>>> default >>>> 15/12/26 23:36:20 INFO HiveMetaStore.audit: ugi=hduser >>>> ip=unknown-ip-addr cmd=get_database: default >>>> 15/12/26 23:36:20 INFO metastore.HiveMetaStore: 2: get_database: >>>> default >>>> 15/12/26 23:36:20 INFO HiveMetaStore.audit: ugi=hduser >>>> ip=unknown-ip-addr cmd=get_database: default >>>> 15/12/26 23:36:20 INFO log.PerfLogger: </PERFLOG method=runTasks >>>> start=1451190980622 end=1451190980637 duration=15 >>>> from=org.apache.hadoop.hive.ql.Driver> >>>> 15/12/26 23:36:20 INFO log.PerfLogger: </PERFLOG >>>> method=Driver.execute start=1451190980621 end=1451190980637 duration=16 >>>> from=org.apache.hadoop.hive.ql.Driver> >>>> OK >>>> 15/12/26 23:36:20 INFO ql.Driver: OK >>>> 15/12/26 23:36:20 INFO log.PerfLogger: <PERFLOG method=releaseLocks >>>> from=org.apache.hadoop.hive.ql.Driver> >>>> 15/12/26 23:36:20 INFO log.PerfLogger: </PERFLOG >>>> method=releaseLocks start=1451190980639 end=1451190980639 duration=0 >>>> from=org.apache.hadoop.hive.ql.Driver> >>>> 15/12/26 23:36:20 INFO log.PerfLogger: </PERFLOG method=Driver.run >>>> start=1451190980587 end=1451190980639 duration=52 >>>> from=org.apache.hadoop.hive.ql.Driver> >>>> 15/12/26 23:36:20 INFO thriftserver.SparkExecuteStatementOperation: >>>> Result Schema: List(result#28) >>>> 15/12/26 23:36:20 INFO thriftserver.SparkExecuteStatementOperation: >>>> Running query 'SELECT * FROM service' with >>>> 37916038-9856-43eb-8b73-920f9faf738f >>>> 15/12/26 23:36:20 INFO parse.ParseDriver: Parsing command: SELECT * >>>> FROM service >>>> 15/12/26 23:36:20 INFO parse.ParseDriver: Parse Completed >>>> 15/12/26 23:36:20 INFO metastore.HiveMetaStore: 2: get_table : >>>> db=default tbl=service >>>> 15/12/26 23:36:20 INFO HiveMetaStore.audit: ugi=hduser >>>> ip=unknown-ip-addr cmd=get_table : db=default tbl=service >>>> 15/12/26 23:36:20 ERROR >>>> thriftserver.SparkExecuteStatementOperation: Error executing query, >>>> currentState RUNNING, >>>> org.apache.spark.sql.AnalysisException: no such table service; line >>>> 1 pos 14 >>>> at >>>> org.apache.spark.sql.catalyst.analysis.package$AnalysisErrorAt.failAnalysis(package.scala:42) >>>> at >>>> org.apache.spark.sql.catalyst.analysis.Analyzer$ResolveRelations$.getTable(Analyzer.scala:260) >>>> at >>>> org.apache.spark.sql.catalyst.analysis.Analyzer$ResolveRelations$$anonfun$apply$7.applyOrElse(Analyzer.scala:268) >>>> at >>>> org.apache.spark.sql.catalyst.analysis.Analyzer$ResolveRelations$$anonfun$apply$7.applyOrElse(Analyzer.scala:264) >>>> at >>>> org.apache.spark.sql.catalyst.plans.logical.LogicalPlan$$anonfun$resolveOperators$1.apply(LogicalPlan.scala:57) >>>> at >>>> org.apache.spark.sql.catalyst.plans.logical.LogicalPlan$$anonfun$resolveOperators$1.apply(LogicalPlan.scala:57) >>>> at >>>> org.apache.spark.sql.catalyst.trees.CurrentOrigin$.withOrigin(TreeNode.scala:51) >>>> at >>>> org.apache.spark.sql.catalyst.plans.logical.LogicalPlan.resolveOperators(LogicalPlan.scala:56) >>>> at >>>> org.apache.spark.sql.catalyst.plans.logical.LogicalPlan$$anonfun$1.apply(LogicalPlan.scala:54) >>>> at >>>> org.apache.spark.sql.catalyst.plans.logical.LogicalPlan$$anonfun$1.apply(LogicalPlan.scala:54) >>>> at >>>> org.apache.spark.sql.catalyst.trees.TreeNode$$anonfun$4.apply(TreeNode.scala:249) >>>> at scala.collection.Iterator$$anon$11.next(Iterator.scala:328) >>>> at scala.collection.Iterator$class.foreach(Iterator.scala:727) >>>> at scala.collection.AbstractIterator.foreach(Iterator.scala:1157) >>>> at >>>> scala.collection.generic.Growable$class.$plus$plus$eq(Growable.scala:48) >>>> at >>>> scala.collection.mutable.ArrayBuffer.$plus$plus$eq(ArrayBuffer.scala:103) >>>> at >>>> scala.collection.mutable.ArrayBuffer.$plus$plus$eq(ArrayBuffer.scala:47) >>>> at scala.collection.TraversableOnce$class.to >>>> (TraversableOnce.scala:273) >>>> at scala.collection.AbstractIterator.to(Iterator.scala:1157) >>>> at >>>> scala.collection.TraversableOnce$class.toBuffer(TraversableOnce.scala:265) >>>> at scala.collection.AbstractIterator.toBuffer(Iterator.scala:1157) >>>> at >>>> scala.collection.TraversableOnce$class.toArray(TraversableOnce.scala:252) >>>> at scala.collection.AbstractIterator.toArray(Iterator.scala:1157) >>>> at >>>> org.apache.spark.sql.catalyst.trees.TreeNode.transformChildren(TreeNode.scala:279) >>>> at >>>> org.apache.spark.sql.catalyst.plans.logical.LogicalPlan.resolveOperators(LogicalPlan.scala:54) >>>> at >>>> org.apache.spark.sql.catalyst.analysis.Analyzer$ResolveRelations$.apply(Analyzer.scala:264) >>>> at >>>> org.apache.spark.sql.catalyst.analysis.Analyzer$ResolveRelations$.apply(Analyzer.scala:254) >>>> at >>>> org.apache.spark.sql.catalyst.rules.RuleExecutor$$anonfun$execute$1$$anonfun$apply$1.apply(RuleExecutor.scala:83) >>>> at >>>> org.apache.spark.sql.catalyst.rules.RuleExecutor$$anonfun$execute$1$$anonfun$apply$1.apply(RuleExecutor.scala:80) >>>> at >>>> scala.collection.LinearSeqOptimized$class.foldLeft(LinearSeqOptimized.scala:111) >>>> at scala.collection.immutable.List.foldLeft(List.scala:84) >>>> at >>>> org.apache.spark.sql.catalyst.rules.RuleExecutor$$anonfun$execute$1.apply(RuleExecutor.scala:80) >>>> at >>>> org.apache.spark.sql.catalyst.rules.RuleExecutor$$anonfun$execute$1.apply(RuleExecutor.scala:72) >>>> at scala.collection.immutable.List.foreach(List.scala:318) >>>> at >>>> org.apache.spark.sql.catalyst.rules.RuleExecutor.execute(RuleExecutor.scala:72) >>>> at >>>> org.apache.spark.sql.SQLContext$QueryExecution.analyzed$lzycompute(SQLContext.scala:916) >>>> at >>>> org.apache.spark.sql.SQLContext$QueryExecution.analyzed(SQLContext.scala:916) >>>> at >>>> org.apache.spark.sql.SQLContext$QueryExecution.assertAnalyzed(SQLContext.scala:914) >>>> at org.apache.spark.sql.DataFrame.<init>(DataFrame.scala:132) >>>> at org.apache.spark.sql.DataFrame$.apply(DataFrame.scala:51) >>>> at org.apache.spark.sql.SQLContext.sql(SQLContext.scala:725) >>>> at >>>> org.apache.spark.sql.hive.thriftserver.SparkExecuteStatementOperation.runInternal(SparkExecuteStatementOperation.scala:224) >>>> at >>>> org.apache.spark.sql.hive.thriftserver.SparkExecuteStatementOperation.run(SparkExecuteStatementOperation.scala:144) >>>> at >>>> org.apache.hive.service.cli.session.HiveSessionImpl.executeStatementInternal(HiveSessionImpl.java:388) >>>> at >>>> org.apache.hive.service.cli.session.HiveSessionImpl.executeStatement(HiveSessionImpl.java:369) >>>> at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) >>>> at >>>> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57) >>>> at >>>> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) >>>> at java.lang.reflect.Method.invoke(Method.java:606) >>>> at >>>> org.apache.hive.service.cli.session.HiveSessionProxy.invoke(HiveSessionProxy.java:78) >>>> at >>>> org.apache.hive.service.cli.session.HiveSessionProxy.access$000(HiveSessionProxy.java:36) >>>> at >>>> org.apache.hive.service.cli.session.HiveSessionProxy$1.run(HiveSessionProxy.java:63) >>>> at java.security.AccessController.doPrivileged(Native Method) >>>> at javax.security.auth.Subject.doAs(Subject.java:415) >>>> at >>>> org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1628) >>>> at >>>> org.apache.hive.service.cli.session.HiveSessionProxy.invoke(HiveSessionProxy.java:59) >>>> at com.sun.proxy.$Proxy47.executeStatement(Unknown Source) >>>> at >>>> org.apache.hive.service.cli.CLIService.executeStatement(CLIService.java:261) >>>> at >>>> org.apache.hive.service.cli.thrift.ThriftCLIService.ExecuteStatement(ThriftCLIService.java:486) >>>> at >>>> org.apache.hive.service.cli.thrift.TCLIService$Processor$ExecuteStatement.getResult(TCLIService.java:1313) >>>> at >>>> org.apache.hive.service.cli.thrift.TCLIService$Processor$ExecuteStatement.getResult(TCLIService.java:1298) >>>> at >>>> org.apache.thrift.ProcessFunction.process(ProcessFunction.java:39) >>>> at org.apache.thrift.TBaseProcessor.process(TBaseProcessor.java:39) >>>> at >>>> org.apache.hive.service.auth.TSetIpAddressProcessor.process(TSetIpAddressProcessor.java:56) >>>> at >>>> org.apache.thrift.server.TThreadPoolServer$WorkerProcess.run(TThreadPoolServer.java:285) >>>> at >>>> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) >>>> at >>>> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) >>>> at java.lang.Thread.run(Thread.java:745) >>>> 15/12/26 23:36:20 WARN thrift.ThriftCLIService: Error executing >>>> statement: >>>> org.apache.hive.service.cli.HiveSQLException: >>>> org.apache.spark.sql.AnalysisException: no such table service; line 1 pos >>>> 14 >>>> at >>>> org.apache.spark.sql.hive.thriftserver.SparkExecuteStatementOperation.runInternal(SparkExecuteStatementOperation.scala:259) >>>> at >>>> org.apache.spark.sql.hive.thriftserver.SparkExecuteStatementOperation.run(SparkExecuteStatementOperation.scala:144) >>>> at >>>> org.apache.hive.service.cli.session.HiveSessionImpl.executeStatementInternal(HiveSessionImpl.java:388) >>>> at >>>> org.apache.hive.service.cli.session.HiveSessionImpl.executeStatement(HiveSessionImpl.java:369) >>>> at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) >>>> at >>>> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57) >>>> at >>>> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) >>>> at java.lang.reflect.Method.invoke(Method.java:606) >>>> at >>>> org.apache.hive.service.cli.session.HiveSessionProxy.invoke(HiveSessionProxy.java:78) >>>> at >>>> org.apache.hive.service.cli.session.HiveSessionProxy.access$000(HiveSessionProxy.java:36) >>>> at >>>> org.apache.hive.service.cli.session.HiveSessionProxy$1.run(HiveSessionProxy.java:63) >>>> at java.security.AccessController.doPrivileged(Native Method) >>>> at javax.security.auth.Subject.doAs(Subject.java:415) >>>> at >>>> org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1628) >>>> at >>>> org.apache.hive.service.cli.session.HiveSessionProxy.invoke(HiveSessionProxy.java:59) >>>> at com.sun.proxy.$Proxy47.executeStatement(Unknown Source) >>>> at >>>> org.apache.hive.service.cli.CLIService.executeStatement(CLIService.java:261) >>>> at >>>> org.apache.hive.service.cli.thrift.ThriftCLIService.ExecuteStatement(ThriftCLIService.java:486) >>>> at >>>> org.apache.hive.service.cli.thrift.TCLIService$Processor$ExecuteStatement.getResult(TCLIService.java:1313) >>>> at >>>> org.apache.hive.service.cli.thrift.TCLIService$Processor$ExecuteStatement.getResult(TCLIService.java:1298) >>>> at >>>> org.apache.thrift.ProcessFunction.process(ProcessFunction.java:39) >>>> at org.apache.thrift.TBaseProcessor.process(TBaseProcessor.java:39) >>>> at >>>> org.apache.hive.service.auth.TSetIpAddressProcessor.process(TSetIpAddressProcessor.java:56) >>>> at >>>> org.apache.thrift.server.TThreadPoolServer$WorkerProcess.run(TThreadPoolServer.java:285) >>>> at >>>> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) >>>> at >>>> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) >>>> at java.lang.Thread.run(Thread.java:745) >>>> 15/12/26 23:41:08 ERROR server.TThreadPoolServer: Error occurred >>>> during processing of message. >>>> java.lang.RuntimeException: >>>> org.apache.thrift.transport.TSaslTransportException: No data or no sasl >>>> data in the stream >>>> at >>>> org.apache.thrift.transport.TSaslServerTransport$Factory.getTransport(TSaslServerTransport.java:219) >>>> at >>>> org.apache.thrift.server.TThreadPoolServer$WorkerProcess.run(TThreadPoolServer.java:268) >>>> at >>>> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) >>>> at >>>> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) >>>> at java.lang.Thread.run(Thread.java:745) >>>> Caused by: org.apache.thrift.transport.TSaslTransportException: No >>>> data or no sasl data in the stream >>>> at >>>> org.apache.thrift.transport.TSaslTransport.open(TSaslTransport.java:328) >>>> at >>>> org.apache.thrift.transport.TSaslServerTransport.open(TSaslServerTransport.java:41) >>>> at >>>> org.apache.thrift.transport.TSaslServerTransport$Factory.getTransport(TSaslServerTransport.java:216) >>>> ... 4 more >>>> 15/12/26 23:41:08 INFO thrift.ThriftCLIService: Client protocol >>>> version: HIVE_CLI_SERVICE_PROTOCOL_V5 >>>> 15/12/26 23:41:08 INFO session.SessionState: Created local >>>> directory: /tmp/aa7ce472-0284-4469-823b-748ef786ab73_resources >>>> 15/12/26 23:41:08 INFO session.SessionState: Created HDFS >>>> directory: /tmp/hive/anonymous/aa7ce472-0284-4469-823b-748ef786ab73 >>>> 15/12/26 23:41:08 INFO session.SessionState: Created local >>>> directory: /tmp/hduser/aa7ce472-0284-4469-823b-748ef786ab73 >>>> 15/12/26 23:41:08 INFO session.SessionState: Created HDFS >>>> directory: >>>> /tmp/hive/anonymous/aa7ce472-0284-4469-823b-748ef786ab73/_tmp_space.db >>>> 15/12/26 23:41:08 INFO thriftserver.SparkExecuteStatementOperation: >>>> Running query 'use default' with 6a274f01-2a83-44b9-b970-2154792af7a2 >>>> 15/12/26 23:41:08 INFO parse.ParseDriver: Parsing command: use >>>> default >>>> 15/12/26 23:41:08 INFO parse.ParseDriver: Parse Completed >>>> 15/12/26 23:41:08 INFO log.PerfLogger: <PERFLOG method=Driver.run >>>> from=org.apache.hadoop.hive.ql.Driver> >>>> 15/12/26 23:41:08 INFO log.PerfLogger: <PERFLOG method=TimeToSubmit >>>> from=org.apache.hadoop.hive.ql.Driver> >>>> 15/12/26 23:41:08 INFO log.PerfLogger: <PERFLOG method=compile >>>> from=org.apache.hadoop.hive.ql.Driver> >>>> 15/12/26 23:41:08 INFO log.PerfLogger: <PERFLOG method=parse >>>> from=org.apache.hadoop.hive.ql.Driver> >>>> 15/12/26 23:41:08 INFO parse.ParseDriver: Parsing command: use >>>> default >>>> 15/12/26 23:41:08 INFO parse.ParseDriver: Parse Completed >>>> 15/12/26 23:41:08 INFO log.PerfLogger: </PERFLOG method=parse >>>> start=1451191268389 end=1451191268390 duration=1 >>>> from=org.apache.hadoop.hive.ql.Driver> >>>> 15/12/26 23:41:08 INFO log.PerfLogger: <PERFLOG >>>> method=semanticAnalyze from=org.apache.hadoop.hive.ql.Driver> >>>> 15/12/26 23:41:08 INFO metastore.HiveMetaStore: 2: get_database: >>>> default >>>> 15/12/26 23:41:08 INFO HiveMetaStore.audit: ugi=hduser >>>> ip=unknown-ip-addr cmd=get_database: default >>>> 15/12/26 23:41:08 INFO ql.Driver: Semantic Analysis Completed >>>> 15/12/26 23:41:08 INFO log.PerfLogger: </PERFLOG >>>> method=semanticAnalyze start=1451191268390 end=1451191268397 duration=7 >>>> from=org.apache.hadoop.hive.ql.Driver> >>>> 15/12/26 23:41:08 INFO ql.Driver: Returning Hive schema: >>>> Schema(fieldSchemas:null, properties:null) >>>> 15/12/26 23:41:08 INFO log.PerfLogger: </PERFLOG method=compile >>>> start=1451191268387 end=1451191268398 duration=11 >>>> from=org.apache.hadoop.hive.ql.Driver> >>>> 15/12/26 23:41:08 INFO ql.Driver: Concurrency mode is disabled, not >>>> creating a lock manager >>>> 15/12/26 23:41:08 INFO log.PerfLogger: <PERFLOG >>>> method=Driver.execute from=org.apache.hadoop.hive.ql.Driver> >>>> 15/12/26 23:41:08 INFO ql.Driver: Starting >>>> command(queryId=hduser_20151226234108_27b4ad3d-0f88-4a81-83f6-eaf0ef49cd22): >>>> use default >>>> 15/12/26 23:41:08 INFO log.PerfLogger: </PERFLOG >>>> method=TimeToSubmit start=1451191268387 end=1451191268399 duration=12 >>>> from=org.apache.hadoop.hive.ql.Driver> >>>> 15/12/26 23:41:08 INFO log.PerfLogger: <PERFLOG method=runTasks >>>> from=org.apache.hadoop.hive.ql.Driver> >>>> 15/12/26 23:41:08 INFO log.PerfLogger: <PERFLOG >>>> method=task.DDL.Stage-0 from=org.apache.hadoop.hive.ql.Driver> >>>> 15/12/26 23:41:08 INFO ql.Driver: Starting task [Stage-0:DDL] in >>>> serial mode >>>> 15/12/26 23:41:08 INFO metastore.HiveMetaStore: 2: get_database: >>>> default >>>> 15/12/26 23:41:08 INFO HiveMetaStore.audit: ugi=hduser >>>> ip=unknown-ip-addr cmd=get_database: default >>>> 15/12/26 23:41:08 INFO metastore.HiveMetaStore: 2: get_database: >>>> default >>>> 15/12/26 23:41:08 INFO HiveMetaStore.audit: ugi=hduser >>>> ip=unknown-ip-addr cmd=get_database: default >>>> 15/12/26 23:41:08 INFO log.PerfLogger: </PERFLOG method=runTasks >>>> start=1451191268399 end=1451191268412 duration=13 >>>> from=org.apache.hadoop.hive.ql.Driver> >>>> 15/12/26 23:41:08 INFO log.PerfLogger: </PERFLOG >>>> method=Driver.execute start=1451191268398 end=1451191268412 duration=14 >>>> from=org.apache.hadoop.hive.ql.Driver> >>>> OK >>>> 15/12/26 23:41:08 INFO ql.Driver: OK >>>> 15/12/26 23:41:08 INFO log.PerfLogger: <PERFLOG method=releaseLocks >>>> from=org.apache.hadoop.hive.ql.Driver> >>>> 15/12/26 23:41:08 INFO log.PerfLogger: </PERFLOG >>>> method=releaseLocks start=1451191268413 end=1451191268413 duration=0 >>>> from=org.apache.hadoop.hive.ql.Driver> >>>> 15/12/26 23:41:08 INFO log.PerfLogger: </PERFLOG method=Driver.run >>>> start=1451191268387 end=1451191268413 duration=26 >>>> from=org.apache.hadoop.hive.ql.Driver> >>>> 15/12/26 23:41:08 INFO thriftserver.SparkExecuteStatementOperation: >>>> Result Schema: List(result#43) >>>> >>>> >>>> Below is the apache-hive-1.2.1-bin/conf/hive-site.xml >>>> >>>> >>>> <description> >>>> The cluster manager to connect to >>>> </description> >>>> </property> >>>> >>>> <property> >>>> <name>spark.serializer</name> >>>> <value>org.apache.spark.serializer.KryoSerializer</value> >>>> <description> >>>> Class to use for serializing objects that will be sent >>>> over the network >>>> </description> >>>> </property> >>>> >>>> >>>> >>>> <property> >>>> <name>hive.server2.authentication</name> >>>> <value>NONE</value> >>>> <description> >>>> Client authentication types. >>>> NONE: no authentication check >>>> LDAP: LDAP/AD based authentication >>>> KERBEROS: Kerberos/GSSAPI authentication >>>> CUSTOM: Custom authentication provider >>>> (Use with property >>>> hive.server2.custom.authentication.class) >>>> </description> >>>> </property> >>>> >>>> <property> >>>> <name>hive.metastore.sasl.enabled</name> >>>> <value>false</value> >>>> <description>If true, the metastore thrift interface will be >>>> secured with SASL. Clients must authenticate with Kerberos.</description> >>>> </property> >>>> >>>> <!--Hive server --> >>>> <property> >>>> <name>hive.server2.thrift.port</name> >>>> <value>10000</value> >>>> <description>Port number of HiveServer2 Thrift interface. >>>> Can be overridden by setting >>>> $HIVE_SERVER2_THRIFT_PORT</description> >>>> </property> >>>> >>>> <property> >>>> <name>hive.server2.thrift.bind.host</name> >>>> <value>192.168.7.87</value> >>>> <description>Bind host on which to run the HiveServer2 Thrift >>>> interface. >>>> Can be overridden by setting >>>> $HIVE_SERVER2_THRIFT_BIND_HOST</description> >>>> </property> >>>> >>>> How can I fix this? >>>> >>>> -- >>>> Regards, >>>> Dasun Hegoda, Software Engineer >>>> www.dasunhegoda.com | dasunheg...@gmail.com >>>> >>> >>> >> >> >> -- >> Regards, >> Dasun Hegoda, Software Engineer >> www.dasunhegoda.com | dasunheg...@gmail.com >> > > > > -- > Regards, > Dasun Hegoda, Software Engineer > www.dasunhegoda.com | dasunheg...@gmail.com > -- Regards, Dasun Hegoda, Software Engineer www.dasunhegoda.com | dasunheg...@gmail.com
