Weiqing Yang

Timeout of triggering the reconcile loop

3

Hi team, Is there a way to tune the timeout at which point the K8s triggers the reconcile loop? Is it this parameter [REFLECTOR_WATCH_CLIENTSIDE_TIMEOUT](https://github.com/kubernetes-client/java/blob/0642e7b8fc1c3bdebd77136c35cacd577c006e62/util/src/main/java/io/kubernetes/client/informer/cache/ReflectorRunnable.java#L41)? The default value is 5 mins....

[Query] Client metrics/monitoring

7

We have been developing our operators using the kubernetes java client, and want to define some metrics about the operators, e.g. health metric, lagging metric, etc. Prometheus metrics are used...

Add more unit tests (InsertInto) about views and tables (refer tpcds)

2

We should all put all sql queries in one place, and use CheckAnswer() to compare results. - Nested select queries - Correlated queries - `WITH` queries

SAMZA-2067: Support Samza's running on Kubernetes

10

## What changes were proposed in this pull request? Make Samza jobs able to run on Kubernetes natively. ## How was this patch tested? Run Samza jobs on AKS.

[FLINK-38477][runtime] Add FINISHED watermark status to support proper watermark aggregation

2

## What is the purpose of the change This PR fixes a watermark aggregation bug that can cause zero output from time-based operators (e.g., IntervalJoin) when some upstream subtasks finish...