[ https://issues.apache.org/jira/browse/CARBONDATA-1116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16032668#comment-16032668 ] chenerlu commented on CARBONDATA-1116: -------------------------------------- Hi, I met same issue when I ran CarbonSessionExample on latest master branch. This issue may caused by creating a new SparkSqlParser with null as its parameter. Please help check and see if same problem. [~ravi.pesala] Thanks > Not able to connect with Carbonsession while starting carbon spark shell and beeline > ------------------------------------------------------------------------------------ > > Key: CARBONDATA-1116 > URL: https://issues.apache.org/jira/browse/CARBONDATA-1116 > Project: CarbonData > Issue Type: Bug > Components: sql > Affects Versions: 1.2.0 > Environment: spark 2.1 > Reporter: Vandana Yadav > Priority: Blocker > > Not able to connect with Carbonsession while starting carbon spark shell and beeline > Steps to reproduce: > 1)Start thrift-server > a) cd $SPARK-HOME/bin > b) ./spark-submit --conf spark.sql.hive.thriftServer.singleSession=true --class org.apache.carbondata.spark.thriftserver.CarbonThriftServer /opt/spark/spark-2.1/carbonlib/carbondata_2.11-1.1.0-SNAPSHOT-shade-hadoop2.7.3.jar hdfs://localhost:54310/opt/prestocarbonStore > 2)Start Beeline > a) cd $SPARK-HOME/bin > b)./beeline > 3) Connect with carbondata via jdbc > !connect jdbc:hive2://localhost:10000 > Enter username for jdbc:hive2://localhost:10000: hduser > Enter password for jdbc:hive2://localhost:10000: ****** > 4) Actual Result: > Error: Could not establish connection to jdbc:hive2://localhost:10000: null (state=08S01,code=0) > 0: jdbc:hive2://localhost:10000 (closed)> > 5) Expected result : it should connect successfully with carbondata > 6)console logs: > 17/06/01 13:03:27 INFO ThriftCLIService: Client protocol version: HIVE_CLI_SERVICE_PROTOCOL_V8 > 17/06/01 13:03:27 INFO SessionState: Created local directory: /tmp/addaba65-46c5-4467-a02f-2bbdfd54329a_resources > 17/06/01 13:03:27 INFO SessionState: Created HDFS directory: /tmp/hive/hduser/addaba65-46c5-4467-a02f-2bbdfd54329a > 17/06/01 13:03:27 INFO SessionState: Created local directory: /tmp/hduser/addaba65-46c5-4467-a02f-2bbdfd54329a > 17/06/01 13:03:27 INFO SessionState: Created HDFS directory: /tmp/hive/hduser/addaba65-46c5-4467-a02f-2bbdfd54329a/_tmp_space.db > 17/06/01 13:03:27 INFO HiveSessionImpl: Operation log session directory is created: /tmp/hduser/operation_logs/addaba65-46c5-4467-a02f-2bbdfd54329a > 17/06/01 13:03:27 INFO CarbonSparkSqlParser: Parsing command: use default > Exception in thread "HiveServer2-Handler-Pool: Thread-84" java.lang.ExceptionInInitializerError > at org.apache.spark.sql.hive.CarbonSessionState$$anon$1.<init>(CarbonSessionState.scala:133) > at org.apache.spark.sql.hive.CarbonSessionState.analyzer$lzycompute(CarbonSessionState.scala:128) > at org.apache.spark.sql.hive.CarbonSessionState.analyzer(CarbonSessionState.scala:127) > at org.apache.spark.sql.execution.QueryExecution.assertAnalyzed(QueryExecution.scala:48) > at org.apache.spark.sql.Dataset$.ofRows(Dataset.scala:63) > at org.apache.spark.sql.SparkSession.sql(SparkSession.scala:592) > at org.apache.spark.sql.SQLContext.sql(SQLContext.scala:699) > at org.apache.spark.sql.hive.thriftserver.SparkSQLSessionManager.openSession(SparkSQLSessionManager.scala:83) > at org.apache.hive.service.cli.CLIService.openSessionWithImpersonation(CLIService.java:202) > at org.apache.hive.service.cli.thrift.ThriftCLIService.getSessionHandle(ThriftCLIService.java:351) > at org.apache.hive.service.cli.thrift.ThriftCLIService.OpenSession(ThriftCLIService.java:246) > at org.apache.hive.service.cli.thrift.TCLIService$Processor$OpenSession.getResult(TCLIService.java:1253) > at org.apache.hive.service.cli.thrift.TCLIService$Processor$OpenSession.getResult(TCLIService.java:1238) > 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:286) > at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) > at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) > at java.lang.Thread.run(Thread.java:745) > Caused by: java.lang.NullPointerException > at org.apache.spark.sql.hive.CarbonIUDAnalysisRule$.<init>(CarbonAnalysisRules.scala:90) > at org.apache.spark.sql.hive.CarbonIUDAnalysisRule$.<clinit>(CarbonAnalysisRules.scala) > ... 20 more -- This message was sent by Atlassian JIRA (v6.3.15#6346) |
Free forum by Nabble | Edit this page |