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; }