Re: [PR] [FLINK-33509] Fix flaky test testNodeAffinity() in InitTaskManagerDecoratorTest.java [flink]
wanglijie95 commented on code in PR #23694: URL: https://github.com/apache/flink/pull/23694#discussion_r1427580681 ## flink-kubernetes/src/test/java/org/apache/flink/kubernetes/kubeclient/decorators/InitTaskManagerDecoratorTest.java: ## @@ -282,12 +282,22 @@ void testNodeAffinity() { assertThat(nodeSelectorTerms.size()).isEqualTo(1); List requirements = nodeSelectorTerms.get(0).getMatchExpressions(); -assertThat(requirements) -.containsExactlyInAnyOrder( +for (int i = 0; i < requirements.size(); i++) { Review Comment: Hi @yijut2, I think we simply change the logic as follows: ``` assertThat(requirements).hasSize(1); NodeSelectorRequirement requirement = requirements.get(0); assertThat(requirement.getKey()) .isEqualTo( flinkConfig.getString(KubernetesConfigOptions.KUBERNETES_NODE_NAME_LABEL)); assertThat(requirement.getOperator()).isEqualTo("NotIn"); assertThat(requirement.getValues()) .containsExactlyInAnyOrderElementsOf(Arrays.asList("blockedNode2", "blockedNode1")); ``` WDYT? -- 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-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
Re: [PR] [FLINK-33509] Fix flaky test testNodeAffinity() in InitTaskManagerDecoratorTest.java [flink]
yijut2 commented on PR #23694: URL: https://github.com/apache/flink/pull/23694#issuecomment-1833145868 @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-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
Re: [PR] [FLINK-33509] Fix flaky test testNodeAffinity() in InitTaskManagerDecoratorTest.java [flink]
flinkbot commented on PR #23694: URL: https://github.com/apache/flink/pull/23694#issuecomment-1805064194 ## CI report: * 67a3adf8ee55b17d2aaf963c4520cdb5597d9c11 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure` re-run the last Azure build -- 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-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org