Hi Sridhar,
Your class is missing default constructor(without arguments) thus it is not a
valid POJO in Flink.
You can check the requirements for POJO in link here:
https://ci.apache.org/projects/flink/flink-docs-release-1.3/dev/api_concepts.html#pojos
> On 12 Jul 2017, at 19:54, Sridhar Chel
I have a DataStream on which I am applying a CEP pattern and grouping the
results using keyby(). The DataStream Object is a pojo :
public class DataStreamObject {
private String field1;
private String field2;
public DataStreamObject(String field1, String field2) {
this.field1
