Hi,
I have been facing issues while trying to read from a hdfs sequence file.
This is my code snippet
DataSource> input = env
.createInput(HadoopInputs.readSequenceFile(Text.class, Text.class,
ravenDataDir),
TypeInformation.of(new TypeHint>() {
}));
Upon executing this in
Could anyone please help me with this?
Thanks,
Akshay
On Mon, 10 Dec 2018, 6:05 pm Akshay Mendole Hi,
>I have been facing issues while trying to read from a hdfs sequence
> file.
>
> This is my code snippet
>
> DataSource> input = env
> .createInput(HadoopInputs.readSequenceFile(Text.clas
Hi,
I am a bit confused by the explanation, the exception that you mentioned, is it
happening in the first code snippet ( with the TypeInformation.of(…)) or the
second one? From looking into the code, I would expect the exception can only
happen in the second snippet (without TypeInformation) b
Hi Stefen,
You are correct. I logged the error messages incorrectly in
my previous mail.
When I execute this code snippet
DataSource> input =
env.createInput(HadoopInputs.readSequenceFile(Text.class, Text.class,
ravenDataDir));
I got this error
The type returned by the input for
Hi,
In that case, are you sure that your Flink version corresponds to the version
of the flink-hadoop-compatibility jar? It seems that you are using Flink 1.7
for the jar and your cluster needs to run that version as well. IIRC, this
particular class was introduced with 1.7, so using a differen
