Advertisement
Guest User

Untitled

a guest
Jul 21st, 2016
119
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 5.34 KB | None | 0 0
  1. val dataFrame = sqlContext.read.format("jdbc").options(Map(
  2. "url" -> "jdbc:postgresql://<IP_Adress>:<Port>/<Database>?user=<Username>&password=<Password>",
  3. "dbtable" -> "table",
  4. "driver" -> "org.postgresql.Driver"
  5. )).load()
  6.  
  7. org.postgresql.util.PSQLException: Connection to <...> refused. Check that the hostname and port are correct and that the postmaster is accepting TCP/IP connections.
  8. at org.postgresql.core.v3.ConnectionFactoryImpl.openConnectionImpl(ConnectionFactoryImpl.java:270)
  9. at org.postgresql.core.ConnectionFactory.openConnection(ConnectionFactory.java:67)
  10. at org.postgresql.jdbc.PgConnection.<init>(PgConnection.java:212)
  11. at org.postgresql.Driver.makeConnection(Driver.java:407)
  12. at org.postgresql.Driver.connect(Driver.java:275)
  13. at org.apache.spark.sql.execution.datasources.jdbc.JdbcUtils$$anonfun$createConnectionFactory$2.apply(JdbcUtils.scala:61)
  14. at org.apache.spark.sql.execution.datasources.jdbc.JdbcUtils$$anonfun$createConnectionFactory$2.apply(JdbcUtils.scala:52)
  15. at org.apache.spark.sql.execution.datasources.jdbc.JDBCRDD$.resolveTable(JDBCRDD.scala:120)
  16. at org.apache.spark.sql.execution.datasources.jdbc.JDBCRelation.<init>(JDBCRelation.scala:91)
  17. at org.apache.spark.sql.execution.datasources.jdbc.DefaultSource.createRelation(DefaultSource.scala:57)
  18. at org.apache.spark.sql.execution.datasources.ResolvedDataSource$.apply(ResolvedDataSource.scala:158)
  19. at org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:119)
  20. at $iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC.readDataFromDatabase(<console>:72)
  21. at $iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:72)
  22. at $iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:98)
  23. at $iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:100)
  24. at $iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:102)
  25. at $iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:104)
  26. at $iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:106)
  27. at $iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:108)
  28. at $iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:110)
  29. at $iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:112)
  30. at $iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:114)
  31. at $iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:116)
  32. at $iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:118)
  33. at $iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:120)
  34. at $iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:122)
  35. at $iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:124)
  36. at $iwC$$iwC$$iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:126)
  37. at $iwC$$iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:128)
  38. at $iwC$$iwC$$iwC$$iwC$$iwC.<init>(<console>:130)
  39. at $iwC$$iwC$$iwC$$iwC.<init>(<console>:132)
  40. at $iwC$$iwC$$iwC.<init>(<console>:134)
  41. at $iwC$$iwC.<init>(<console>:136)
  42. at $iwC.<init>(<console>:138)
  43. at <init>(<console>:140)
  44. at .<init>(<console>:144)
  45. at .<clinit>(<console>)
  46. at .<init>(<console>:7)
  47. at .<clinit>(<console>)
  48. at $print(<console>)
  49. at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
  50. at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
  51. at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
  52. at java.lang.reflect.Method.invoke(Method.java:483)
  53. at org.apache.spark.repl.SparkIMain$ReadEvalPrint.call(SparkIMain.scala:1065)
  54. at org.apache.spark.repl.SparkIMain$Request.loadAndRun(SparkIMain.scala:1346)
  55. at org.apache.spark.repl.SparkIMain.loadAndRunReq$1(SparkIMain.scala:840)
  56. at org.apache.spark.repl.SparkIMain.interpret(SparkIMain.scala:871)
  57. at org.apache.spark.repl.SparkIMain.interpret(SparkIMain.scala:819)
  58. at notebook.kernel.Repl$$anonfun$6.apply(Repl.scala:200)
  59. at notebook.kernel.Repl$$anonfun$6.apply(Repl.scala:200)
  60. at scala.util.DynamicVariable.withValue(DynamicVariable.scala:57)
  61. at scala.Console$.withOut(Console.scala:126)
  62. at notebook.kernel.Repl.evaluate(Repl.scala:199)
  63. at notebook.client.ReplCalculator$$anonfun$10$$anon$1$$anonfun$27.replEvaluate$1(ReplCalculator.scala:401)
  64. at notebook.client.ReplCalculator$$anonfun$10$$anon$1$$anonfun$27.apply(ReplCalculator.scala:414)
  65. at notebook.client.ReplCalculator$$anonfun$10$$anon$1$$anonfun$27.apply(ReplCalculator.scala:395)
  66. at scala.concurrent.impl.Future$PromiseCompletingRunnable.liftedTree1$1(Future.scala:24)
  67. at scala.concurrent.impl.Future$PromiseCompletingRunnable.run(Future.scala:24)
  68. at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:40)
  69. at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:397)
  70. at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
  71. at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
  72. at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
  73. at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement