Admaing commented on PR #29239: URL: https://github.com/apache/flink/pull/29239#issuecomment-5830584465
@Jackeyzhe confirmed and fixed in be7924c — I reproduced `[true]` → `[true, false]` for `UNKNOWN` + `IDLE`. The activity signal is now guarded by `hasActiveOutput()`, so only outputs that reported `ACTIVE` count; `UNKNOWN` still holds the combined watermark back, so its watermark behaviour is unchanged. Added `subtaskStaysIdleWhenOnlyAnUnknownAndAnIdleSplitAreRegistered` for the mixed state — red on 627b6ce, green now. Note: registration is not evidence of activity either, so an idle subtask now re-activates on the new split's first record rather than when it is assigned; FLINK-22926's registration-time immediacy is dropped and noted as out of scope in the PR description. `test_ci core` is green on be7924c. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
