topic Re: Getting "socket closed" with query federation to Oracle DB on Amazon RDS in Data Engineering

Getting "socket closed" with query federation to Oracle DB on Amazon RDS

luketl2 — Wed, 28 Jan 2026 16:26:30 GMT

I am following this guide to connect to an Oracle DB in Amazon RDS: https://docs.databricks.com/aws/en/query-federation/oracle. I've created the connection, but when I go to test it, it loads for a while and then says "socket closed". From my understanding, this implies that the TCP session establishes (networking is fine) but immediately is closed by Oracle DB for whatever reason. I've gone through all the possibilities: we are using NNE, we checked and server-side NNE is at "REQUESTED" level (should be higher than "ACCEPTED"), we have stable egress IP and it is whitelisted on server side, and we have double-checked the service name. Not sure what else to do. Is there any way to get more info on the Databricks side? I tried checking driver logs but I did not see anything useful. Thanks

Re: Getting "socket closed" with query federation to Oracle DB on Amazon RDS

Saritha_S — Tue, 03 Feb 2026 10:28:43 GMT

Hi @luketl2 Could you please provide us the complete stack trace?

Re: Getting "socket closed" with query federation to Oracle DB on Amazon RDS

luketl2 — Tue, 03 Feb 2026 15:34:21 GMT

A few notes: we know that my IP from the cluster I am testing on is whitelisted, and I have run nc -vz to their IP and port and it returns "open," so I am confident we establish tcp. Nothing in stderr on driver, but here is what I see in log4j:

26/02/03 15:19:41 INFO ClusterLoadMonitor: Removed query with execution ID:9. Current active queries:0

26/02/03 15:19:41 INFO SQLExecution: 0 QueryExecution(s) are running

26/02/03 15:19:41 INFO CurrentQueryContext: Thread Thread[WRAPPER-ReplId-19c23-fe347-5,5,main]: current category Some(EXECUTABLE_COMMAND), restoring to previous category Some(UNDETERMINED).

26/02/03 15:19:41 ERROR SQLDriverLocal: Error in SQL query: -- This is a system generated query from catalog explorer

CREATE FOREIGN CATALOG `foreign_data` USING CONNECTION `foreign_db` OPTIONS (service_name 'db_a', test_catalog 'true')

org.apache.spark.SparkIllegalArgumentException: [CANNOT_ESTABLISH_CONNECTION] Cannot establish connection to remote ORACLE database. Please check connection information and credentials e.g. host, port, user, password and database options. ** If you believe the information is correct, please check your workspace's network setup and ensure it does not have outbound restrictions to the host. Please also check that the host does not block inbound connections from the network where the workspace's Spark clusters are deployed. ** Detailed error message: ORA-17002: I/O error: Socket read interrupted, Authentication lapse 0 ms.

https://docs.oracle.com/error-help/db/ora-17002/. SQLSTATE: 08001

at org.apache.spark.sql.errors.QueryExecutionErrors$.cannotEstablishConnectionError(QueryExecutionErrors.scala:1278)

at org.apache.spark.sql.execution.datasources.jdbc.JDBCDialectTestConnection.testCatalogConnection(JDBCTestConnection.scala:86)

at com.databricks.sql.managedcatalog.command.QueryFederationCommand$.testCatalogConnection(queryFederationCommandsExec.scala:153)

at com.databricks.sql.managedcatalog.command.TestForeignCatalogConnectionCommand.run(queryFederationCommandsExec.scala:302)

at org.apache.spark.sql.execution.command.ExecutedCommandExec.$anonfun$sideEffectResult$2(commands.scala:84)

at org.apache.spark.sql.execution.SparkPlan.runCommandInAetherOrSpark(SparkPlan.scala:194)

at org.apache.spark.sql.execution.command.ExecutedCommandExec.$anonfun$sideEffectResult$1(commands.scala:84)

at com.databricks.spark.util.FrameProfiler$.record(FrameProfiler.scala:94)

at org.apache.spark.sql.execution.command.ExecutedCommandExec.sideEffectResult$lzycompute(commands.scala:81)

at org.apache.spark.sql.execution.command.ExecutedCommandExec.sideEffectResult(commands.scala:80)

