Skip to content

Commit a40701f

Browse files
committed
add log perperties when run perjob mode
1 parent 410d618 commit a40701f

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

launcher/src/main/java/com/dtstack/flink/sql/launcher/perjob/PerJobClusterClientBuilder.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -69,7 +69,7 @@ public AbstractYarnClusterDescriptor createPerJobClusterDescriptor(Properties co
6969
Configuration newConf = new Configuration();
7070
confProp.forEach((key, val) -> newConf.setString(key.toString(), val.toString()));
7171

72-
AbstractYarnClusterDescriptor clusterDescriptor = getClusterDescriptor(newConf, yarnConf, ".");
72+
AbstractYarnClusterDescriptor clusterDescriptor = getClusterDescriptor(newConf, yarnConf, launcherOptions.getFlinkconf());
7373

7474
if (StringUtils.isNotBlank(flinkJarPath)) {
7575
if (!new File(flinkJarPath).exists()) {

0 commit comments

Comments
 (0)