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

kkloudas pushed a commit to branch executors
in repository https://gitbox.apache.org/repos/asf/flink.git

commit 91afa87873e2a6f6dfca4db33622b17dc09084b6
Author: Kostas Kloudas <kklou...@gmail.com>
AuthorDate: Tue Nov 12 08:58:07 2019 +0100

    intentional breaking
---
 .../src/main/java/org/apache/flink/client/cli/CliFrontend.java        | 4 +---
 1 file changed, 1 insertion(+), 3 deletions(-)

diff --git 
a/flink-clients/src/main/java/org/apache/flink/client/cli/CliFrontend.java 
b/flink-clients/src/main/java/org/apache/flink/client/cli/CliFrontend.java
index f37a29a..e7280f4 100644
--- a/flink-clients/src/main/java/org/apache/flink/client/cli/CliFrontend.java
+++ b/flink-clients/src/main/java/org/apache/flink/client/cli/CliFrontend.java
@@ -35,12 +35,10 @@ import 
org.apache.flink.client.program.ProgramInvocationException;
 import org.apache.flink.client.program.ProgramMissingJobException;
 import org.apache.flink.client.program.ProgramParametrizationException;
 import org.apache.flink.configuration.ConfigConstants;
-import org.apache.flink.configuration.ConfigUtils;
 import org.apache.flink.configuration.Configuration;
 import org.apache.flink.configuration.CoreOptions;
 import org.apache.flink.configuration.GlobalConfiguration;
 import org.apache.flink.configuration.JobManagerOptions;
-import org.apache.flink.configuration.PipelineOptions;
 import org.apache.flink.configuration.RestOptions;
 import org.apache.flink.core.fs.FileSystem;
 import org.apache.flink.core.plugin.PluginUtils;
@@ -222,7 +220,7 @@ public class CliFrontend {
                        final ExecutionConfigAccessor executionParameters) 
throws FlinkException {
                final Configuration effectiveConfig = 
customCommandLine.applyCommandLineOptionsToConfiguration(commandLine);
                executionParameters.applyToConfiguration(effectiveConfig);
-               ConfigUtils.encodeStreamToConfig(effectiveConfig, 
PipelineOptions.JARS, program.getAllLibraries().stream(), URL::toString);
+//             ConfigUtils.encodeStreamToConfig(effectiveConfig, 
PipelineOptions.JARS, program.getAllLibraries().stream(), URL::toString);
                return effectiveConfig;
        }
 

Reply via email to