Re: ype of TypeVariable could not be determined

2016-03-09 Thread Timo Walther
m>> Reply-To: "user@flink.apache.org <mailto:user@flink.apache.org>" mailto:user@flink.apache.org>> Date: Wednesday 9 March 2016 at 09:41 To: "user@flink.apache.org <mailto:user@flink.apache.org>" mailto:user@flink.apache.org>> Subject: RE: ype of TypeVariable

Re: ype of TypeVariable could not be determined

2016-03-09 Thread Wang Yangjun
gt; Reply-To: "user@flink.apache.org<mailto:user@flink.apache.org>" mailto:user@flink.apache.org>> Date: Wednesday 9 March 2016 at 09:41 To: "user@flink.apache.org<mailto:user@flink.apache.org>" mailto:user@flink.apache.org>> Subject: RE: ype of TypeVaria

RE: ype of TypeVariable could not be determined

2016-03-08 Thread Radu Tudoran
delete it! From: Wang Yangjun [mailto:yangjun.w...@aalto.fi] Sent: Tuesday, March 08, 2016 7:15 PM To: user@flink.apache.org Subject: Re: ype of TypeVariable could not be determined Hi Radu, I met this issue also. The reason is outTypeInfo couldn't be created base on generic type when a tr

Re: ype of TypeVariable could not be determined

2016-03-08 Thread Timo Walther
Hi Radu, the exception can have multiple causes. It would be great if you could share some example code. In most cases the problem is the following: public class MapFunction { } new MapFunction(); The type WhatEverType is type erasured by Java. The type must not be declared in the "new"

Re: ype of TypeVariable could not be determined

2016-03-08 Thread Wang Yangjun
Hi Radu, I met this issue also. The reason is outTypeInfo couldn't be created base on generic type when a transform applied. public SingleOutputStreamOperator transform(String operatorName, TypeInformation outTypeInfo, OneInputStreamOperator operator) The solution would be passed Calss to you