Weird question about running Flink on AWS… I seem ...
# random
m
Weird question about running Flink on AWS… I seem to be having a conflict between:
org.apache.hadoop.fs.s3a.S3ARetryPolicy
org.apache.hadoop.conf.Configuration
I get an error message about getTimeDuration(String, String, TimeUnit) NoSuchMethod - so I suspect S3ARetryPolicy is a 3.x hadoop client class and Configuration is a 2.7.x class - any idea how I can debug this a little more? I’m using AWS Kinesis Studio
S3ARetryPolicy coming from /opt/flink/lib/flink-s3-fs-hadoop-1.13.2.jar while Configuration coming from /opt/flink/lib/hadoop-common-2.6.5.jar are there any AWS Kinesis employees on this Slack?
d
Hey Matt, I'll DM you