Support Questions

Find answers, ask questions, and share your expertise

kudu connection

avatar
Contributor

Dear Team,

 

kindly advise on why connection from our CDC tools to Kudu is not working? What does KuduWriterException: End of file: unable to send message: Other end of pipe was closed (error 0) mean?

 

at java.lang.Thread.run(Thread.java:750)
com.webaction.common.exc.ConnectionException: Couldn't establish connection with Kudu ( RB-HADOOP-03.mtg.local:7051,RB-HADOOP-04.mtg.local:7051,RB-HADOOP-05.mtg.local:7051,RB-HADOOP-03.mtg.local:7051,RB-HADOOP-04.mtg.local:7051,RB-HADOOP-05.mtg.local:7051,RB-HADOOP-03.mtg.local:7051,RB-HADOOP-04.mtg.local:7051,RB-HADOOP-05.mtg.local:7051,RB-HADOOP-03.mtg.local:7051,RB-HADOOP-04.mtg.local:7051,RB-HADOOP-05.mtg.local:7051,RB-HADOOP-03.mtg.local:7051,RB-HADOOP-04.mtg.local:7051,RB-HADOOP-05.mtg.local:7051,RB-HADOOP-03.mtg.local:7051,RB-HADOOP-04.mtg.local:7051,RB-HADOOP-05.mtg.local:7051,RB-HADOOP-03.mtg.local:7051,RB-HADOOP-04.mtg.local:7051,RB-HADOOP-05.mtg.local:7051,RB-HADOOP-03.mtg.local:7051,RB-HADOOP-04.mtg.local:7051,RB-HADOOP-05.mtg.local:7051,RB-HADOOP-03.mtg.local:7051,RB-HADOOP-04.mtg.local:7051,RB-HADOOP-05.mtg.local:7051 )
at com.striim.proc.Connection.KuduWriterConnection.connect(KuduWriterConnection.java:83)
at com.striim.proc.Connection.KuduWriterConnection.<init>(KuduWriterConnection.java:44)
at com.striim.proc.Connection.KuduWriterConnection.getConnection(KuduWriterConnection.java:100)
at com.striim.proc.KuduWriter.initializeKuduClient(KuduWriter.java:224)
at com.striim.proc.KuduWriter.initWriter(KuduWriter.java:132)
at com.webaction.utils.writers.common.RetriableBaseDataStoreWriter.init(RetriableBaseDataStoreWriter.java:78)
at com.webaction.runtime.components.Target.start(Target.java:377)
at com.webaction.runtime.components.Flow.start(Flow.java:431)
at com.webaction.runtime.components.Flow.start(Flow.java:375)
at com.webaction.runtime.components.Flow.start(Flow.java:335)
at com.webaction.runtime.components.Flow$2.run(Flow.java:1612)
at java.lang.Thread.run(Thread.java:750)
com.webaction.common.exc.ConnectionException: Couldn't establish connection with Kudu ( RB-HADOOP-03.mtg.local:7051,RB-HADOOP-04.mtg.local:7051,RB-HADOOP-05.mtg.local:7051,RB-HADOOP-03.mtg.local:7051,RB-HADOOP-04.mtg.local:7051,RB-HADOOP-05.mtg.local:7051,RB-HADOOP-03.mtg.local:7051,RB-HADOOP-04.mtg.local:7051,RB-HADOOP-05.mtg.local:7051,RB-HADOOP-03.mtg.local:7051,RB-HADOOP-04.mtg.local:7051,RB-HADOOP-05.mtg.local:7051,RB-HADOOP-03.mtg.local:7051,RB-HADOOP-04.mtg.local:7051,RB-HADOOP-05.mtg.local:7051,RB-HADOOP-03.mtg.local:7051,RB-HADOOP-04.mtg.local:7051,RB-HADOOP-05.mtg.local:7051,RB-HADOOP-03.mtg.local:7051,RB-HADOOP-04.mtg.local:7051,RB-HADOOP-05.mtg.local:7051,RB-HADOOP-03.mtg.local:7051,RB-HADOOP-04.mtg.local:7051,RB-HADOOP-05.mtg.local:7051,RB-HADOOP-03.mtg.local:7051,RB-HADOOP-04.mtg.local:7051,RB-HADOOP-05.mtg.local:7051,RB-HADOOP-03.mtg.local:7051,RB-HADOOP-04.mtg.local:7051,RB-HADOOP-05.mtg.local:7051,RB-HADOOP-03.mtg.local:7051,RB-HADOOP-04.mtg.local:7051,RB-HADOOP-05.mtg.local:7051,RB-HADOOP-03.mtg.local:7051,RB-HADOOP-04.mtg.local:7051,RB-HADOOP-05.mtg.local:7051 )
at com.striim.proc.Connection.KuduWriterConnection.connect(KuduWriterConnection.java:83)
at com.striim.proc.Connection.KuduWriterConnection.<init>(KuduWriterConnection.java:44)
at com.striim.proc.Connection.KuduWriterConnection.getConnection(KuduWriterConnection.java:100)
at com.striim.proc.KuduWriter.initializeKuduClient(KuduWriter.java:224)
at com.striim.proc.KuduWriter.initWriter(KuduWriter.java:132)
at com.webaction.utils.writers.common.RetriableBaseDataStoreWriter.init(RetriableBaseDataStoreWriter.java:78)
at com.webaction.runtime.components.Target.start(Target.java:377)
at com.webaction.runtime.components.Flow.start(Flow.java:431)
at com.webaction.runtime.components.Flow.start(Flow.java:375)
at com.webaction.runtime.components.Flow.start(Flow.java:335)
at com.webaction.runtime.components.Flow$2.run(Flow.java:1612)
at java.lang.Thread.run(Thread.java:750)
com.striim.proc.exception.KuduWriterException: End of file: unable to send message: Other end of pipe was closed (error 0)
at com.striim.proc.CheckPoint.CheckpointTableImpl.checkForCheckpointTable(CheckpointTableImpl.java:133)
at com.striim.proc.CheckPoint.CheckpointTableImpl.<init>(CheckpointTableImpl.java:44)
at com.striim.proc.KuduWriter.initWriter(KuduWriter.java:152)
at com.webaction.utils.writers.common.RetriableBaseDataStoreWriter.init(RetriableBaseDataStoreWriter.java:78)
at com.webaction.runtime.components.Target.start(Target.java:377)
at com.webaction.runtime.components.Flow.start(Flow.java:431)
at com.webaction.runtime.components.Flow.start(Flow.java:375)
at com.webaction.runtime.components.Flow.start(Flow.java:335)
at com.webaction.runtime.components.Flow$2.run(Flow.java:1612)
at java.lang.Thread.run(Thread.java:750)
Command RESUME failed so application CDC.CDC_CBS_CUST_CBS_NP is put in HALTED state
com.striim.proc.exception.KuduWriterException: End of file: unable to send message: Other end of pipe was closed (error 0)
at com.striim.proc.CheckPoint.CheckpointTableImpl.checkForCheckpointTable(CheckpointTableImpl.java:133)
at com.striim.proc.CheckPoint.CheckpointTableImpl.<init>(CheckpointTableImpl.java:44)
at com.striim.proc.KuduWriter.initWriter(KuduWriter.java:152)
at com.webaction.utils.writers.common.RetriableBaseDataStoreWriter.init(RetriableBaseDataStoreWriter.java:78)
at com.webaction.runtime.components.Target.start(Target.java:377)
at com.webaction.runtime.components.Flow.start(Flow.java:431)
at com.webaction.runtime.components.Flow.start(Flow.java:375)
at com.webaction.runtime.components.Flow.start(Flow.java:335)
at com.webaction.runtime.components.Flow$2.run(Flow.java:1612)
at java.lang.Thread.run(Thread.java:750)
com.striim.proc.exception.KuduWriterException: End of file: unable to send message: Other end of pipe was closed (error 0)
at com.striim.proc.CheckPoint.CheckpointTableImpl.checkForCheckpointTable(CheckpointTableImpl.java:133)
at com.striim.proc.CheckPoint.CheckpointTableImpl.<init>(CheckpointTableImpl.java:44)
at com.striim.proc.KuduWriter.initWriter(KuduWriter.java:152)
at com.webaction.utils.writers.common.RetriableBaseDataStoreWriter.init(RetriableBaseDataStoreWriter.java:78)
at com.webaction.runtime.components.Target.start(Target.java:377)
at com.webaction.runtime.components.Flow.start(Flow.java:431)
at com.webaction.runtime.components.Flow.start(Flow.java:375)
at com.webaction.runtime.components.Flow.start(Flow.java:335)
at com.webaction.runtime.components.Flow$2.run(Flow.java:1612)

 

