You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "featzhang (via GitHub)" <gi...@apache.org> on 2026/02/28 13:05:41 UTC
[PR] [FLINK-39176][runtime] Integrate NodeHealthManager with Slot Filtering [flink]
featzhang opened a new pull request, #27711:
URL: https://github.com/apache/flink/pull/27711
## What is the purpose of the change
This PR implements the integration of NodeHealthManager with the slot allocation process in FineGrainedSlotManager. It enables filtering out quarantined nodes during slot allocation to prevent jobs from being scheduled on unhealthy nodes.
This PR builds on PR #27701 (NodeHealthManager abstraction) and implements Phase 2 of the node health management mechanism.
## Brief change log
- Modified FineGrainedSlotManager to filter out quarantined nodes during slot allocation in allocateSlotsAccordingTo() method
- Updated ResourceManagerRuntimeServices to accept NodeHealthManager parameter in createSlotManager() method
- Enhanced ResourceManagerFactory to pass NoOpNodeHealthManager as default implementation
- Extended FineGrainedSlotManagerBuilder and FineGrainedSlotManagerTestBase to support NodeHealthManager in test infrastructure
- Added comprehensive integration test NodeQuarantineSlotFilteringITCase covering slot allocation filtering, quarantine expiry, and manual removal scenarios
- Fixed compilation issues in test infrastructure related to method name conflicts
## Verifying this change
This change is verified by:
- Existing unit tests continue to pass
- New integration test NodeQuarantineSlotFilteringITCase validates the slot filtering functionality
- Manual testing with quarantined nodes shows slots are correctly filtered
- Compilation succeeds with mvnw clean spotless:apply install -DskipTests -Pfast
## Does this pull request potentially affect
- Public API: No
- Serializers: No
- The runtime per-record code paths: No
- Anything that affects deployment or recovery: JobManager failover: No
- The S3 file system connector: No
## Documentation
- Does this pull request introduce a new feature: Yes, node health-based slot filtering
- If yes, how is the feature documented: Code comments and integration tests. Full documentation will be added in subsequent PRs for REST API and configuration options.
--
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: issues-unsubscribe@flink.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [PR] [FLINK-39176][runtime] Integrate NodeHealthManager with Slot Filtering [flink]
Posted by "github-actions[bot] (via GitHub)" <gi...@apache.org>.
github-actions[bot] closed pull request #27711: [FLINK-39176][runtime] Integrate NodeHealthManager with Slot Filtering
URL: https://github.com/apache/flink/pull/27711
--
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: issues-unsubscribe@flink.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [PR] [FLINK-39176][runtime] Integrate NodeHealthManager with Slot Filtering [flink]
Posted by "featzhang (via GitHub)" <gi...@apache.org>.
featzhang commented on PR #27711:
URL: https://github.com/apache/flink/pull/27711#issuecomment-3979543265
@flinkbot run azure
--
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: issues-unsubscribe@flink.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [PR] [FLINK-39176][runtime] Integrate NodeHealthManager with Slot Filtering [flink]
Posted by "flinkbot (via GitHub)" <gi...@apache.org>.
flinkbot commented on PR #27711:
URL: https://github.com/apache/flink/pull/27711#issuecomment-3977152918
<!--
Meta data
{
"version" : 1,
"metaDataEntries" : [ {
"hash" : "2861c61919aba054b8a4e61b2e66a7bb90b31f2f",
"status" : "UNKNOWN",
"url" : "TBD",
"triggerID" : "2861c61919aba054b8a4e61b2e66a7bb90b31f2f",
"triggerType" : "PUSH"
} ]
}-->
## CI report:
* 2861c61919aba054b8a4e61b2e66a7bb90b31f2f UNKNOWN
<details>
<summary>Bot commands</summary>
The @flinkbot bot supports the following commands:
- `@flinkbot run azure` re-run the last Azure build
</details>
--
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: issues-unsubscribe@flink.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [PR] [FLINK-39176][runtime] Integrate NodeHealthManager with Slot Filtering [flink]
Posted by "github-actions[bot] (via GitHub)" <gi...@apache.org>.
github-actions[bot] commented on PR #27711:
URL: https://github.com/apache/flink/pull/27711#issuecomment-4873780019
This PR has been closed since it has not had any activity in 120 days.
If you feel like this was a mistake, or you would like to continue working on it,
please feel free to re-open the PR and ask for a review.
--
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: issues-unsubscribe@flink.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [PR] [FLINK-39176][runtime] Integrate NodeHealthManager with Slot Filtering [flink]
Posted by "featzhang (via GitHub)" <gi...@apache.org>.
featzhang commented on PR #27711:
URL: https://github.com/apache/flink/pull/27711#issuecomment-3994892211
@flinkbot run azure
--
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: issues-unsubscribe@flink.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [PR] [FLINK-39176][runtime] Integrate NodeHealthManager with Slot Filtering [flink]
Posted by "github-actions[bot] (via GitHub)" <gi...@apache.org>.
github-actions[bot] commented on PR #27711:
URL: https://github.com/apache/flink/pull/27711#issuecomment-4600004144
This PR is being marked as stale since it has not had any activity in the last 90 days.
If you would like to keep this PR alive, please leave a comment asking for a review.
If the PR has merge conflicts, update it with the latest from the base branch.
If you are having difficulty finding a reviewer, please reach out to the
community, contact details can be found here: https://flink.apache.org/what-is-flink/community/
If this PR is no longer valid or desired, please feel free to close it.
If no activity occurs in the next 30 days, it will be automatically closed.
--
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: issues-unsubscribe@flink.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org