Re: ype of TypeVariable could not be determined

2016-03-09 Thread Timo Walther
tion) by persons other than the intended recipient(s) is prohibited. If you receive this e-mail in error, please notify the sender by phone or email immediately and delete it! *From:*Wang Yangjun [mailto:yangjun.w...@aalto.fi] *Sent:* Tuesday, March 08, 2016 7:15 PM *To:* user@flink.apache.org <ma

Re: ype of TypeVariable could not be determined

2016-03-09 Thread Wang Yangjun
her than the intended recipient(s) is prohibited. If you receive this e-mail in error, please notify the sender by phone or email immediately and delete it! From: Wang Yangjun [mailto:yangjun.w...@aalto.fi] Sent: Tuesday, March 08, 2016 7:15 PM To: user@flink.apache.org<mailto:user@flink.apache.

RE: ype of TypeVariable could not be determined

2016-03-08 Thread Radu Tudoran
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 transform a

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

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