Re: Exception when using keyby operator

2017-09-13 Thread Tzu-Li (Gordon) Tai
Following up: here’s the JIRA ticket for improving the POJO data type documentation - https://issues.apache.org/jira/browse/FLINK-7614. - Gordon On 11 September 2017 at 10:31:23 AM, Sridhar Chellappa (flinken...@gmail.com) wrote: That fixed my issue. Thanks. I also agree we need to fix the Do

Re: Exception when using keyby operator

2017-09-11 Thread Sridhar Chellappa
That fixed my issue. Thanks. I also agree we need to fix the Documentation On Thu, Sep 7, 2017 at 6:15 PM, Timo Walther wrote: > Hi Sridhar, > > according to the exception, your "meEvents" stream is not POJO. You can > check that by printing "meEvents.getType()". In general, you can always > che

Re: Exception when using keyby operator

2017-09-07 Thread Timo Walther
Hi Sridhar, according to the exception, your "meEvents" stream is not POJO. You can check that by printing "meEvents.getType()". In general, you can always check the log for such problems. There should be something like: 14:40:57,079 INFO org.apache.flink.api.java.typeutils.TypeExtractor

Exception when using keyby operator

2017-09-06 Thread Sridhar Chellappa
I am trying to use the KeyBy operator as follows : Pattern myEventsCEPPattern = Pattern.begin("FirstEvent") .subtype(MyEvent.class) .next("SecondEvent") .subtype(MyEvent.class)