Re: Unable to get Flink S3 plugin to work

Could you try to copy the plugin jar into FLINK_HOME/lib? On Fri, Oct 21, 2022 at 4:59 AM Matt Fysh wrote: > Hi Jeff, > > I created a small reproduction repo here: > https://github.com/mattfysh/zepp-flink-s3 and the error I'm seeing is: > > org.apache.flink.core.fs.UnsupportedFileSystemSchemeExc

Re: Unable to get Flink S3 plugin to work

Hi Jeff, I created a small reproduction repo here: https://github.com/mattfysh/zepp-flink-s3 and the error I'm seeing is: org.apache.flink.core.fs.UnsupportedFileSystemSchemeException: Could not find a file system implementation for scheme 's3a' I'm using version 1.13.2 to match AWS where I hop

Re: Unable to get Flink S3 plugin to work

What exact error do you mean? Even if you run flink inside zeppelin, you still need to configure FLINK_HOME, for any jars, you need to put under FLINK_HOME I believe. On Thu, Oct 20, 2022 at 3:52 PM Matt Fysh wrote: > Hi Zeppers, > > I'm running Flink inside the Zeppelin 0.10 docker image, and

Unable to get Flink S3 plugin to work

Hi Zeppers, I'm running Flink inside the Zeppelin 0.10 docker image, and having difficulty writing a stream to S3. I've copied the plugin inside the Flink plugin directory, but I think it also requires the Service Loader to be configured according to this StackOverflow question