The error is not a the missing Class "S3ErrorResponseHandler", but the
initialization of that class.

It could be missing classes that are statically referenced by the
"S3ErrorResponseHandler".
The ones I see are "XMLInputFactory" (part of Java itself, should always be
there) and "org.apache.commons.logging.Log" which should also be there.
There may be other classes loaded during initialization. Knowing more about
the exception would help, as we have not seen that error, yet.


On Wed, Jan 3, 2018 at 11:39 AM, Nico Kruber <n...@data-artisans.com> wrote:

> Hi Kyle,
> except for putting the jar into the lib/ folder and setting up
> credentials, nothing else should be required [1].
>
> The S3ErrorResponseHandler class itself is in the jar, as you can see with
> jar tf flink-s3-fs-presto-1.4.0.jar | grep
> org.apache.flink.fs.s3presto.shaded.com.amazonaws.services.s3.internal.
> S3ErrorResponseHandler
>
> Therefore, the cause for this exception would be interesting (as Stephan
> suggested).
>
>
> Nico
>
> [1]
> https://ci.apache.org/projects/flink/flink-docs-
> release-1.4/ops/deployment/aws.html#shaded-hadooppresto-
> s3-file-systems-recommended
>
> On 03/01/18 10:22, Stephan Ewen wrote:
> > Hi Kyle!
> >
> > Is there more of the stack trace available, like an original exception
> > cause?
> >
> > Best,
> > Stephan
> >
> >
> > On Sun, Dec 31, 2017 at 5:10 PM, Kyle Hamlin <hamlin...@gmail.com
> > <mailto:hamlin...@gmail.com>> wrote:
> >
> >     Hi,
> >
> >     When testing Flink 1.4 locally the error below keeps getting thrown.
> >     I've followed the setup by moving the flink-s3-fs-presto.jar from
> >     the opt/ folder to the lib/ folder. Is there something additional I
> >     need to do?
> >
> >     java.lang.NoClassDefFoundError: Could not initialize class
> >     org.apache.flink.fs.s3presto.shaded.com.amazonaws.services.
> s3.internal.S3ErrorResponseHandler
> >     at
> >     org.apache.flink.fs.s3presto.shaded.com.amazonaws.services.
> s3.AmazonS3Client.<init>(AmazonS3Client.java:363)
> >     at
> >     org.apache.flink.fs.s3presto.shaded.com.amazonaws.services.
> s3.AmazonS3Client.<init>(AmazonS3Client.java:542)
> >     at
> >     org.apache.flink.fs.s3presto.shaded.com.facebook.presto.
> hive.PrestoS3FileSystem.createAmazonS3Client(PrestoS3FileSystem.java:639)
> >     at
> >     org.apache.flink.fs.s3presto.shaded.com.facebook.presto.
> hive.PrestoS3FileSystem.initialize(PrestoS3FileSystem.java:212)
> >     at
> >     org.apache.flink.fs.s3presto.S3FileSystemFactory.create(
> S3FileSystemFactory.java:132)
> >     at
> >     org.apache.flink.core.fs.FileSystem.getUnguardedFileSystem(
> FileSystem.java:397)
> >     at org.apache.flink.core.fs.FileSystem.get(FileSystem.java:320)
> >     at org.apache.flink.core.fs.Path.getFileSystem(Path.java:293)
> >     at
> >     org.apache.flink.runtime.state.filesystem.
> FsCheckpointStreamFactory.<init>(FsCheckpointStreamFactory.java:99)
> >     at
> >     org.apache.flink.runtime.state.filesystem.FsStateBackend.
> createStreamFactory(FsStateBackend.java:277)
> >     at
> >     org.apache.flink.streaming.runtime.tasks.StreamTask.
> createCheckpointStreamFactory(StreamTask.java:787)
> >     at
> >     org.apache.flink.streaming.api.operators.AbstractStreamOperator.
> initializeState(AbstractStreamOperator.java:247)
> >     at
> >     org.apache.flink.streaming.runtime.tasks.StreamTask.
> initializeOperators(StreamTask.java:694)
> >     at
> >     org.apache.flink.streaming.runtime.tasks.StreamTask.
> initializeState(StreamTask.java:682)
> >     at
> >     org.apache.flink.streaming.runtime.tasks.StreamTask.
> invoke(StreamTask.java:253)
> >     at org.apache.flink.runtime.taskmanager.Task.run(Task.java:718)
> >
> >
>
>

Reply via email to