at org.apache.spark.sql.execution.command.ExecutedCommandExec.executeCollect(commands.scala:94)

at org.apache.spark.sql.execution.QueryExecution.$anonfun$eagerlyExecuteCommands$5(QueryExecution.scala:553)

at com.databricks.util.LexicalThreadLocal$Handle.runWith(LexicalThreadLocal.scala:63)

at org.apache.spark.sql.execution.QueryExecution.$anonfun$eagerlyExecuteCommands$4(QueryExecution.scala:553)

at org.apache.spark.sql.catalyst.QueryPlanningTracker$.withTracker(QueryPlanningTracker.scala:233)

at org.apache.spark.sql.execution.QueryExecution.$anonfun$eagerlyExecuteCommands$3(QueryExecution.scala:552)

at org.apache.spark.sql.execution.SQLExecution$.$anonfun$withNewExecutionId0$11(SQLExecution.scala:486)

at com.databricks.sql.util.MemoryTrackerHelper.withMemoryTracking(MemoryTrackerHelper.scala:80)

at org.apache.spark.sql.execution.SQLExecution$.$anonfun$withNewExecutionId0$10(SQLExecution.scala:422)

at org.apache.spark.sql.execution.SQLExecution$.withSQLConfPropagated(SQLExecution.scala:810)

at org.apache.spark.sql.execution.SQLExecution$.$anonfun$withNewExecutionId0$1(SQLExecution.scala:352)

at org.apache.spark.sql.SparkSession.withActive(SparkSession.scala:1481)

at org.apache.spark.sql.execution.SQLExecution$.withNewExecutionId0(SQLExecution.scala:217)

at org.apache.spark.sql.execution.SQLExecution$.withNewExecutionId(SQLExecution.scala:747)

at org.apache.spark.sql.execution.QueryExecution.$anonfun$eagerlyExecuteCommands$2(QueryExecution.scala:548)

at org.apache.spark.sql.execution.QueryExecution$.withInternalError(QueryExecution.scala:1426)

at org.apache.spark.sql.execution.QueryExecution.$anonfun$eagerlyExecuteCommands$1(QueryExecution.scala:544)

at org.apache.spark.sql.execution.QueryExecution.withMVTagsIfNecessary(QueryExecution.scala:473)

at org.apache.spark.sql.execution.QueryExecution.org$apache$spark$sql$execution$QueryExecution$$eagerlyExecute$1(QueryExecution.scala:542)

at org.apache.spark.sql.execution.QueryExecution$$anonfun$$nestedInanonfun$eagerlyExecuteCommands$8$1.applyOrElse(QueryExecution.scala:621)

at org.apache.spark.sql.execution.QueryExecution$$anonfun$$nestedInanonfun$eagerlyExecuteCommands$8$1.applyOrElse(QueryExecution.scala:616)

at org.apache.spark.sql.catalyst.trees.TreeNode.$anonfun$transformDownWithPruning$1(TreeNode.scala:521)

at org.apache.spark.sql.catalyst.trees.CurrentOrigin$.withOrigin(origin.scala:85)

at org.apache.spark.sql.catalyst.trees.TreeNode.transformDownWithPruning(TreeNode.scala:521)

at org.apache.spark.sql.catalyst.plans.logical.LogicalPlan.org$apache$spark$sql$catalyst$plans$logical$AnalysisHelper$$super$transformDownWithPruning(LogicalPlan.scala:42)

at org.apache.spark.sql.catalyst.plans.logical.AnalysisHelper.transformDownWithPruning(AnalysisHelper.scala:361)

at org.apache.spark.sql.catalyst.plans.logical.AnalysisHelper.transformDownWithPruning$(AnalysisHelper.scala:357)

at org.apache.spark.sql.catalyst.plans.logical.LogicalPlan.transformDownWithPruning(LogicalPlan.scala:42)

at org.apache.spark.sql.catalyst.trees.TreeNode.transformDown(TreeNode.scala:497)

at org.apache.spark.sql.execution.QueryExecution.$anonfun$eagerlyExecuteCommands$8(QueryExecution.scala:616)

at org.apache.spark.sql.catalyst.plans.logical.AnalysisHelper$.allowInvokingTransformsInAnalyzer(AnalysisHelper.scala:418)

