Re: VerifyError when running Python streaming job

2018-08-08 Thread Joe Malt
Hi everyone, Thanks for your help. I discovered that the WordCount example runs when the lib directory is empty - something I had in there was causing it to break (perhaps a version conflict?). I haven't yet figured out what the culprit was, but I'll post an update if I do. Thanks again, Joe On

Re: VerifyError when running Python streaming job

2018-08-08 Thread Chesnay Schepler
I cannot reproduce the problem in 1.6-rc4 and 1.7-SNAPSHOT either :/ On 08.08.2018 10:33, Chesnay Schepler wrote: hmm, i was able to run it with 1.5.2 at least. Let's see what 1.6 says... On 08.08.2018 10:27, Chesnay Schepler wrote: I'll take a look, but it sounds like the source is the issue?

Re: VerifyError when running Python streaming job

2018-08-08 Thread Chesnay Schepler
hmm, i was able to run it with 1.5.2 at least. Let's see what 1.6 says... On 08.08.2018 10:27, Chesnay Schepler wrote: I'll take a look, but it sounds like the source is the issue? On 08.08.2018 09:34, vino yang wrote: Hi Joe, Did you try the word_count example from the flink codebase?[1] Re

Re: VerifyError when running Python streaming job

2018-08-08 Thread Chesnay Schepler
I'll take a look, but it sounds like the source is the issue? On 08.08.2018 09:34, vino yang wrote: Hi Joe, Did you try the word_count example from the flink codebase?[1] Recently, I tried this example, it works fine to me. An example of an official document may not guarantee your success due

Re: VerifyError when running Python streaming job

2018-08-08 Thread vino yang
Hi Joe, Did you try the word_count example from the flink codebase?[1] Recently, I tried this example, it works fine to me. An example of an official document may not guarantee your success due to maintenance issues. cc @Chesnay [1]: https://github.com/apache/flink/blob/master/flink-libraries/

VerifyError when running Python streaming job

2018-08-07 Thread Joe Malt
Hi, I'm running into errors when trying to run a Flink streaming program. Running the WordCount example from the docs fails with this error: java.lang.VerifyError: (class: site$py, method: _