Re: Why is task manager shutting down?

Hi You can configure the key `task.cancellation.timeout`[1] to increase the timeout, and the code about this logic is here[2] [1] https://nightlies.apache.org/flink/flink-docs-master/docs/deployment/config/#task-cancellation-timeout [2] https://github.com/apache/flink/blob/f543b8ac690b1dee58bc

Re: Global window in batch mode

Hi Vararu, Flink ML has a custom implementation of WindowAssigner, called EndOfStreamWindows, that might help solve your problem. Please have a check to see if this meets your requirements. https://github.com/apache/flink-ml/blob/master/flink-ml-core/src/main/java/org/apache/flink/ml/common/datast