Re: Wikiedit QuickStart with Kinesis

2016-09-01 Thread Foster, Craig
Oh, in that case, maybe I should look into using the KCL. I'm just using boto and boto3 which are definitely having different problems but both related to the encoding. boto3 prints *something*: (.96.129.59,-20)'(01:541:4305:C70:10B4:FA8C:3CF9:B9B0,0(Patrick Barlane,0(Nedrutland,12(GreenC bo

Re: Wikiedit QuickStart with Kinesis

2016-09-01 Thread Tzu-Li Tai
I’m afraid the “AUTO” option on the Kinesis producer is actually bugged, so the internally used KPL library correctly pick up credentials with the default credential provider chain. I’ve just filed a JIRA for this: https://issues.apache.org/jira/browse/FLINK-4559

Re: Wikiedit QuickStart with Kinesis

2016-09-01 Thread Foster, Craig
r. From: "Tzu-Li (Gordon) Tai" Reply-To: "user@flink.apache.org" Date: Thursday, September 1, 2016 at 2:25 AM To: "user@flink.apache.org" Subject: Re: Wikiedit QuickStart with Kinesis Hi Craig, I’ve just run a simple test on this and there should be no problem. W

Re: Wikiedit QuickStart with Kinesis

2016-09-01 Thread Tzu-Li (Gordon) Tai
Hi Craig, I’ve just run a simple test on this and there should be no problem. What Flink version were you using (the archetype version used with the Flink Quickstart Maven Archetype)? Also, on which branch / commit was the Kinesis connector built? Seeing that you’ve used the “AUTO” credentials