Uploaded image for project: 'Flume'
  1. Flume
  2. FLUME-2638

javax.net.ssl.SSLPeerUnverifiedException: peer not authenticated

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Open
    • Priority: Major
    • Resolution: Unresolved
    • Affects Version/s: 1.5.1
    • Fix Version/s: None
    • Component/s: Configuration
    • Labels:
      None

      Description

      I have configured S3 as a sink for Flume-NG, but getting the following error.

      Is there anything I have to do to load S3 certs into JVM

      15/03/06 08:34:47 WARN hdfs.HDFSEventSink: HDFS IO error
      javax.net.ssl.SSLPeerUnverifiedException: peer not authenticated
      at sun.security.ssl.SSLSessionImpl.getPeerCertificates(SSLSessionImpl.java:395)
      at org.apache.http.conn.ssl.AbstractVerifier.verify(AbstractVerifier.java:126)
      at org.apache.http.conn.ssl.SSLSocketFactory.connectSocket(SSLSocketFactory.java:437)
      at org.apache.http.impl.conn.DefaultClientConnectionOperator.openConnection(DefaultClientConnectionOperator.java:180)
      at org.apache.http.impl.conn.AbstractPoolEntry.open(AbstractPoolEntry.java:151)
      at org.apache.http.impl.conn.AbstractPooledConnAdapter.open(AbstractPooledConnAdapter.java:125)
      at org.apache.http.impl.client.DefaultRequestDirector.tryConnect(DefaultRequestDirector.java:643)
      at org.apache.http.impl.client.DefaultRequestDirector.execute(DefaultRequestDirector.java:479)
      at org.apache.http.impl.client.AbstractHttpClient.execute(AbstractHttpClient.java:906)
      at org.apache.http.impl.client.AbstractHttpClient.execute(AbstractHttpClient.java:805)
      at org.jets3t.service.impl.rest.httpclient.RestStorageService.performRequest(RestStorageService.java:334)
      at org.jets3t.service.impl.rest.httpclient.RestStorageService.performRequest(RestStorageService.java:281)
      at org.jets3t.service.impl.rest.httpclient.RestStorageService.performRestHead(RestStorageService.java:942)
      at org.jets3t.service.impl.rest.httpclient.RestStorageService.getObjectImpl(RestStorageService.java:2148)
      at org.jets3t.service.impl.rest.httpclient.RestStorageService.getObjectDetailsImpl(RestStorageService.java:2075)
      at org.jets3t.service.StorageService.getObjectDetails(StorageService.java:1093)
      at org.jets3t.service.StorageService.getObjectDetails(StorageService.java:548)
      at org.apache.hadoop.fs.s3native.Jets3tNativeFileSystemStore.retrieveMetadata(Jets3tNativeFileSystemStore.java:174)
      at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
      at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
      at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
      at java.lang.reflect.Method.invoke(Method.java:622)
      at org.apache.hadoop.io.retry.RetryInvocationHandler.invokeMethod(RetryInvocationHandler.java:187)
      at org.apache.hadoop.io.retry.RetryInvocationHandler.invoke(RetryInvocationHandler.java:102)
      at org.apache.hadoop.fs.s3native.$Proxy6.retrieveMetadata(Unknown Source)
      at org.apache.hadoop.fs.s3native.NativeS3FileSystem.getFileStatus(NativeS3FileSystem.java:468)
      at org.apache.hadoop.fs.FileSystem.exists(FileSystem.java:1400)
      at org.apache.hadoop.fs.s3native.NativeS3FileSystem.create(NativeS3FileSystem.java:395)
      at org.apache.hadoop.fs.FileSystem.create(FileSystem.java:908)
      at org.apache.hadoop.fs.FileSystem.create(FileSystem.java:889)
      at org.apache.hadoop.fs.FileSystem.create(FileSystem.java:786)
      at org.apache.hadoop.fs.FileSystem.create(FileSystem.java:775)
      at org.apache.flume.sink.hdfs.HDFSDataStream.doOpen(HDFSDataStream.java:86)
      at org.apache.flume.sink.hdfs.HDFSDataStream.open(HDFSDataStream.java:113)
      at org.apache.flume.sink.hdfs.BucketWriter$1.call(BucketWriter.java:273)
      at org.apache.flume.sink.hdfs.BucketWriter$1.call(BucketWriter.java:262)
      at org.apache.flume.sink.hdfs.BucketWriter$9$1.run(BucketWriter.java:722)
      at org.apache.flume.sink.hdfs.BucketWriter.runPrivileged(BucketWriter.java:183)
      at org.apache.flume.sink.hdfs.BucketWriter.access$1700(BucketWriter.java:59)
      at org.apache.flume.sink.hdfs.BucketWriter$9.call(BucketWriter.java:719)
      at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:334)
      at java.util.concurrent.FutureTask.run(FutureTask.java:166)
      at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1146)
      at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
      at java.lang.Thread.run(Thread.java:701)

        Attachments

          Activity

            People

            • Assignee:
              Unassigned
              Reporter:
              gblazer George Blazer
            • Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

              • Created:
                Updated: