Re: ClassCastException when using RowTypeInfo

2017-12-13 Thread Timo Walther
Hi Madan, this is definitely a bug. The Row type has mostly been added for the Table & SQL API and has not tested for expression keys. But in general I would use a tuple in your case as they are more efficient. The `registerType` is only necessary for generic types serialized with Kryo. I op

ClassCastException when using RowTypeInfo

2017-12-13 Thread madan
Hi, Below is sample code I am trying with, StreamExecutionEnvironment env = StreamExecutionEnvironment. getExecutionEnvironment(); TypeInformation[] types = new TypeInformation[] {BasicTypeInfo.INT_TYPE_INFO, BasicTypeInfo.STRING_TYPE_INFO, BasicTypeInfo.DOUBLE_TYPE_INFO, BasicTypeInfo.