Re: What S3 Permissions does StreamingFileSink need?

2019-12-05 Thread r_khachatryan
Hi Li, Could you please list the permissions you see and the error message you receive from AWS? Li Peng-2 wrote > Hey folks, I'm trying to use StreamingFileSink with s3, using IAM roles > for > auth. Does anyone know what permissions the role should have for the > specified s3 bucket to work pr

Re: How does Flink handle backpressure in EMR

2019-12-05 Thread r_khachatryan
Hi Michael Flink *does* detect backpressure but currently, it only propagates it back to sources. And so it doesn't support auto-scaling. Regards, Roman Nguyen, Michael wrote > How does Flink handle backpressure (caused by an increase in traffic) in a > Flink job when it’s being hosted in an EM

Re: User program failures cause JobManager to be shutdown

2019-12-05 Thread r_khachatryan
Hi Dongwon, Could you please provide Flink version you are running and the job manager logs? Regards, Roman eastcirclek wrote > Hi, > > I tried to run a program by uploading a jar on Flink UI. When I > intentionally enter a wrong parameter to my program, JobManager dies. > Below > is all log m