This doesn't work even with TextInputFormat. Not sure what's wrong. On Tue, Aug 1, 2017 at 9:53 AM, Mohit Anchlia <mohitanch...@gmail.com> wrote:
> I don't see the print output. > > On Tue, Aug 1, 2017 at 2:08 AM, Fabian Hueske <fhue...@gmail.com> wrote: > >> 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 <mohitanch...@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 <mohitanch...@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. >>>> >>> >>> >> >
