Hi, Welcome to the mailing list.
What exactly is your problem? Do you receive an error message? Is the program not compiling? Do you receive no output? Regardless of that, I would recommend to provide the timestamp extractors to the Kafka source functions. Also, I would have a close look at the window join semantics and validate that it provides the semantics that you need. The interval join is an alternative that should be applicable to more use cases. Best, Fabian Am Fr., 30. Nov. 2018 um 14:11 Uhr schrieb Rakesh Kumar < rakkukumar2...@gmail.com>: > Hi all, > > I am new to flink, i written a small flink streaming program which take > two inputs from kafka and put it to two different data streams. i wanted to > apply watermarks on it and then i wanted to join both datastream. > > For reference i have attached an image. >
