D
Size: a a a
D
D
D
at org.apache.zeppelin.spark.SparkInterpreter.open(SparkInterpreter.java:98)
... 9 more
GP
S
at org.apache.zeppelin.spark.SparkInterpreter.open(SparkInterpreter.java:98)
... 9 more
S
D
at org.apache.zeppelin.scheduler.Job.run(Job.java:172)
at org.apache.zeppelin.scheduler.AbstractScheduler.runJob(AbstractScheduler.java:130)
at org.apache.zeppelin.scheduler.FIFOScheduler.lambda$runJobInScheduler$0(FIFOScheduler.java:39)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1130)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:630)
at java.base/java.lang.Thread.run(Thread.java:832)
D
D
D
GP
D
D
import java.util.Properties
val url = "jdbc:postgresql://<…>:5432/<…>”
val connectionProperties = new Properties()
connectionProperties.setProperty("Driver", "org.postgresql.Driver")
D
D
D
org.apache.zeppelin.interpreter.InterpreterException: org.apache.zeppelin.interpreter.InterpreterException: Fail to open SparkInterpreter
D
org.apache.zeppelin.interpreter.InterpreterException: org.apache.zeppelin.interpreter.InterpreterException: Fail to open SparkInterpreter
осталасьD
%spark
val query1 = "SELECT <…>”
// Class.forName("org.postgresql.Driver");
val query1df = spark.read.jdbc(url, query1, connectionProperties)
D
GP