Создайте искровое соединение Apache с БД Oracle с помощью JDBC.JAVA

Программисты JAVA общаются здесь
Ответить
Anonymous
 Создайте искровое соединение Apache с БД Oracle с помощью JDBC.

Сообщение Anonymous »

Я пытаюсь создать соединение с тестовым сервером Oracle моей компании с помощью Apache Spark и Scala. Ниже приведен оператор, который я запускаю в искровой оболочке. Я использую JDK 8 и установил соответствующий драйвер jdbc в каталог jar искры.
Синтаксис моего URL-адреса или других конфигураций выглядит неверным?
Означает ли сообщение об ошибке внизу что-то более полезное, чем «Сетевой адаптер не смог установить соединение».
scala> val user =
scala> val password =

val jdbc = spark.read.format("jdbc").option("url","jdbc:oracle:thin:@(DESCRIPTION =(ADDRESS = (PROTOCOL = TCP)(HOST =)(PORT = 1521))(LOAD_BALANCE = YES)(FAILOVER = YES)(SERVER = DEDICATED)(CONNECT_DATA = (SERVICE_NAME = )(FAILOVER_MODE =(TYPE = SELECT)(METHOD = BASIC)(RETRIES = 180)(DELAY = 5))))").option("driver", "oracle.jdbc.driver.OracleDriver").option("query","select * from realmed.office_user_status_type").option("user",username).option("password",password).load()


при выполнении приведенной выше команды создается впечатление, что она пытается подключиться в течение минуты или около того, а затем возвращает следующую ошибку
java.sql.SQLRecoverableException: ORA-17820: The network adapter could not establish the connection. (CONNECTION_ID=QDew7TDmTtecLW0yGr39SA==)
https://docs.oracle.com/error-help/db/ora-17820/
at oracle.jdbc.driver.T4CConnection.handleLogonNetException(T4CConnection.java:1382)
at oracle.jdbc.driver.T4CConnection.logon(T4CConnection.java:975)
at oracle.jdbc.driver.PhysicalConnection.connect(PhysicalConnection.java:1126)
at oracle.jdbc.driver.T4CDriverExtension.getConnection(T4CDriverExtension.java:104)
at oracle.jdbc.driver.OracleDriver.connect(OracleDriver.java:825)
at oracle.jdbc.driver.OracleDriver.connect(OracleDriver.java:651)
at org.apache.spark.sql.execution.datasources.jdbc.connection.BasicConnectionProvider.getConnection(BasicConnectionProvider.scala:49)
at org.apache.spark.sql.execution.datasources.jdbc.connection.ConnectionProviderBase.create(ConnectionProvider.scala:102)
at org.apache.spark.sql.jdbc.JdbcDialect.$anonfun$createConnectionFactory$1(JdbcDialects.scala:160)
at org.apache.spark.sql.jdbc.JdbcDialect.$anonfun$createConnectionFactory$1$adapted(JdbcDialects.scala:156)
at org.apache.spark.sql.execution.datasources.jdbc.JDBCRDD$.getQueryOutputSchema(JDBCRDD.scala:63)
at org.apache.spark.sql.execution.datasources.jdbc.JDBCRDD$.resolveTable(JDBCRDD.scala:58)
at org.apache.spark.sql.execution.datasources.jdbc.JDBCRelation$.getSchema(JDBCRelation.scala:241)
at org.apache.spark.sql.execution.datasources.jdbc.JdbcRelationProvider.createRelation(JdbcRelationProvider.scala:37)
at org.apache.spark.sql.execution.datasources.DataSource.resolveRelation(DataSource.scala:346)
at org.apache.spark.sql.DataFrameReader.loadV1Source(DataFrameReader.scala:229)
at org.apache.spark.sql.DataFrameReader.$anonfun$load$2(DataFrameReader.scala:211)
at scala.Option.getOrElse(Option.scala:201)
at org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:211)
at org.apache.spark.sql.DataFrameReader.load(DataFrameReader.scala:172)
... 42 elided
Caused by: oracle.net.ns.NetException: ORA-17820: The network adapter could not establish the connection. (CONNECTION_ID=QDew7TDmTtecLW0yGr39SA==)
https://docs.oracle.com/error-help/db/ora-17820/
at oracle.net.nt.ConnStrategy.execute(ConnStrategy.java:769)
at oracle.net.resolver.AddrResolution.resolveAndExecute(AddrResolution.java:707)
at oracle.net.ns.NSProtocol.establishConnection(NSProtocol.java:938)
at oracle.net.ns.NSProtocol.establishConnection(NSProtocol.java:911)
at oracle.net.ns.NSProtocolNIO.redirectConnection(NSProtocolNIO.java:525)
at oracle.net.ns.NSProtocolNIO.handleConnectPacketResponse(NSProtocolNIO.java:447)
at oracle.net.ns.NSProtocolNIO.negotiateConnection(NSProtocolNIO.java:268)
at oracle.net.ns.NSProtocol.connect(NSProtocol.java:331)
at oracle.jdbc.driver.T4CConnection.connectNetworkSessionProtocol(T4CConnection.java:2947)
at oracle.jdbc.driver.T4CConnection.logon(T4CConnection.java:910)
... 60 more



Подробнее здесь: https://stackoverflow.com/questions/783 ... -with-jdbc
Ответить

Быстрый ответ

Изменение регистра текста: 
Смайлики
:) :( :oops: :roll: :wink: :muza: :clever: :sorry: :angel: :read: *x)
Ещё смайлики…
   
К этому ответу прикреплено по крайней мере одно вложение.

Если вы не хотите добавлять вложения, оставьте поля пустыми.

Максимально разрешённый размер вложения: 15 МБ.

Вернуться в «JAVA»