Skip to content

[Console] Reduce watcher poll frequency and deduplicate in-flight polls#4397

Closed
shangeyao wants to merge 1 commit into
apache:devfrom
shangeyao:fix/watcher-poll-interval-dedup
Closed

[Console] Reduce watcher poll frequency and deduplicate in-flight polls#4397
shangeyao wants to merge 1 commit into
apache:devfrom
shangeyao:fix/watcher-poll-interval-dedup

Conversation

@shangeyao

Copy link
Copy Markdown
Contributor

Summary

  • Split Flink/Spark app watchers into 5s steady-state and 1s fast polling during operations
  • Add per-app single-flight guards to avoid overlapping REST polls
  • Align FlinkClusterWatcher schedule with its 30-second interval

Fixes #4396

Test plan

  • Start/stop Flink app — state updates within ~10s
  • Running apps still refresh about every 5s
  • Cluster health monitoring continues to work

AI Disclosure

  • Model: Claude Opus 4.6
  • Platform/Tool: Cursor
  • Human Oversight: partially reviewed
  • Prompt Summary: Watcher poll interval optimization from dev branch scan

Made with Cursor

Use 5-second steady-state polling with 1-second fast path during app
operations, align cluster watcher to 30 seconds, and skip overlapping
per-app watch tasks.

Generated-by: Cursor
Co-authored-by: Cursor <cursoragent@cursor.com>
@shangeyao

Copy link
Copy Markdown
Contributor Author

Closing this PR because the StreamPark Console frontend is about to undergo a major refactor. These console-side changes would likely conflict with or require rework after the refactor. Will revisit relevant improvements once the new frontend architecture is in place.

@shangeyao shangeyao closed this Jun 30, 2026
@sonarqubecloud

Copy link
Copy Markdown

Quality Gate Failed Quality Gate failed

Failed conditions
57.6% Duplication on New Code (required ≤ 3%)

See analysis details on SonarQube Cloud

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

Projects

None yet

Development

Successfully merging this pull request may close these issues.

[Console] Reduce watcher poll frequency and deduplicate in-flight polls

1 participant