Skip to content

Instantly share code, notes, and snippets.

Embed
What would you like to do?
# Segment creation job config:
path.to.input=avro
path.to.output=segments
path.to.schema=schema/events.json
segment.table.name=events
# Segment tar push job config:
push.to.hosts=https://localhost
push.to.port=8081
2018-10-30 07:53:29,680 INFO job.SegmentTarPushJob: ******** Now uploading segments tar from dir: file:/home/ubuntu/cloud9/acstats.site.pinot/db/segments
2018-10-30 07:53:29,686 INFO job.SegmentTarPushJob: ******** Upoading file: events_0 to Host: https://localhost and Port: 8081 *******
2018-10-30 07:53:29,710 INFO utils.FileUploadUtils: Sending file events_0 to https://localhost:8081
2018-10-30 07:53:29,716 INFO utils.FileUploadUtils: URI is: https://localhost:8081
2018-10-30 07:54:00,356 WARN utils.FileUploadUtils: Retry 0 of Upload of File events_0 to URI https://localhost:8081 after error trying to send file Sleeping for 60 seconds. Caught Exception
java.lang.RuntimeException: javax.net.ssl.SSLHandshakeException: Remote host closed connection during handshake
at com.linkedin.pinot.common.utils.FileUploadUtils.sendFile(FileUploadUtils.java:466)
at com.linkedin.pinot.common.utils.FileUploadUtils.sendFileRetry(FileUploadUtils.java:378)
at com.linkedin.pinot.common.utils.FileUploadUtils.sendSegment(FileUploadUtils.java:370)
at com.linkedin.pinot.hadoop.job.SegmentTarPushJob.pushOneTarFile(SegmentTarPushJob.java:90)
at com.linkedin.pinot.hadoop.job.SegmentTarPushJob.pushDir(SegmentTarPushJob.java:72)
at com.linkedin.pinot.hadoop.job.SegmentTarPushJob.run(SegmentTarPushJob.java:57)
at com.linkedin.pinot.hadoop.PinotHadoopJobLauncher.kickOffPinotHadoopJob(PinotHadoopJobLauncher.java:57)
at com.linkedin.pinot.hadoop.PinotHadoopJobLauncher.main(PinotHadoopJobLauncher.java:90)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.apache.hadoop.util.RunJar.run(RunJar.java:318)
at org.apache.hadoop.util.RunJar.main(RunJar.java:232)
Caused by: javax.net.ssl.SSLHandshakeException: Remote host closed connection during handshake
at sun.security.ssl.SSLSocketImpl.readRecord(SSLSocketImpl.java:994)
at sun.security.ssl.SSLSocketImpl.performInitialHandshake(SSLSocketImpl.java:1367)
at sun.security.ssl.SSLSocketImpl.startHandshake(SSLSocketImpl.java:1395)
at sun.security.ssl.SSLSocketImpl.startHandshake(SSLSocketImpl.java:1379)
at org.apache.http.conn.ssl.SSLSocketFactory.connectSocket(SSLSocketFactory.java:553)
at org.apache.http.conn.ssl.SSLSocketFactory.connectSocket(SSLSocketFactory.java:412)
at org.apache.http.impl.conn.DefaultClientConnectionOperator.openConnection(DefaultClientConnectionOperator.java:179)
at org.apache.http.impl.conn.ManagedClientConnectionImpl.open(ManagedClientConnectionImpl.java:328)
at org.apache.http.impl.client.DefaultRequestDirector.tryConnect(DefaultRequestDirector.java:612)
at org.apache.http.impl.client.DefaultRequestDirector.execute(DefaultRequestDirector.java:447)
at org.apache.http.impl.client.AbstractHttpClient.doExecute(AbstractHttpClient.java:884)
at org.apache.http.impl.client.CloseableHttpClient.execute(CloseableHttpClient.java:82)
at org.apache.http.impl.client.CloseableHttpClient.execute(CloseableHttpClient.java:107)
at org.apache.http.impl.client.CloseableHttpClient.execute(CloseableHttpClient.java:55)
at com.linkedin.pinot.common.utils.FileUploadUtils.sendFile(FileUploadUtils.java:426)
... 13 more
Caused by: java.io.EOFException: SSL peer shut down incorrectly
at sun.security.ssl.InputRecord.read(InputRecord.java:505)
at sun.security.ssl.SSLSocketImpl.readRecord(SSLSocketImpl.java:975)
... 27 more
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment