[FLINK-40168][table] Thread the EARLY_FIRE hint into the interval join

[weiqingy]

Part of the FLIP-497 implementation stack under umbrella FLINK-36953. Landing order:

Step	Sub-task	Scope
PR-1a	FLINK-40167	EARLY_FIRE hint surface + option validation (#28353, merged)
PR-1b (this PR)	FLINK-40168	Thread the hint into the interval join (planner → ExecNode)
PR-2	FLINK-40169	target option
PR-3	FLINK-40170	Update-producing changelog mode + insert-only guard
PR-4	FLINK-40171	Runtime early-fire emit + retraction
PR-5	FLINK-40172	Processing-time early fire on an event-time join
PR-6	FLINK-40173	State restore coverage
PR-7	FLINK-40174	User-facing documentation

What is the purpose of the change

Threads the (already-registered) EARLY_FIRE hint through the planner to the ExecNode. StreamPhysicalIntervalJoinRule reads the hint, resolves the effective time mode from the join's time domain, validates the domain combinations, and threads the delay and time mode into StreamExecIntervalJoin as NON_NULL JSON fields. The operator receives the parameters but ignores them; runtime behavior lands in PR-4.

Brief change log

• StreamPhysicalIntervalJoinRule reads the hint, resolves the effective time mode, rejects row-time triggering on a processing-time join, and rejects (for now) processing-time triggering on an event-time join.
• Thread earlyFireDelay/earlyFireTimeMode through StreamPhysicalIntervalJoin into StreamExecIntervalJoin as NON_NULL JSON fields.

Verifying this change

This change added tests and can be verified as follows:

• EarlyFireJoinHintTest: earlyFireDelay/earlyFireTimeMode reach the exec plan for both a row-time (default ROWTIME) and a processing-time (default PROCTIME) interval join; row-time-on-proctime and processing-time-on-rowtime are rejected; a compiled-plan JSON round-trip covers serialization of the new ExecNode fields.

Does this pull request potentially affect one of the following parts:

• Dependencies (does it add or upgrade a dependency): no
• The public API, i.e., is any changed class annotated with @Public(Evolving): no
• The serializers: yes (compiled-plan ExecNode JSON only; no state serializer change)
• The runtime per-record code paths (performance sensitive): no
• Anything that affects deployment or recovery: no
• The S3 file system connector: no

Documentation

• Does this pull request introduce a new feature? no (planner threading for the FLIP-497 hint)
• If yes, how is the feature documented? not applicable

---

Was generative AI tooling used to co-author this PR?

• Yes (please specify the tool below)

Generated-by: Claude Code (Anthropic)

[flinkbot]

CI report:

• 647116f Azure: SUCCESS
• a856401 Azure: PENDING

Bot commands

The @flinkbot bot supports the following commands:

• @flinkbot run azure re-run the last Azure build

[weiqingy]

Hi @RocMarshal, opening PR-1b of the FLIP-497 stack ahead as a draft. It's stacked on #28353, so I'll rebase it onto master and take it out of draft for review once #28353 is merged. Thanks!

[weiqingy]

Hi @RocMarshal, #28353 (PR-1a) has merged, so I've rebased this onto master. The diff is now standalone: just the planner threading and its tests. Taking it out of draft. Ready for review when you have a chance, thanks!