at org.apache.spark.sql.execution.QueryExecution.eagerlyExecuteCommands(QueryExecution.scala:616)

at org.apache.spark.sql.execution.QueryExecution.$anonfun$lazyCommandExecuted$1(QueryExecution.scala:429)

at scala.util.Try$.apply(Try.scala:213)

at org.apache.spark.util.Utils$.doTryWithCallerStacktrace(Utils.scala:1684)

at org.apache.spark.util.Utils$.getTryWithCallerStacktrace(Utils.scala:1745)

at org.apache.spark.util.LazyTry.get(LazyTry.scala:58)

at org.apache.spark.sql.execution.QueryExecution.commandExecuted(QueryExecution.scala:434)

at org.apache.spark.sql.Dataset.<init>(Dataset.scala:406)

at org.apache.spark.sql.Dataset$.$anonfun$ofRows$3(Dataset.scala:150)

at org.apache.spark.sql.SparkSession.withActive(SparkSession.scala:1481)

at org.apache.spark.sql.SparkSession.$anonfun$withActiveAndFrameProfiler$1(SparkSession.scala:1488)

at com.databricks.spark.util.FrameProfiler$.record(FrameProfiler.scala:94)

at org.apache.spark.sql.SparkSession.withActiveAndFrameProfiler(SparkSession.scala:1488)

at org.apache.spark.sql.Dataset$.ofRows(Dataset.scala:141)

at org.apache.spark.sql.SparkSession.$anonfun$sql$4(SparkSession.scala:1161)

at org.apache.spark.sql.SparkSession.withActive(SparkSession.scala:1481)

at org.apache.spark.sql.SparkSession.sql(SparkSession.scala:1113)

at org.apache.spark.sql.SparkSession.sql(SparkSession.scala:1185)

at com.databricks.backend.daemon.driver.DriverLocal$DbClassicStrategy.executeSQLQuery(DriverLocal.scala:372)

at com.databricks.backend.daemon.driver.DriverLocal.executeSQLSubCommand(DriverLocal.scala:472)

at com.databricks.backend.daemon.driver.DriverLocal.$anonfun$executeSql$1(DriverLocal.scala:496)

at scala.collection.immutable.List.map(List.scala:293)

at com.databricks.backend.daemon.driver.DriverLocal.executeSql(DriverLocal.scala:491)

at com.databricks.backend.daemon.driver.SQLDriverLocal.repl(SQLDriverLocal.scala:39)

at com.databricks.backend.daemon.driver.DriverLocal.$anonfun$execute$36(DriverLocal.scala:1321)

at com.databricks.unity.UCSEphemeralState$Handle.runWith(UCSEphemeralState.scala:51)

at com.databricks.unity.HandleImpl.runWith(UCSHandle.scala:104)

at com.databricks.backend.daemon.driver.DriverLocal.$anonfun$execute$30(DriverLocal.scala:1312)

at com.databricks.logging.AttributionContextTracing.$anonfun$withAttributionContext$1(AttributionContextTracing.scala:49)

at com.databricks.logging.AttributionContext$.$anonfun$withValue$1(AttributionContext.scala:293)

at scala.util.DynamicVariable.withValue(DynamicVariable.scala:62)

at com.databricks.logging.AttributionContext$.withValue(AttributionContext.scala:289)

at com.databricks.logging.AttributionContextTracing.withAttributionContext(AttributionContextTracing.scala:47)

at com.databricks.logging.AttributionContextTracing.withAttributionContext$(AttributionContextTracing.scala:44)

at com.databricks.backend.daemon.driver.DriverLocal.withAttributionContext(DriverLocal.scala:130)

at com.databricks.logging.AttributionContextTracing.withAttributionTags(AttributionContextTracing.scala:96)

at com.databricks.logging.AttributionContextTracing.withAttributionTags$(AttributionContextTracing.scala:77)

at com.databricks.backend.daemon.driver.DriverLocal.withAttributionTags(DriverLocal.scala:130)

at com.databricks.backend.daemon.driver.DriverLocal.$anonfun$execute$1(DriverLocal.scala:1236)

