(flink-cdc) branch master updated: [hotfix] Fix environment variable check for FLINK_CDC_HOME in YarnApplicationDeploymentExecutor. (#4012)

[kunni]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new ceffbc0ea [hotfix] Fix environment variable check for FLINK_CDC_HOME 
in YarnApplicationDeploymentExecutor. (#4012)
ceffbc0ea is described below

commit ceffbc0ea1a223bb2a81bd63c507be5978dee7f3
Author: Tianzhu Wen <149778446+joycurr...@users.noreply.github.com>
AuthorDate: Tue Apr 29 15:06:00 2025 +0800

    [hotfix] Fix environment variable check for FLINK_CDC_HOME in 
YarnApplicationDeploymentExecutor. (#4012)
---
 .../composer/flink/deployment/YarnApplicationDeploymentExecutor.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/flink/deployment/YarnApplicationDeploymentExecutor.java
 
b/flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/flink/deployment/YarnApplicationDeploymentExecutor.java
index 16b9b1501..c8ff52253 100644
--- 
a/flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/flink/deployment/YarnApplicationDeploymentExecutor.java
+++ 
b/flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/flink/deployment/YarnApplicationDeploymentExecutor.java
@@ -127,7 +127,7 @@ public class YarnApplicationDeploymentExecutor implements 
PipelineDeploymentExec
         Preconditions.checkNotNull(
                 flinkCDCHomeFromEnvVar,
                 "FLINK_CDC_HOME is not correctly set in environment variable, 
current FLINK_CDC_HOME is: "
-                        + FLINK_CDC_HOME_ENV_VAR);
+                        + flinkCDCHomeFromEnvVar);
         Path flinkCDCLibPath = new Path(flinkCDCHomeFromEnvVar, "lib");
         if (!flinkCDCLibPath.getFileSystem().exists(flinkCDCLibPath)
                 || 
!flinkCDCLibPath.getFileSystem().getFileStatus(flinkCDCLibPath).isDir()) {