Re: Unable to build flink from source

2019-05-05 Thread Hai
I have met this error when I build with a wrong jdk version. May be you should change to a newly jdk version, maby jdk 1.8? Original Message Sender:syedms110400...@vu.edu.pk Recipient:useru...@flink.apache.org Date:Monday, May 6, 2019 09:20 Subject:Unable to build flink from source Hi I am try

Re: IllegalArgumentException with CEP & reinterpretAsKeyedStream

2019-05-05 Thread Le-Van Huyen
Thank you Yun. I haven't tried to follow your guide to check (would take some time for me to follow on how to do). However, I could now confirm that the "*union"* is the culprit. In my Flink Console GUI, I can see that the link from StreamC to CEP via "union" is a FORWARD link, not a HASH one, whi

Unable to build flink from source

2019-05-05 Thread syed
Hi I am trying to build flink 1.3.3 from source using IntelliJ IDEA Ultimate 2019.1 IDE. When I build the project, I am receiving the following error *java package sun.misc does not exist* I am using the instruction to Importing Flink into an IDE available at this link https://ci.apache.org/pro

Re: IllegalArgumentException with CEP & reinterpretAsKeyedStream

2019-05-05 Thread Yun Tang
Hi Averell I think this is because after 'union', the input stream actually did not follow the rule that key must be pre-partitioned in EXACTLY the same way Flink’s keyBy would partition the data [1]. An easy way to verify this is refer to [2] to filter whether different sub-task of union strea

IllegalArgumentException with CEP & reinterpretAsKeyedStream

2019-05-05 Thread Averell
Hi everyone, I have a big stream A, filtered by flags from a small stream B, then unioned with another stream C to become the input for my CEP. As the three streams A, B, C are all keyed, I expected that the output stream resulting from connecting/unioning them would also be keyed, thus I used /re