Ask Your Question

Revision history [back]

Getting error when we give destination as elasticsearch related to SASL

Hi

We have secured the elastic search cluster recently and the URL has been changed from http to https. We give the https URL in Cluster HTTP URIs for elastic search and also enable security and provide the username and password.

Inspite of this, we get the below error when loading data to an elastic search index:

com.streamsets.datacollector.runner.PipelineRuntimeException: CONTAINER_0800 - Pipeline 'Customer58c89a7d-528b-4b6d-a4d0-56a6a1f22882' validation error : ELASTICSEARCH_09 - Could not connect to the cluster HTTP endpoint: javax.net.ssl.SSLHandshakeException: General SSLEngine problem 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:740) at com.streamsets.datacollector.execution.runner.common.AsyncRunner.lambda$start$3(AsyncRunner.java:151) at com.streamsets.pipeline.lib.executor.SafeScheduledExecutorService$SafeCallable.lambda$call$0(SafeScheduledExecutorService.java:249) at com.streamsets.datacollector.security.GroupsInScope.execute(GroupsInScope.java:33) at com.streamsets.pipeline.lib.executor.SafeScheduledExecutorService$SafeCallable.call(SafeScheduledExecutorService.java:245) 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 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748)

Can you please help on this.