感谢您对以下查询的回复。
我在 vora 中创建了几个表(例如测试、地址)。我能够看到这些表的列表SHOW DATASOUCE
并查询它们。后来我重新启动了vora实例并以vora用户身份重新登录并启动了vora spark shell。我知道我不会在新 shell 中看到这个表,因为它不会出现在新的 spark 上下文中。但是我遇到了一些链接,它说
<ClusterUtils.markAllHostsAsFailed()>
将从元数据加载 vora spark 上下文中的所有表,但是尽管执行了以下一系列命令
scala> import org.apache.spark.sql._
import org.apache.spark.sql._
scala> val SapSqlSc = new SapSQLContext(sc)
scala> import com.sap.spark.vora.client
import com.sap.spark.vora.client
scala> client.ClusterUtils.markAllHostsAsFailed()
scala> SapSqlSc.sql(s"""
| SHOW DATASOURCETABLES
| USING com.sap.spark.vora
| OPTIONS
| (
| zkUrls "ip-x-x-x-1.ec2.internal:2181,ip-x-x-x-2.ec2.internal:2181",
| namenodeurl "ip-x-x-x-1.ec2.internal:8020"
| )
| """.stripMargin).collect
我得到以下错误和异常
16/03/04 11:56:24 ERROR Datastore.Schema: Failed initialising database.
Failed to start database 'metastore_db' with class loader org.apache.spark.sql.hive.client.IsolatedClientLoader$$anon$1@3d3efa54, see the next exception for details.
:
:
Caused by: java.sql.SQLException: Failed to start database 'metastore_db' with class loader org.apache.spark.sql.hive.client.IsolatedClientLoader $$anon$1@3d3efa54, see the next exception for details.at org.apache.derby.impl.jdbc.SQLExceptionFactory40.getSQLException(Unknown Source)
at org.apache.derby.impl.jdbc.Util.newEmbedSQLException(Unknown Source)