Re: Using filesystem plugin with MiniCluster

2023-01-12 Thread Chesnay Schepler
There is no good way in 1.15 IIRC. Adding a dependency on flink-s3-fs-hadoop _can_ work, if you dont run into dependency conflicts. Otherwise you have to create a plugin manager yourself, point it to some local directory via a system property (I think?), and then eagerly call FileSystem#init

Re: Using filesystem plugin with MiniCluster

2023-01-03 Thread Yaroslav Tkachenko
Hey Ken, I have flink-s3-fs-hadoop as a provided dependency in my project, and I've configured my IDE to include provided dependencies when starting applications. Works just fine. On Tue, Jan 3, 2023 at 5:06 PM Ken Krugler wrote: > Hi all, > > With Flink 1.15.x, is there a way to use the S3 Pre