How to custom (or use) a window to specify everyday's beginning as watermark?

2019-11-25 Thread Rock
I need my job to aggregator every device's mertic as daily report.But I did not find a window can cover exactly one day,or let everyday's beginning as watermark .Should I custom a window or any other way to achieve?

Re??Re?? how to setup a ha flink cluster on k8s?

2019-11-19 Thread Rock
vino yang http://shzhangji.com/blog/2019/08/24/deploy-flink-job-cluster-on-kubernetes/ Rock https://ci.apache.org/projects/flink/flink-docs-release-1.9/ops/deployment/kubernetes.html  this not ha , when job-manager down and rescheduled the metadata for running job is lost.    I tried

how to setup a ha flink cluster on k8s?

2019-11-15 Thread Rock
I'm trying to setup a flink cluster on k8s for production use.But the setup here https://ci.apache.org/projects/flink/flink-docs-release-1.9/ops/deployment/kubernetes.html  this not ha , when job-manager down and rescheduled the metadata for running job is lost.    I tried to use ha setup for