(flink) branch master updated: [hotfix] Fix YARN ContainerId.getId Deprecated Used.

[fanrui]

This is an automated email from the ASF dual-hosted git repository.

fanrui pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
     new ad8bbb49a5a [hotfix] Fix YARN ContainerId.getId Deprecated Used.
ad8bbb49a5a is described below

commit ad8bbb49a5af4731a8b071e986ae9f16033c593c
Author: Shilun Fan <slfan1...@apache.org>
AuthorDate: Tue Apr 2 08:40:56 2024 +0800

    [hotfix] Fix YARN ContainerId.getId Deprecated Used.
---
 .../src/test/java/org/apache/flink/yarn/YarnConfigurationITCase.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/flink-yarn-tests/src/test/java/org/apache/flink/yarn/YarnConfigurationITCase.java
 
b/flink-yarn-tests/src/test/java/org/apache/flink/yarn/YarnConfigurationITCase.java
index fb690107f74..01b9e4ff6e1 100644
--- 
a/flink-yarn-tests/src/test/java/org/apache/flink/yarn/YarnConfigurationITCase.java
+++ 
b/flink-yarn-tests/src/test/java/org/apache/flink/yarn/YarnConfigurationITCase.java
@@ -144,7 +144,7 @@ class YarnConfigurationITCase extends YarnTestBase {
                             }
 
                             for (ContainerReport container : containers) {
-                                if (container.getContainerId().getId() == 1) {
+                                if 
(container.getContainerId().getContainerId() == 1) {
                                     // this should be the application master
                                     
assertThat(container.getAllocatedResource().getMemorySize())
                                             .isEqualTo(masterMemory);