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
pache.org<mailto:user@flink.apache.org>" mailto:user@flink.apache.org>> Subject: ype of TypeVariable could not be determined Hi, I am trying to create a custom stream source. I first build this with generic and I run into problems regarding type extraction. I tried to put concre

ype of TypeVariable could not be determined

2016-03-08 Thread Radu Tudoran
Hi, I am trying to create a custom stream source. I first build this with generic and I run into problems regarding type extraction. I tried to put concrete types but run into the same issue (see errors below). Can anyone provide a solution to solve this issue. Caused by: org.apache.flink.api.