Advertisement
Guest User

Untitled

a guest
Oct 6th, 2017
76
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 3.66 KB | None | 0 0
  1. [hadoop@[SNIP] ~]$ SPARK_PRINT_LAUNCH_COMMAND=1 spark-shell --driver-class-path ~/postgresql-42.0.0.jar
  2. Spark Command: /etc/alternatives/jre/bin/java -cp /home/hadoop/postgresql-42.0.0.jar:/usr/lib/spark/conf/:/usr/lib/spark/jars/*:/etc/hadoop/conf/ -Dscala.usejavacp=true -Xmx640M -XX:+UseConcMarkSweepGC -XX:CMSInitiatingOccupancyFraction=70 -XX:MaxHeapFreeRatio=70 -XX:+CMSClassUnloadingEnabled -XX:OnOutOfMemoryError=kill -9 %p org.apache.spark.deploy.SparkSubmit --conf spark.driver.extraClassPath=/home/hadoop/postgresql-42.0.0.jar --class org.apache.spark.repl.Main --name Spark shell spark-shell
  3. ========================================
  4. Setting default log level to "WARN".
  5. To adjust logging level use sc.setLogLevel(newLevel). For SparkR, use setLogLevel(newLevel).
  6. 17/02/28 17:17:52 WARN Client: Neither spark.yarn.jars nor spark.yarn.archive is set, falling back to uploading libraries under SPARK_HOME.
  7. 17/02/28 17:18:56 WARN ObjectStore: Failed to get database global_temp, returning NoSuchObjectException
  8. Spark context Web UI available at http://[SNIP]
  9. Spark context available as 'sc' (master = yarn, app id = application_1487878172787_0014).
  10. Spark session available as 'spark'.
  11. Welcome to
  12. ____ __
  13. / __/__ ___ _____/ /__
  14. _ / _ / _ `/ __/ '_/
  15. /___/ .__/_,_/_/ /_/_ version 2.1.0
  16. /_/
  17.  
  18. Using Scala version 2.11.8 (OpenJDK 64-Bit Server VM, Java 1.8.0_121)
  19. Type in expressions to have them evaluated.
  20. Type :help for more information.
  21.  
  22. scala> val loader = spark.read.format("jdbc") // connection options removed
  23. loader: org.apache.spark.sql.DataFrameReader = org.apache.spark.sql.DataFrameReader@46067a74
  24.  
  25. scala> loader.load
  26. java.sql.SQLException: No suitable driver
  27. at java.sql.DriverManager.getDriver(DriverManager.java:315)
  28. at org.apache.spark.sql.execution.datasources.jdbc.JDBCOptions$$anonfun$7.apply(JDBCOptions.scala:84)
  29. at org.apache.spark.sql.execution.datasources.jdbc.JDBCOptions$$anonfun$7.apply(JDBCOptions.scala:84)
  30. at scala.Option.getOrElse(Option.scala:121)
  31. at org.apache.spark.sql.execution.datasources.jdbc.JDBCOptions.<init>(JDBCOptions.scala:83)
  32. at org.apache.spark.sql.execution.datasources.jdbc.JDBCOptions.<init>(JDBCOptions.scala:34)
  33. at org.apache.spark.sql.execution.datasources.jdbc.JdbcRelationProvider.createRelation(JdbcRelationProvider.scala:32)
  34. at org.apache.spark.sql.execution.datasources.DataSource.resolveRelation(DataSource.scala:330)
  35. at org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:152)
  36. at org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:125)
  37. ... 48 elided
  38.  
  39. scala> loader.load
  40. res1: org.apache.spark.sql.DataFrame = [id: int, fsid: string ... 4 more fields]
  41.  
  42. import java.sql.DriverManager
  43. import com.vertica.jdbc.Driver
  44.  
  45.  
  46. val jdbcUsername = "<username>"
  47. val jdbcPassword = "<password>"
  48. val jdbcHostname = "<vertica server>"
  49. val jdbcPort = <vertica port>
  50. val jdbcDatabase ="<vertica DB>"
  51. val jdbcUrl = s"jdbc:vertica://${jdbcHostname}:${jdbcPort}/${jdbcDatabase}?user=${jdbcUsername}&password=${jdbcPassword}"
  52.  
  53. val connectionProperties = new Properties()
  54. connectionProperties.put("user", jdbcUsername)
  55. connectionProperties.put("password", jdbcPassword )
  56.  
  57. val connection = DriverManager.getConnection(jdbcUrl, connectionProperties)
  58. java.sql.SQLException: No suitable driver found for jdbc:vertica://${jdbcHostname}:${jdbcPort}/${jdbcDatabase}?user=${jdbcUsername}&password=${jdbcPassword}
  59.  
  60. at java.sql.DriverManager.getConnection(Unknown Source)
  61. at java.sql.DriverManager.getConnection(Unknown Source)
  62. ... 56 elided
  63.  
  64. scala> val connection = DriverManager.getConnection(jdbcUrl, connectionProperties)
  65. connection: java.sql.Connection = com.vertica.jdbc.VerticaJdbc4ConnectionImpl@7d994c
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement