Hi All, I have a job where my source is kafka. Stream1 is partition the data on dynamic key, join the data with static rules(source kafka).I use KeyedCoProcessFunction to join the Steam1 with Stream2(source kafka). All works fine in a normal run.
For changing the watermark generation interval I stop the job taking a savepoint. When I restart the job with the savepoint the watermark is stuck at - -9223372036854775808. Because of this the process function doesn't emit any results. What could be the problem? Thanks, Hemant
