Re: reading file from s3

2021-03-07 Thread Avi Levi
Chesnay Schepler > *Cc:* user@flink.apache.org > *Subject:* [SUSPECTED FRAUD]Re: reading file from s3 > > Hey Avi, > > Do you use 'Hadoop S3 plugin' to read from S3? > > If yes, what is its version? > > If not try to read from S3 as follow (ref > <http

Re: reading file from s3

2021-03-06 Thread Tamir Sagi
ure.gif?u=1088647&e=139753658&v=61d0f9764de1d96603b59533d7797a450ed41f983a06e5e81998ef6e88d9aff3] From: Tamir Sagi Sent: Saturday, March 6, 2021 7:33 PM To: Avi Levi ; Chesnay Schepler Cc: user@flink.apache.org Subject: [SUSPECTED FRAUD]Re: reading file fr

Re: reading file from s3

2021-03-06 Thread Tamir Sagi
ure.gif?u=1088647&e=139745102&v=e1c175d1aad586ec34f211146023d1e58b49bba775226af52da8148eaa4c27fd] From: Avi Levi Sent: Saturday, March 6, 2021 6:59 AM To: Chesnay Schepler Cc: user@flink.apache.org Subject: Re: reading file from s3 EXTERNAL EMAIL Does anyone b

Re: reading file from s3

2021-03-05 Thread Avi Levi
Does anyone by any chance have a working example (of course without the credentials etc') that can be shared on github ?simply reading/writing a file from/to s3. I keep on struggling with this one and getting weird exceptions Thanks On Thu, Mar 4, 2021 at 7:30 PM Avi Levi wrote: > Sure, This is

Re: reading file from s3

2021-03-04 Thread Avi Levi
Sure, This is the full exception stacktrace: Exception in thread "main" org.apache.flink.runtime.client.JobExecutionException: Job execution failed. at org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:144) at org.apache.flink.runtime.minicluster.MiniClusterJobClient

Re: reading file from s3

2021-03-04 Thread Chesnay Schepler
Can you show us the full exception stacktrace? Intuitively I would think your cluster configuration contains an invalid value for some memory configuration option. On 3/4/2021 4:45 PM, Avi Levi wrote: Hi , I am pretty new. I am keep on struggling to read a file from s3 but getting this weird 

reading file from s3

2021-03-04 Thread Avi Levi
Hi , I am pretty new. I am keep on struggling to read a file from s3 but getting this weird exception : Caused by: java.lang.NumberFormatException: For input string: "64M" (if anyone can link me to a working github example that will be awesome) . what am i doing wrong? This is how my code looks li