当前位置: 首页 > 知识库问答 >
问题:

将表加载到DF时,Spark 2.2.0无法连接到Phoenix 4.11.0版本

柯冯浩
2023-03-14

所有运行在同一主机上的技术堆栈:

Apache Spark 2.2.0版本

Hbase 1.2版本

from pyspark import SparkContext, SparkConf
from pyspark.sql import SQLContext

conf = SparkConf().setAppName("pysparkPhoenixLoad").setMaster("local")
sc = SparkContext(conf=conf)
sqlContext = SQLContext(sc)

df = sqlContext.read.format("org.apache.phoenix.spark").option("table", 
"schema.table1").option("zkUrl", "localhost:2181").load()
df.show()

18/07/30 12:28:15警告hbaseConfiguration:已不推荐配置选项“hbase.regionserver.lease.period”。而是使用“hbase.client.scanner.timeout.period”

18/07/30 12:28:54 INFO rpcretryingcaller:调用异常,tries=10,retries=35,started=38367 ms前,cancelled=false,msg=row'system:catalog,,'on table'hbase:meta,at region=hbase:meta,,1.1588230740,hostname=master01,16020,1532591192223,seqnum=0

共有1个答案

全冥夜
2023-03-14

看看这些答案:

  • Phoenix jdbc不工作,没有异常和卡住
  • HBase Java客户端-未知主机:localhost.localdomain

这两个问题都发生在Java(使用JDBC)中,但在这里看起来是一个类似的问题。

127.0.0.1    master01
 类似资料:
  • 问题内容: 我已经在RHEL7上安装了ES 7.5和Kibana 7.5,但是在启动Kibana并检查UI后,我看到了错误,“ Kibana服务器尚未准备好。” 检查Kibana日志,我发现它没有正确连接到ES。任何帮助表示赞赏! 这是 journalctl –unit kibana 的输出: Elasticsearch.yml Kibana.yml 另外,当我运行 ss -tunlp | gre

  • 我已经在RHEL7上安装了ES 7.5和Kibana 7.5,但是在启动Kibana并检查UI之后,我看到了错误,“Kibana服务器还没有准备好。” 检查Kibana日志,我看到它没有正确连接到ES。感谢任何帮助! 以下是journalctl的输出——单位kibana: 弹性搜索。yml 基巴纳。yml 此外,当我在Kibana启动期间运行ss-tunlp|grep 5601时,我看到Kiban

  • 我正在尝试将MySQL数据库连接到XAMPP。每当我尝试在XAMPP上按start MySQL时,它都不会运行,我会得到一个错误: 这是因为我的病毒防护软件或VPN吗?我将如何更改MySQL和控制面板中的端口?如果有人能给我一些建议或指导我回答与此类似的已回答问题,将不胜感激。谢谢你。

  • 我有一个Debezium连接器,连接到SQL服务器,其中一个表在配置参数中。我想添加另一个表,我已经添加到参数中,尽管我的连接器没有接收到它。 我以前的看起来像这样: 我当前的如下所示: 我重启了Kafka,重启了Debezium中的连接器,但是当我查看bash中的连接器状态时,我仍然看到旧的值。是否需要做其他事情来让连接器刷新配置文件中的内容? Debezium版本:1.2.5。Kafka最终版

  • 问题内容: 事实证明,这是对python的粗略过渡。这里发生了什么?: 输出文件如下所示: 然后我得到这个错误: 问题答案: 返回一个字节串。 在Python 3中,unicode()对象与对象之间没有隐式转换。如果您知道输出的编码,则可以使用它来获取字符串,也可以将要添加的内容转换为

  • null 错误:SQL异常:java.SQL.sqlexception:找不到适合JDBC的驱动程序:mariadb://localhost:3306/customer构建成功(总时间:3秒)