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. >>> >> >> >
