Hi, a bit more information would be useful. Are you using event-time? Is the Flink program kept running after adding the first batch of events and when adding the second batch or is it to invocations of your Flink program? Do you have a custom timestamp/watermark assigner?
Cheers, Aljoscha On Tue, 24 Jan 2017 at 14:28 Sujit Sakre <sujit.sa...@northgateps.com> wrote: > Hi, > > We are using a sliding window function to process data read from Kafka > Stream. We are using FlinkKafkaConsumer09 to read the data. The window > function and sink are running correctly. > > To test the program, we are generating a stream of data from command line. > This works when we add set of records once. When we add again, it does not > work, Flink produces no result, even though the records are added to same > Kafka topic from the same command line instance. > > Please could you suggest what could be wrong. > > Many thanks. > > > *Sujit Sakre* > > This email is sent on behalf of Northgate Public Services (UK) Limited and > its associated companies including Rave Technologies (India) Pvt Limited > (together "Northgate Public Services") and is strictly confidential and > intended solely for the addressee(s). > If you are not the intended recipient of this email you must: (i) not > disclose, copy or distribute its contents to any other person nor use its > contents in any way or you may be acting unlawfully; (ii) contact > Northgate Public Services immediately on +44(0)1908 264500 > <+44%201908%20264500> quoting the name of the sender and the addressee > then delete it from your system. > Northgate Public Services has taken reasonable precautions to ensure that > no viruses are contained in this email, but does not accept any > responsibility once this email has been transmitted. You should scan > attachments (if any) for viruses. > > Northgate Public Services (UK) Limited, registered in England and Wales > under number 00968498 with a registered address of Peoplebuilding 2, > Peoplebuilding Estate, Maylands Avenue, Hemel Hempstead, Hertfordshire, HP2 > 4NN. Rave Technologies (India) Pvt Limited, registered in India under > number 117068 with a registered address of 2nd Floor, Ballard House, Adi > Marzban Marg, Ballard Estate, Mumbai, Maharashtra, India, 400001. >
