2017-06-19 2 views
1

私のコード読み取りが失敗しました:エラーが発生した火花シェルでスパークSQLはHDFSからJSONファイルは、このような

val sqlContext = new org.apache.spark.sql.hive.HiveContext(sc) 
import sqlContext.implicits._ 
val customers = sqlContext.read.json("jsonfilepath") 

を、私はこれを理解することはできません:?

17/06/19 09:59:04 ERROR bonecp.PoolWatchThread: Error in trying to obtain a connection. Retrying in 7000ms 
java.sql.SQLException: A read-only user or a user in a read-only database is not permitted to disable read-only mode on a connection. 
     at org.apache.derby.impl.jdbc.SQLExceptionFactory.getSQLException(Unknown Source) 
     at org.apache.derby.impl.jdbc.Util.generateCsSQLException(Unknown Source) 
     at org.apache.derby.impl.jdbc.TransactionResourceImpl.wrapInSQLException(Unknown Source) 
     at org.apache.derby.impl.jdbc.TransactionResourceImpl.handleException(Unknown Source) 
     at org.apache.derby.impl.jdbc.EmbedConnection.handleException(Unknown Source) 
     at org.apache.derby.impl.jdbc.EmbedConnection.setReadOnly(Unknown Source) 
     at com.jolbox.bonecp.ConnectionHandle.setReadOnly(ConnectionHandle.java:1324) 
     at com.jolbox.bonecp.ConnectionHandle.<init>(ConnectionHandle.java:262) 
     at com.jolbox.bonecp.PoolWatchThread.fillConnections(PoolWatchThread.java:115) 
     at com.jolbox.bonecp.PoolWatchThread.run(PoolWatchThread.java:82) 
     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: ERROR 25505: A read-only user or a user in a read-only database is not permitted to disable read-only mode on a connection. 
     at org.apache.derby.iapi.error.StandardException.newException(Unknown Source) 
     at org.apache.derby.iapi.error.StandardException.newException(Unknown Source) 
     at org.apache.derby.impl.sql.conn.GenericAuthorizer.setReadOnlyConnection(Unknown Source) 
     at org.apache.derby.impl.sql.conn.GenericLanguageConnectionContext.setReadOnly(Unknown Source) 
     ... 8 more 

私はそれを解決するにはどうすればよいのおかげ

+0

エラーメッセージが明確に私はハイブ使用HiveContextにデータを保存するデータベース –

答えて

0

なぜHiveContextを使用してjsonデータを読み取っていますか?

代わりにSOLContextを使用してください。

val sqlContext = new org.apache.spark.sql.SQLContext(sc) 
import sqlContext.implicits._ 
val customers = sqlContext.read.json("jsonfilepath") 
+0

のパーミッションを変更する必要があると言う、SQLContextは私の作品 – shaojie

関連する問題