This is an automated email from the ASF dual-hosted git repository.
kunni pushed a commit to branch release-3.4
in repository https://gitbox.apache.org/repos/asf/flink-cdc.git
The following commit(s) were added to refs/heads/release-3.4 by this push:
new 885607344 [hotfix] Fix environment variable check for FLINK_CDC_HOME
in YarnApplicationDeploymentExecutor. (#4012) (#4013)
885607344 is described below
commit 885607344e885e3e407aefd7216470d8cec52099
Author: Tianzhu Wen <[email protected]>
AuthorDate: Tue Apr 29 17:41:58 2025 +0800
[hotfix] Fix environment variable check for FLINK_CDC_HOME in
YarnApplicationDeploymentExecutor. (#4012) (#4013)
(cherry picked from commit ceffbc0ea1a223bb2a81bd63c507be5978dee7f3)
---
.../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()) {
