Skip to content

Commit a41db39

Browse files
committed
[TODO:test] Only set jar URI in native mode
1 parent 69e0ce8 commit a41db39

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

flink-kubernetes-operator/src/main/java/org/apache/flink/kubernetes/operator/config/FlinkConfigBuilder.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -301,7 +301,7 @@ protected FlinkConfigBuilder applyJobOrSessionSpec() throws URISyntaxException {
301301
effectiveConfig.set(
302302
DeploymentOptions.TARGET, KubernetesDeploymentTarget.APPLICATION.getName());
303303

304-
if (jobSpec.getJarURI() != null) {
304+
if (deploymentMode == KubernetesDeploymentMode.NATIVE && jobSpec.getJarURI() != null) {
305305
effectiveConfig.set(
306306
PipelineOptions.JARS,
307307
Collections.singletonList(new URI(jobSpec.getJarURI()).toString()));

0 commit comments

Comments
 (0)