Hi Nick, Just to be sure: don't you see some ClassCastException in the log ?
Thanks, Regards JB On 12/10/2015 07:56 PM, Nick Pentreath wrote:
Could you provide an example / test case and more detail on what issue you're facing? I've just tested a simple program reading from a dev Kinesis stream and using stream.print() to show the records, and it works under 1.5.1 but doesn't appear to be working under 1.5.2. UI for 1.5.2: Inline image 1 UI for 1.5.1: Inline image 2 On Thu, Dec 10, 2015 at 5:50 PM, Brian London <brianmlon...@gmail.com <mailto:brianmlon...@gmail.com>> wrote: Has anyone managed to run the Kinesis demo in Spark 1.5.2? The Kinesis ASL that ships with 1.5.2 appears to not work for me although 1.5.1 is fine. I spent some time with Amazon earlier in the week and the only thing we could do to make it work is to change the version to 1.5.1. Can someone please attempt to reproduce before I open a JIRA issue for it?
-- Jean-Baptiste Onofré jbono...@apache.org http://blog.nanthrax.net Talend - http://www.talend.com --------------------------------------------------------------------- To unsubscribe, e-mail: user-unsubscr...@spark.apache.org For additional commands, e-mail: user-h...@spark.apache.org
