flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Saliya Ekanayake <esal...@gmail.com>
Subject Re: Error while reading binary file
Date Mon, 08 Feb 2016 15:00:47 GMT
Thank you Till and Max. I'll try the set file path method and let you know.
On Feb 8, 2016 5:45 AM, "Maximilian Michels" <mxm@apache.org> wrote:

> 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?
>
> Thanks,
> Max
>
> 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
>

Mime
View raw message