at com.databricks.backend.daemon.driver.DriverLocal$.$anonfun$maybeSynchronizeExecution$4(DriverLocal.scala:1721)

at com.databricks.backend.daemon.driver.DriverLocal.execute(DriverLocal.scala:879)

at com.databricks.backend.daemon.driver.DriverWrapper.$anonfun$tryExecutingCommand$2(DriverWrapper.scala:1054)

at scala.util.Try$.apply(Try.scala:213)

at com.databricks.backend.daemon.driver.DriverWrapper.$anonfun$tryExecutingCommand$1(DriverWrapper.scala:1043)

at com.databricks.backend.daemon.driver.DriverWrapper.$anonfun$tryExecutingCommand$3(DriverWrapper.scala:1089)

at com.databricks.logging.UsageLogging.executeThunkAndCaptureResultTags$1(UsageLogging.scala:616)

at com.databricks.logging.UsageLogging.$anonfun$recordOperationWithResultTags$4(UsageLogging.scala:643)

at com.databricks.logging.AttributionContextTracing.$anonfun$withAttributionContext$1(AttributionContextTracing.scala:49)

at com.databricks.logging.AttributionContext$.$anonfun$withValue$1(AttributionContext.scala:293)

at scala.util.DynamicVariable.withValue(DynamicVariable.scala:62)

at com.databricks.logging.AttributionContext$.withValue(AttributionContext.scala:289)

at com.databricks.logging.AttributionContextTracing.withAttributionContext(AttributionContextTracing.scala:47)

at com.databricks.logging.AttributionContextTracing.withAttributionContext$(AttributionContextTracing.scala:44)

at com.databricks.backend.daemon.driver.DriverWrapper.withAttributionContext(DriverWrapper.scala:81)

at com.databricks.logging.AttributionContextTracing.withAttributionTags(AttributionContextTracing.scala:96)

at com.databricks.logging.AttributionContextTracing.withAttributionTags$(AttributionContextTracing.scala:77)

at com.databricks.backend.daemon.driver.DriverWrapper.withAttributionTags(DriverWrapper.scala:81)

at com.databricks.logging.UsageLogging.recordOperationWithResultTags(UsageLogging.scala:611)

at com.databricks.logging.UsageLogging.recordOperationWithResultTags$(UsageLogging.scala:519)

at com.databricks.backend.daemon.driver.DriverWrapper.recordOperationWithResultTags(DriverWrapper.scala:81)

at com.databricks.backend.daemon.driver.DriverWrapper.tryExecutingCommand(DriverWrapper.scala:1089)

at com.databricks.backend.daemon.driver.DriverWrapper.executeCommandAndGetError(DriverWrapper.scala:766)

at com.databricks.backend.daemon.driver.DriverWrapper.executeCommand(DriverWrapper.scala:859)

at com.databricks.backend.daemon.driver.DriverWrapper.$anonfun$runInnerLoop$1(DriverWrapper.scala:630)

at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:23)

at com.databricks.logging.AttributionContextTracing.$anonfun$withAttributionContext$1(AttributionContextTracing.scala:49)

at com.databricks.logging.AttributionContext$.$anonfun$withValue$1(AttributionContext.scala:293)

at scala.util.DynamicVariable.withValue(DynamicVariable.scala:62)

at com.databricks.logging.AttributionContext$.withValue(AttributionContext.scala:289)

at com.databricks.logging.AttributionContextTracing.withAttributionContext(AttributionContextTracing.scala:47)

at com.databricks.logging.AttributionContextTracing.withAttributionContext$(AttributionContextTracing.scala:44)

at com.databricks.backend.daemon.driver.DriverWrapper.withAttributionContext(DriverWrapper.scala:81)

at com.databricks.backend.daemon.driver.DriverWrapper.runInnerLoop(DriverWrapper.scala:625)

at com.databricks.backend.daemon.driver.DriverWrapper.runInner(DriverWrapper.scala:548)

at com.databricks.backend.daemon.driver.DriverWrapper.run(DriverWrapper.scala:373)

at java.base/java.lang.Thread.run(Thread.java:840)

Suppressed: org.apache.spark.util.Utils$OriginalTryStackTraceException: Full stacktrace of original doTryWithCallerStacktrace caller