You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ga...@apache.org on 2019/05/23 15:23:38 UTC
[flink] 02/04: [hotfix][runtime] Fix checkstyle violations in
RestartStrategyFactory
This is an automated email from the ASF dual-hosted git repository.
gary pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit aa9b89919ef10570920fdc6b22cabdf244b70508
Author: Gary Yao <ga...@apache.org>
AuthorDate: Wed May 15 11:41:38 2019 +0200
[hotfix][runtime] Fix checkstyle violations in RestartStrategyFactory
---
.../runtime/executiongraph/restart/RestartStrategyFactory.java | 9 +++++++--
1 file changed, 7 insertions(+), 2 deletions(-)
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/restart/RestartStrategyFactory.java b/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/restart/RestartStrategyFactory.java
index f15ee0b..b5361ce 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/restart/RestartStrategyFactory.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/restart/RestartStrategyFactory.java
@@ -22,14 +22,19 @@ import org.apache.flink.api.common.restartstrategy.RestartStrategies;
import org.apache.flink.configuration.AkkaOptions;
import org.apache.flink.configuration.ConfigConstants;
import org.apache.flink.configuration.Configuration;
+
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-import scala.concurrent.duration.Duration;
import java.io.Serializable;
import java.lang.reflect.InvocationTargetException;
import java.lang.reflect.Method;
+import scala.concurrent.duration.Duration;
+
+/**
+ * Factory for {@link RestartStrategy}.
+ */
public abstract class RestartStrategyFactory implements Serializable {
private static final long serialVersionUID = 7320252552640522191L;
@@ -37,7 +42,7 @@ public abstract class RestartStrategyFactory implements Serializable {
private static final String CREATE_METHOD = "createFactory";
/**
- * Factory method to create a restart strategy
+ * Factory method to create a restart strategy.
* @return The created restart strategy
*/
public abstract RestartStrategy createRestartStrategy();