Re: Anyone got Flink working in EMR with KinesisConnector

2018-01-11 Thread Fabian Hueske
Great, thanks for reporting back! 2018-01-10 22:46 GMT+01:00 xiatao123 : > got the issue fixed after applying patch from > https://github.com/apache/flink/pull/4150 > > > > -- > Sent from: http://apache-flink-user-mailing-list-archive.2336050. > n4.nabble.com/ >

Re: Anyone got Flink working in EMR with KinesisConnector

2018-01-10 Thread xiatao123
got the issue fixed after applying patch from https://github.com/apache/flink/pull/4150 -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

Anyone got Flink working in EMR with KinesisConnector

2018-01-10 Thread Tao Xia
Hi All, I ran into an exception after deployed our app in EMR. It seems like the connection to Kinesis failed. Any one got Flink KinesisConnector working in EMR? Release label:emr-5.11.0 Hadoop distribution:Amazon 2.7.3 Applications:Flink 1.3.2 java.lang.IllegalStateException: Socket not create