This is an automated email from the ASF dual-hosted git repository. kkloudas pushed a commit to branch executor-impl in repository https://gitbox.apache.org/repos/asf/flink.git
commit 2ee04c78aaa13a897c68db64ff3fccafc5cde380 Author: Kostas Kloudas <[email protected]> AuthorDate: Thu Nov 14 16:03:42 2019 +0100 [hotfix] minor checkstyle fixes --- .../apache/flink/core/execution/DefaultExecutorServiceLoader.java | 6 +++--- .../src/main/java/org/apache/flink/core/execution/Executor.java | 1 + 2 files changed, 4 insertions(+), 3 deletions(-) diff --git a/flink-core/src/main/java/org/apache/flink/core/execution/DefaultExecutorServiceLoader.java b/flink-core/src/main/java/org/apache/flink/core/execution/DefaultExecutorServiceLoader.java index 241feab..64c0034 100644 --- a/flink-core/src/main/java/org/apache/flink/core/execution/DefaultExecutorServiceLoader.java +++ b/flink-core/src/main/java/org/apache/flink/core/execution/DefaultExecutorServiceLoader.java @@ -67,12 +67,12 @@ public class DefaultExecutorServiceLoader implements ExecutorServiceLoader { } if (compatibleFactories.size() > 1) { - final List<String> configStr = + final String configStr = configuration.toMap().entrySet().stream() .map(e -> e.getKey() + "=" + e.getValue()) - .collect(Collectors.toList()); + .collect(Collectors.joining("\n")); - throw new IllegalStateException("Multiple compatible client factories found for:\n" + String.join("\n", configStr) + "."); + throw new IllegalStateException("Multiple compatible client factories found for:\n" + configStr + "."); } return compatibleFactories.isEmpty() ? null : compatibleFactories.get(0); diff --git a/flink-core/src/main/java/org/apache/flink/core/execution/Executor.java b/flink-core/src/main/java/org/apache/flink/core/execution/Executor.java index 3476742..8515f43 100644 --- a/flink-core/src/main/java/org/apache/flink/core/execution/Executor.java +++ b/flink-core/src/main/java/org/apache/flink/core/execution/Executor.java @@ -29,6 +29,7 @@ public interface Executor { /** * Executes a {@link Pipeline} based on the provided configuration. + * * @param pipeline the {@link Pipeline} to execute * @param configuration the {@link Configuration} with the required execution parameters * @return the {@link JobExecutionResult} corresponding to the pipeline execution.
