Skip to content

Commit ceffbc0

Browse files
authored
[hotfix] Fix environment variable check for FLINK_CDC_HOME in YarnApplicationDeploymentExecutor. (#4012)
1 parent ecaf82e commit ceffbc0

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

flink-cdc-composer/src/main/java/org/apache/flink/cdc/composer/flink/deployment/YarnApplicationDeploymentExecutor.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -127,7 +127,7 @@ private String getFlinkCDCDistJarFromEnv() throws IOException {
127127
Preconditions.checkNotNull(
128128
flinkCDCHomeFromEnvVar,
129129
"FLINK_CDC_HOME is not correctly set in environment variable, current FLINK_CDC_HOME is: "
130-
+ FLINK_CDC_HOME_ENV_VAR);
130+
+ flinkCDCHomeFromEnvVar);
131131
Path flinkCDCLibPath = new Path(flinkCDCHomeFromEnvVar, "lib");
132132
if (!flinkCDCLibPath.getFileSystem().exists(flinkCDCLibPath)
133133
|| !flinkCDCLibPath.getFileSystem().getFileStatus(flinkCDCLibPath).isDir()) {

0 commit comments

Comments
 (0)