Auron MetricNode periodic updates

Auron's current metric design is tailored for batch processing scenarios, where metrics are updated only after a task has completed.
However, in Flink environments, tasks are long-running, so we need to update metrics periodically.
For more details, see rt.rs

I'd like to work on this issue. Is it still available?

@qingfei1994

hi @qingfei1994 assigned to you

@qingfei1994

hi @qingfei1994 is anything update for this issue?

[AURON apache#2189] Periodically publish native metrics for long-runn…

Yes, will create a draft pull request for this.
Summary is as below:

Periodic native metric publish on a tokio interval, sending positive deltas so incremental MetricNode.add does not double-count.
Config auron.metrics.update.interval.ms (default 1000; 0 = finalize-only).
FlinkMetricNode.fromPlan so Kafka (including fused Project[Filter[KafkaScan]]) and Calc share a plan-shaped metric tree for getChild(i).

[AURON apache#2189] Periodically publish native metrics for long-runn…

[AURON apache#2189] introduce auron.metrics.update.enabled to only en…

[AURON apache#2189] Hold metric_state lock across getMetrics to seria…

Navigation Menu

Repository navigation

Auron MetricNode periodic updates #2189

Metadata

Assignees

Labels

Type

Projects

Milestone

Relationships

Development

Auron MetricNode periodic updates #2189

Description

Activity

qingfei1994 commented on Aug 18, 2026

Tartarus0zm commented on Aug 19, 2026

Tartarus0zm commented on Aug 31, 2026

qingfei1994 commented on Aug 31, 2026

Metadata

Metadata

Assignees

Labels

Type

Projects

Milestone

Relationships

Development

Issue actions