oraclejava类。组织。阿帕奇。梁sdk。util。UserCodeException:java。sql。SQLException:无法创建PoolableConnectionFactory

Question

我使用java中的dataflow作业从Oracle中提取数据。在使用直接运行程序运行数据流作业时，我面临以下错误

jsonPayload：{ 异常：“java.lang.RuntimeException:org.apache.beam.sdk.util.UserCodeException:java.sql.SQLException:无法创建PoolableConnectionFactory（IO错误：网络适配器无法建立连接） 在com。谷歌。云数据流。工人IntrinsicMapTaskExecutorFactory$1。typedApply（IntrinsicMapTaskExecutorFactory.java:192） 在com。谷歌。云数据流。工人IntrinsicMapTaskExecutorFactory$1。typedApply（IntrinsicMapTaskExecutorFactory.java:163） 在com。谷歌。云数据流。工人图表网络$TypeSafeNodeFunction。apply（Networks.java:63） 在com。谷歌。云数据流。工人图表网络$TypeSafeNodeFunction。应用（Networks.java:50） 在com。谷歌。云数据流。工人图表网络。replaceDirectedNetworkNodes（Networks.java:87） 在com。谷歌。云数据流。工人IntrinsicMapTaskExecutorFactory。创建（IntrinsicMapTaskExecutorFactory.java:123） 在com。谷歌。云数据流。工人BatchDataflowWorker。doWork（BatchDataflowWorker.java:334） 在com。谷歌。云数据流。工人BatchDataflowWorker。getAndPerformWork（BatchDataflowWorker.java:288） 在com。谷歌。云数据流。工人DataflowBatchWorkerHarness$WorkerThread。doWork（DataflowBatchWorkerHarness.java:134） 在com。谷歌。云数据流。工人DataflowBatchWorkerHarness$WorkerThread。调用（DataflowBatchWorkerHarness.java:114） 在com。谷歌。云数据流。工人DataflowBatchWorkerHarness$WorkerThread。调用（DataflowBatchWorkerHarness.java:101） 在爪哇。util。同时发生的未来任务。运行（FutureTask.java:266） 在爪哇。util。同时发生的线程池执行器。runWorker（ThreadPoolExecutor.java:1142） 在爪哇。util。同时发生的线程池执行器$Worker。运行（ThreadPoolExecutor.java:617） 在爪哇。朗。丝线。运行（Thread.java:745） 原因：org。阿帕奇。梁sdk。util。UserCodeException:java。sql。SQLException:无法创建PoolableConnectionFactory（IO错误：网络适配器无法建立连接） 在org。阿帕奇。梁sdk。util。UserCodeException。wrap（UserCodeException.java:36） 在org。阿帕奇。梁sdk。木卫一。jdbc。JdbcIO$ReadFn$DoFnInvoker。invokeSetup（未知源） 在com。谷歌。云数据流。工人DofInstanceManager$ConcurrentQueueInstanceManager。反序列化复制（dofnInstanceManager.java:63） 在com。谷歌。云数据流。工人DofInstanceManager$ConcurrentQueueInstanceManager。peek（dofnInstanceManager.java:45） 在com。谷歌。云数据流。工人用户访问工厂。创建（userfactory.java:94） 在com。谷歌。云数据流。工人这是一家工厂。创建（defaultfactory.java:74） 在com。谷歌。云数据流。工人IntrinsicMapTaskExecutorFactory。createParDoOperation（IntrinsicMapTaskExecutorFactory.java:262） 在com。谷歌。云数据流。工人IntrinsicMapTaskExecutorFactory。访问$000（IntrinsicMapTaskExecutorFactory.java:84） 在com。谷歌。云数据流。工人IntrinsicMapTaskExecutorFactory$1。typedApply（IntrinsicMapTaskExecutorFactory.java:181） ... 14多

还有更多的许可。请参考下面我的代码， PipelineOptions=PipelineOptions工厂。fromArgs（args）。withValidation（）。创建（）； 管道=管道。创建（选项）； 管道应用（JdbcIO>；读取（）。使用DataSourceConfiguration（JdbcIO.DataSourceConfiguration.create（“oracle.jdbc.driver.OracleDriver”，“jdbc:oracle:thin:@/:1521/orcl”）。withUsername（“用户名”）。使用密码（“传递单词”）。withQuery（“从供应商中选择供应商ID、供应商名称”）。withRowMapper（新JdbcIO.RowMapper>；（）{ @凌驾 public KV mapRow（ResultSet ResultSet）引发异常{ 系统出来println（“===================================================================================================================”）； 千伏=千伏。of（resultSet.getString（“标签”），resultSet。getString("姓名);； 返回千伏； } }).withCoder（KvCoder.of）（StringUtf8Coder.of（），StringUtf8Coder。of（）））。应用（GroupByKey.create（））

我也有Oracle版本11g，所以我使用ojdbc6。罐子在这里

请帮帮我