flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Fabian Hueske <fhue...@gmail.com>
Subject Re: Using FileInputFormat - org.apache.flink.streaming.api.functions.source.TimestampedFileInputSplit
Date Tue, 01 Aug 2017 09:08:48 GMT
Hi Mohit,

these are just INFO log statements that do not necessarily indicate a
problem.
Is the program working otherwise or do you observe other problems?

Best, Fabian

2017-08-01 0:32 GMT+02:00 Mohit Anchlia <mohitanchlia@gmail.com>:

> I even tried existing format but still same error:
>
> FileInputFormat<String> fileInputFormat = *new* TextInputFormat(*new*
> Path(args[0]));
>
> fileInputFormat.setNestedFileEnumeration(*true*);
>
> streamEnv.readFile(fileInputFormat, args[0],
>
> FileProcessingMode.*PROCESS_CONTINUOUSLY*, 10000L).print();
>
>
> [main] INFO org.apache.flink.api.java.typeutils.TypeExtractor - class
> org.apache.flink.streaming.api.functions.source.TimestampedFileInputSplit
> does not contain a setter for field modificationTime
> [main] INFO org.apache.flink.api.java.typeutils.TypeExtractor - c
>
> On Mon, Jul 31, 2017 at 1:07 PM, Mohit Anchlia <mohitanchlia@gmail.com>
> wrote:
>
>>  In trying to use this code I get the following error. Is it asking me to
>> implement additional interface?
>>
>> streamEnv.readFile(format, args[0], FileProcessingMode.
>> *PROCESS_CONTINUOUSLY*, 2000).print();
>>
>>
>> [main] INFO com.s.flink.example.PDFInputFormat - Start streaming
>> [main] INFO org.apache.flink.api.java.typeutils.TypeExtractor - class
>> org.apache.flink.streaming.api.functions.source.TimestampedFileInputSplit
>> does not contain a setter for field modificationTime
>> [main] INFO org.apache.flink.api.java.typeutils.TypeExtractor - class
>> org.apache.flink.streaming.api.functions.source.TimestampedFileInputSplit
>> is not a valid POJO type because not all fields are valid POJO fields.
>>
>
>

Mime
View raw message