flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Maximilian Michels <...@apache.org>
Subject Re: Error while reading binary file
Date Mon, 08 Feb 2016 10:45:02 GMT
Hi Saliya,

Thanks for your question. Flink's type analyzer couldn't extract the
type information. You may implement the ResultTypeQueryable interface
in your custom source. That way you can manually specify the correct
type. If that doesn't help you, could you please share more of the
stack trace?


On Mon, Feb 8, 2016 at 7:00 AM, Saliya Ekanayake <esaliya@gmail.com> wrote:
> Hi,
> I was trying to read a simple binary file using SerializedInputFormat as
> suggested in a different thread, but encounters the following error. I tried
> to do what the exception suggests, but eventhough createInput() returns a
> DataSet object I couldn't find how to specify which file to read.
> Any help is appreciated. The file I am trying to read is a simple binary
> file with containing java short values. Is there any example on reading
> binary files available?
> Exception in thread "main"
> org.apache.flink.api.common.InvalidProgramException: The type returned by
> the input format could not be automatically determined. Please specify the
> TypeInformation of the produced type explicitly by using the
> 'createInput(InputFormat, TypeInformation)' method instead.
> Thank you,
> Saliya
> --
> Saliya Ekanayake
> Ph.D. Candidate | Research Assistant
> School of Informatics and Computing | Digital Science Center
> Indiana University, Bloomington
> Cell 812-391-4914
> http://saliya.org

View raw message