Re: Join two streams

2023-06-29 Thread Shrihari R
Hey Иван, Use *TumblingProcessingTimeWindows* instead of TumblingEventTimeWindows. TumblingEventTimeWindows requires a watermark strategy. *Ref* https://stackoverflow.com/questions/72291659/flink-tumbling-window-is-not-triggered-no-watermark-strategy *Regards* Shrihari On Fri, Jun 30, 2023 at

Savepoint Failing - Flink 1.16.2 - Scala12

2023-06-23 Thread Shrihari R
I am trying to stop the job by triggering the savepoint, but it's failing with the below error. *./bin/flink stop --savepointPath gs://staging-data-flink/flink-1-16-2/savepoints/ 3a912091b13c446c0d359074414db1db* it's working if I just trigger the save point without stopping the job. *./bin/flink

Re: Savepoint Failing - Flink 1.16.2 - Scala12

2023-06-23 Thread Shrihari R
On Fri, Jun 23, 2023 at 11:54 PM Shrihari R wrote: > Hi All, > > I am trying to stop the job by triggering the savepoint, but it's > failing with the below attached error. > > *Command Used* > ./bin/flink stop --savepointPath > gs://staging-data-flink