BluemixでApache Sparkサービスを使用している私のpostgresql 8.4 dbに接続する際に問題があります。
私のコードは:
%AddJar https://jdbc.postgresql.org/download/postgresql-8.4-703.jdbc4.jar -f
val sqlContext = new org.apache.spark.sql.SQLContext(sc)
sqlContext.load("jdbc", Map("url" -> "jdbc:postgresql://<ip_address>:5432/postgres?
user=postgres&password=<password>", "dbtable" -> "table_name"))
そして、私はエラーを取得します:
名前:java.sql.SQLException
メッセージ:jdbc:postgresql://:5432 / postgres?user = postgres&password =
私は読んでいて、SparkクラスのパスにJDBCドライバを追加する必要があるようです.Bluemix Apache Sparkサービスでこれをどうやって行うのか分かりません。
回答:
回答№1は0現在、Bluemix Apache SparkにJDBCドライバを追加する際に問題があります。チームはそれを解決するために取り組んでいます。あなたはここで進歩に従うことができます: https://developer.ibm.com/answers/questions/248803/connecting-to-postgresql-db-using-jdbc-from-bluemi.html
回答№2の場合は0
おそらく見ている ここに?私は、load()関数がSpark 1.4では非推奨と考えています[ソース]。
代わりにこれを試すことができます
val url = "jdbc:postgresql://:5432/postgres"
val prop = new java.util.Properties
prop.setProperty("user","postgres")
prop.setProperty("password","xxxxxx")
val table = sqlContext.read.jdbc(url,"table_name",prop)
URLには完成したバージョンが必要な場合とない場合があります。
jdbc:postgresql://:5432 / postgres? ユーザー= postgres&パスワード=パスワード
回答№3の場合は0
これはBluemixの私のために働いた
%AddJar https://jdbc.postgresql.org/download/postgresql-9.4.1208.jar -f
val sqlContext =新しいorg.apache.spark.sql.SQLContext(sc);
( "url" - > "jdbc:postgresql://:/"、 "user" - > ""、 "password" - > ""、df = sqlContext.read.format( "jdbc" "dbtable" - > ""、 "driver" - > "org.postgresql.Driver"))。load()