Hey Alexander,
I have looked into your issue. You can simply use
env.createInput(InputFormat,TypeInformation) instead of env.readFile()
then you can pass TypeInformation manually without implementing
ResultTypeQueryable.
Regards,
Timo
On 29.01.2015 14:54, Alexander Alexandrov wrote:
The
Alight, thanks for the hint.
I suggest to close PR 349 and refine the exception with a hint HOW exactly
to pass the TypeInformation instance, e.g.
The type returned by the input format could not be automatically
determined. Please pass the TypeInformation of the produced type explicitly
via
The problem seems to be that the reflection analysis cannot determine the
type of the TypeSerializerInputFormat.
One possible solution is to add the ResultTypeQueryable interface and force
clients to explicitly set the TypeInformation.
This might break code which relies on automatic type