Thanks,

Roshan

1 ACCEPTED SOLUTION

avatar
Expert Contributor

Hello Roshan,

com.striim.proc.exception.KuduWriterException: End of file: unable to send message: Other end of pipe was closed (error 0)

Looks to me like a known bug discovered recently for which there is already a patch.  Seems to be related to Cloudera OPSAPS-61660.

Best bet for you would be to open a ticket with support to have it confirmed.

 

Regards,

Jason R.

View solution in original post

3 REPLIES 3

avatar
Expert Contributor

Hello Roshan,

com.striim.proc.exception.KuduWriterException: End of file: unable to send message: Other end of pipe was closed (error 0)

Looks to me like a known bug discovered recently for which there is already a patch.  Seems to be related to Cloudera OPSAPS-61660.

Best bet for you would be to open a ticket with support to have it confirmed.

 

Regards,

Jason R.

avatar
Contributor

Thanks Jason. We upgraded Cloudera and issue is resolved.

avatar
Community Manager

Hi @roshanbi, Has the reply helped resolve your issue? If so, please mark the appropriate reply as the solution, as it will make it easier for others to find the answer in the future.  



Regards,

Vidya Sargur,
Community Manager


Was your question answered? Make sure to mark the answer as the accepted solution.
If you find a reply useful, say thanks by clicking on the thumbs up button.
Learn more about the Cloudera Community: