flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Saliya Ekanayake <esal...@gmail.com>
Subject Error while reading binary file
Date Mon, 08 Feb 2016 06:00:02 GMT

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 Ekanayake
Ph.D. Candidate | Research Assistant
School of Informatics and Computing | Digital Science Center
Indiana University, Bloomington
Cell 812-391-4914

View raw message