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" <m...@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 <esal...@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 >
