Skip to content

[FLINK-40664][tests] Isolate MDC logging test clusters - #1

Open
sankalpsthakur wants to merge 2 commits into
masterfrom
cursor/flink-40664-jobid-logging-c294
Open

sankalpsthakur wants to merge 2 commits into
masterfrom
cursor/flink-40664-jobid-logging-c294

Conversation

@sankalpsthakur

@sankalpsthakur sankalpsthakur commented Sep 18, 2026

Copy link
Copy Markdown
Owner

Tracking fork for apache/flink#29235, using the same source branch. Review upstream; do not merge this fork PR.

At 9d2c0a0b, EnrichedMdcLoggingITCase has its own MiniCluster. The original JobIDLoggingUtil assertion order is preserved; no production helper changes remain. Tests cover all four wrong-job cleanup messages and an event matching both expected and ignored patterns.

Upstream Azure build 79245 is reported successful for this exact head. This is existing CI evidence, not a new local run or maintainer approval. The upstream title/body and response to the review still need updating to describe this implementation.

JIRA: FLINK-40664.

Generated-by: Cursor Grok 4.6.

…gITCase

Ignored log patterns now skip matching events even when they carry a
different MDC job ID. MiniCluster tests can observe TaskExecutor slot
cleanup for another job; that used to fail as "wrong value".

Generated-by: Cursor Grok 4.6

Co-authored-by: Sankalp Thakur <sankalpsthakur@users.noreply.github.com>

@sankalpsthakur sankalpsthakur left a comment

Copy link
Copy Markdown
Owner Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

AI-assisted review of 244995b: this changes the shared JobIDLoggingUtil contract, not just one ignored message. Matching events are now discarded before both the MDC check and expected-pattern accounting.

The unignored wrong-value negative test is useful. Add coverage for an unignored missing key and for an event matching both expected and ignored patterns, making the intended precedence explicit. Check other helper callers for overlap.

The reported three unit tests establish the helper behavior only. Run the affected JobIDLoggingITCase/MiniCluster case repeatedly, retaining a before-fix failure or deterministic reproduction. Do not present passing helper tests as evidence that the original nightly flake is resolved. I have not run the Flink suites in this review.

…ion precedence

Generated-by: ChatGPT GPT-6 Astra Pro
@sankalpsthakur sankalpsthakur changed the title [FLINK-40664][tests] Ignore Freeing inactive slots log in JobIDLoggingITCase [FLINK-40664][tests] Isolate MDC logging test clusters Sep 19, 2026
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant