Re: Issue reading from S3

2021-05-22 Thread Angelo G.
Hi Yun Gao, Thank you for your prompt response. I've changed the table 'format' from 'parquet' to 'raw' as in your example and I've been able to access the file: Job has been submitted with JobID 441e7518bb615109624c1f33f222475b ++ |url

Re: Issue reading from S3

2021-05-20 Thread Yun Gao
Hi Angelo, I tried the fail case provied with a similar one: StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(); env.setParallelism(1); EnvironmentSettings settings = EnvironmentSettings.newInstance().inBatchMode().useBlinkPlanner().build(); TableEnvironment