You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by kk...@apache.org on 2019/11/18 13:10:59 UTC
[flink] 03/19: [hotfix] minor checkstyle fixes
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 c058f2fcaa1ec71da6aa92ae730db27641babfb0
Author: Kostas Kloudas <kk...@gmail.com>
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.