Issue reading from S3

2021-05-18 Thread Angelo G.
Hi, I'm trying to read from and write to S3 with Flink 1.12.2. I'm submitting the job to local cluster (tar.gz distribution). I do not have a Hadoop installation running in the same machine. S3 (not Amazon) is running in a remote location and I have access to it via endpoint and access/secret keys

Re: Issue reading from S3

2021-05-22 Thread Angelo G.
tion items > are effective ? > > Also I only configured the s3a.path-style: true, s3a.access-key and > s3a.secret-key, is it possible to remove the other configuration items > and have a try ? > > Best, > Yun > > > > --Original Mail

S3 + Parquet credentials issue

2021-05-31 Thread Angelo G.
Hello, Trying to read a parquet file located in S3 leads to a AWS credentials exception. Switching to other format (raw, for example) works ok regarding to file access. This is a snippet of code to reproduce the issue: static void parquetS3Error() { EnvironmentSettings settings = Environmen

Re: S3 + Parquet credentials issue

2021-06-15 Thread Angelo G.
>> setting this logger to DEBUG level: org.apache.hadoop.fs.s3a >> >> >> Good luck :) >> >> Svend >> >> >> >> [1] >> https://hadoop.apache.org/docs/current/hadoop-aws/tools/hadoop-aws/index.html >> [2] >> https:/

Re: S3 + Parquet credentials issue

2021-06-20 Thread Angelo G.
LConnection.java:984) > ~[?:1.8.0_171] > at > com.amazonaws.internal.ConnectionUtils.connectToEndpoint(ConnectionUtils.java:52) > ~[blob_p-575afa7acc2fe3049b65534303a189df3afe9895-6c71352c89388f6a3754b9b72482e6d2:?] > at > com.amazonaws.internal.EC2ResourceFetcher.doReadResource(EC2ResourceFetcher.java:80