Hi Saliya, in order to set the file path for the SerializedInputFormat you first have to create it and then explicitly call setFilePath.
final SerializedInputFormat<Record> inputFormat = new SerializedInputFormat<Record>(); inputFormat.setFilePath(PATH_TO_FILE); env.createInput(inputFormat, myTypeInfo); Cheers, Till 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 >
