hbaseでスパークを接続する方法

接続中に問題が発生しています。hbaseでスパークを接続する方法

scala> val results = sql("SELECT * FROM tablename"); 
results: org.apache.spark.sql.DataFrame = [hbid: string, matrix_col: string, matrix_value_col: double, country_col: string] 

scala> results.show();

org.apache.hadoop.hbase.client.RetriesExhaustedException：ヌル火7月25日10時03分27秒SGT 2017、java.net.SocketTimeoutException：試み= 36、例外の後に失敗しました： callTimeout = 60000、 callDuration = 68549：行 'nrd_app_spt：capacity_new ,, 00000000000000' on テーブル 'hbase：meta' at region = hbase：meta ,, 1.1588230740、 hostname = x01shdpeapp3a.sgp.dbs.com、60020,1500273862255 、seqNum = 0 原因：java.net.SocketTimeoutException：callTimeout = 60000、callDuration = 68549：行 'nrd_app_spt：capacity_new ,, 00000000000000' on テーブル 'hbase：meta' at region = hbase：meta ,, 1.1588230740、 hostname = x01shdpeapp3a.sgp.dbs.com、60020,1500273862255、seqNum = 0 原因：org.apache.hadoop.hbase.exceptions.ConnectionClosingException ： org.apache.hadoop.hbase.exceptions.ConnectionClosingException：x01shdpeapp3a.sgp.dbs.com/10.92.139.145へ接続 x01shdpeapp3a.sgp.dbs.com/10.92.139.145:60020にコールすると、ローカル例外で失敗しました：60020はです。コールID = 9、waitTime = 3

出典

2017-08-01 Gayathri Devi

私はHBaseのテーブルを読みたいといくつかの組み込み関数を実行します。HBaseの-site.xmlの中に

<property> <name>zookeeper.znode.parent</name> <value>/hbase-unsecure</value> </property>

変更を次のプロパティを変更することで解決の問題。スカラーはクエリを書くのに十分ですか？ –

SparkからHbaseに接続するときに同様の問題が発生しました。

<property> 
     <name>zookeeper.znode.parent</name> 
     <value>/hbase</value> 
</property>

出典

2017-08-01 10:44:52

ありがとうございます。あなたにpingを試みます。 [email protected]にメールすることができます。 –

hbaseでスパークを接続する方法

答えて

関連する問題