首页 文章

无法使用HANA Studio创建虚拟表

提问于
浏览
0

在带有Spark Controller 1.6 PL1的MapR 5.1 / Spark 1.5.2上的SAP HANA Vora 1.2中:

我已经配置了Spark Controller并启动了服务器 . 成功加载表格,可以从VORA工具中看到 .

在SAP HANA Studio中,我可以看到我创建的文件夹“spark_velocity”和“M_JCUST” . 当我尝试添加此表时,我的HANA文件夹中包含“添加为虚拟表”选项,我收到错误消息:

SAP DBTech JDBC: [476]: invalid remote object name: 
Unable to retrieve remote metadata for 
SparkSQL.spark_velocity.SparkSQL.spark_velocity.M_JCUST: line 0 col 0 (at pos 0)

/ var / log / hanaes如下:

16/11/01 20:11:37 INFO Utils:释放缓冲区16/11/01 20:11:37 INFO DefaultSource:使用现有目录表创建VoraRelation M_JCUST 16/11/01 20:11:37 INFO Utils :释放缓冲区16/11/01 20:11:37错误HanaVoraCatalog:查找关系中发生异常java.lang.ClassCastException:org.apache.spark.sql.sources.BaseRelationSource无法强制转换为org.apache.spark.sq位于org.apache.spark.sql.hive.hana.CompositeCatalog $ class.getTableRelation(HanaDBCatalog.scala)的org.apache.spark.sql.vora.hana.HanaVoraCatalog.getTableRelation(HanaVoraCatalog.scala:27)中的l.sources.BaseRelation :99)org.apache.spark.sql.hive.hana.HanaSimpleCatalog.getTableRelation(SparkCatalog.scala:44)at org.apache.spark.sql.hive.hana.HanaSQLContext.getTableMetaNew(HanaSQLContext.scala:337)at at com.sap.hana.spark.network.CommandHandler.handleMessage(CommandRouter.scala:516)at com.sap.hana.spark.network.CommandHandler $$ anonfun $ receive $ 2 $$ anon $ 1.run(CommandRouter.scala:272) )在com.sap.hana.spark.n etwork.CommandHandler $$ anonfun $在javax.security.auth.Subject.doAs上的java.security.AccessController.doPrivileged(Native Method)收到$ 2 $$ anon $ 1.run(CommandRouter.scala:270)(Subject.java:360 )atg.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1575)at comkap.hana.spark.network.CommandHandler $$ anonfun $ receive $ 2.applyOrElse(CommandRouter.scala:270)at akka . actor.Actor $ class.aroundReceive(Actor.scala:467)at com.ap.hana.spark.network.CommandHandler.aroundReceive(CommandRouter.scala:231)at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) at akka.actor.ActorCell.invoke(ActorCell.scala:487)at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:238)at akka.dispatch.Mailbox.run(Mailbox.scala:220)at akka.dispatch . ForkJoinExecutorConfigurator $ AkkaForkJoinTask.exec(AbstractDispatcher.scala:397)at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260):16/11/01 20:11:37 ERROR CommandHandler:java.lang.NullPointerException at org .apache . spark.sql.hive.hana.HanaSQLContext.getTableMetaNew(HanaSQLContext.scala:347)at com.sap.hana.spark.network.CommandHandler.handleMessage(CommandRouter.scala:516)at com.sap.hana.spark.network . CommandHandler $$ anonfun $ com.sap.hana.spark.network.CommandHandler $$ anonfun $ receive $ 2 $$ $ 1.run(CommandRouter.scala:270 )在org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1575)的javax.security.auth.Subject.doAs(Subject.java:360)的java.security.AccessController.doPrivileged(Native Method)中com.sap.hana.spark.network.CommandHandler $$ anonfun $在com.sap.hana的akka.actor.Actor $ class.aroundReceive(Actor.scala:467)收到$ 2.applyOrElse(CommandRouter.scala:270) . spark.network.CommandHandler.aroundReceive(CommandRouter.scala:231)at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516)at akka.actor.ActorCell.invoke(ActorCell.scala:487)at akka.dispatch.Mailbox .processMailbox(Mailbox.scala:238)at akka.dispatch.Mai lbox.run(Mailbox.scala:220)at akka.dispatch.ForkJoinExecutorConfigurator $ AkkaForkJoinTask.exec(AbstractDispatcher.scala:397)at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)at scala.concurrent.forkjoin .ForkJoinPool $ WorkQueue.runTask(ForkJoinPool.java:1339)scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)16 / 11 / 01 20:11:37 ERROR RequestOrchestrator:java.lang.NullPointerException,位于com.sap.hana.spark.network.CommandHandler的org.apache.spark.sql.hive.hana.HanaSQLContext.getTableMetaNew(HanaSQLContext.scala:347) .handleMessage(CommandRouter.scala:516)在com.sap.hana.spark.network.CommandHandler $$ anonfun $在com.sap.hana.spark.network收到$ 2 $$ anon $ 1.run(CommandRouter.scala:272) .CommandHandler $$ anonfun $在javax.security.auth.Subject.doAs(Subjec)的java.security.AccessController.doPrivileged(Native Method)收到$ 2 $$ anon $ 1.run(CommandRouter.scala:270) t.java:360)at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1575)at com.ap.hana.spark.network.CommandHandler $$ anonfun $ receive $ 2.applyOrElse(CommandRouter.scala:270)at akka.actor .Actor $ class.aroundReceive(Actor.scala:467)at com . akka.actor.ActorCell.receiveMessage(ActorCell.scala:516位于akka.dispatch.Mail上的akka.dispatch.Mailbox.processMailbox(Mailbox.scala:238)中的akka.actor.ActorCell.invoke(ActorCell.scala:487)akka.dispatch.Mailbox.run(Mailbox.scala:220)at akka.dispatch.ForkJoinExecutorConfigurator $ scka.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)上的scala.concurrent.forkjoin.ForkJoinPool $ WorkQueue.runTask(ForkJoinPool.java:1339)中的$ AkkaForkJoinTask.exec(AbstractDispatcher.scala:397) . concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)

此问题与以下发布的问题相同:SAP HANA Vora 1.2 : Cannot load as virtual table in HANA Studio

但是,我使用SAP HANA SPS12,Spark Controller 1.6 PL1和MapR支持,并正确地替换了spark-sap-datasources-1.2.33-assembly.jar .

有关此错误的任何建议吗?

谢谢并问候法力

1 回答

  • 1

    由于Spark Controller 1.6.1 PL1和Spark 1.5.2之间不兼容,这是一个已知问题 . 目前计划在下一个Spark Controller版本中解决此问题(Subject to change)

相关问题