In https://issues.apache.org/jira/browse/FLINK-35767, support for s5cmd was
added to Flink 2.0. The ticket also mentions Flink 1.20, but I think that's
by mistake. Indeed nothing is mentioned in the docs:

1.20.2:
https://github.com/apache/flink/blob/release-1.20.2/flink-filesystems/flink-s3-fs-[
…]/org/apache/flink/fs/s3/common/AbstractS3FileSystemFactory.java

vs

master:
https://github.com/apache/flink/blob/master/flink-filesystems/flink-s3-fs-base/src[
…]/org/apache/flink/fs/s3/common/AbstractS3FileSystemFactory.java

Can anyone confirm?

If that's the case, is there a way for me to enable s5cmd in Flink 1.20.x
somehow? Or maybe something similar in the meantime I bump to Flink 2.x?
Would that be worth the effort?

Regards,

Salva

Reply via email to