Problem using the JDBC Consumer with Ignite Database

asked 2018-04-16 04:37:17 -0500

this post is marked as community wiki

This post is a wiki. Anyone with karma >75 is welcome to improve it.

Hi I am trying to connect to Ignite database from streamsets as JDBC consumer, But while I am connecting getting below exception

DEST_IGNITE_san/DEST_IGNITE461c471-2cda-4dcf-8cd4-0892f23ff358  ERROR   An exception occurred while running the pipeline, com.streamsets.datacollector.runner.PipelineRuntimeException: CONTAINER_0800 - Pipeline 'DESTIGNITE461c471-2cda-4dcf-8cd4-0892f23ff358' validation error : JDBC_00 - Cannot connect to specified database: com.zaxxer.hikari.pool.PoolInitializationException: Exception during pool initialization: Failed to establish connection.  ProductionPipelineRunnable  *admin      ProductionPipelineRunnable-CLIMXDESTIGNITEsana461c471-2cda-4dcf-8cd4-0892f23ff358-DEST_IGNITE
com.streamsets.datacollector.runner.PipelineRuntimeException: CONTAINER_0800 - Pipeline 'DESTIGNITEsana461c471-2cda-4dcf-8cd4-0892f23ff358' validation error : JDBC_00 - Cannot connect to specified database: com.zaxxer.hikari.pool.PoolInitializationException: Exception during pool initialization: Failed to establish connection.
    at com.streamsets.datacollector.execution.runner.common.ProductionPipeline.run(ProductionPipeline.java:131)
    at com.streamsets.datacollector.execution.runner.common.ProductionPipelineRunnable.run(ProductionPipelineRunnable.java:74)
    at com.streamsets.datacollector.execution.runner.standalone.StandaloneRunner.start(StandaloneRunner.java:755)
    at com.streamsets.datacollector.execution.runner.common.AsyncRunner.lambda$start$3(AsyncRunner.java:152)
    at com.streamsets.pipeline.lib.executor.SafeScheduledExecutorService$SafeCallable.lambda$call$0(SafeScheduledExecutorService.java:227)
    at com.streamsets.datacollector.security.GroupsInScope.execute(GroupsInScope.java:33)
    at com.streamsets.pipeline.lib.executor.SafeScheduledExecutorService$SafeCallable.call(SafeScheduledExecutorService.java:223)
    at com.streamsets.pipeline.lib.executor.SafeScheduledExecutorService$SafeCallable.lambda$call$0(SafeScheduledExecutorService.java:227)
    at com.streamsets.datacollector.security.GroupsInScope.execute(GroupsInScope.java:33)
    at com.streamsets.pipeline.lib.executor.SafeScheduledExecutorService$SafeCallable.call(SafeScheduledExecutorService.java:223)
    at java.util.concurrent.FutureTask.run(FutureTask.java:266)
    at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
    at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
    at com.streamsets.datacollector.metrics.MetricSafeScheduledExecutorService$MetricsTask.run(MetricSafeScheduledExecutorService.java:100)
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
    at java.lang.Thread.run(Thread.java:745)

I am able to connect to the ignite from normal java program. Below are the Details i am using to connect to URL : jdbc:ignite://Ip adderes :10800/ Driver: org.apache.ignite.IgniteJdbcDriver

can anyone pls help me in this.

edit retag flag offensive close merge delete

Comments

Yes, Jeff, Driver was setup correctly.

Kumar gravatar imageKumar ( 2018-04-17 02:47:22 -0500 )edit

Looks like a connectivity error - did you check that the host/port was accessible from the Data Collector machine?

metadaddy gravatar imagemetadaddy ( 2018-06-18 10:32:34 -0500 )edit