Skip to content
Snippets Groups Projects
Commit aa4492c9 authored by Sören Henning's avatar Sören Henning
Browse files

Fix typo

parent aa07fc73
Branches
Tags
1 merge request!272Introduce Abstract Flink Service Class
Pipeline #8634 passed
......@@ -8,9 +8,9 @@ import org.slf4j.LoggerFactory;
import titan.ccp.common.configuration.ServiceConfigurations;
/**
* A general Apache Flink-based microservice. It is configured by {@link #configureEnv()},
* and extended by implementing business logic in {@link #buildPipeline()}.
* The configuration of the serializer needs to be implemented in {@link #configureSerializers()}.
* A general Apache Flink-based microservice. It is configured by {@link #configureEnv()}, and
* extended by implementing business logic in {@link #buildPipeline()}. The configuration of the
* serializer needs to be implemented in {@link #configureSerializers()}.
*/
public abstract class AbstractFlinkService {
......@@ -35,6 +35,7 @@ public abstract class AbstractFlinkService {
/**
* Abstract Service constructing the name and {@link StreamExecutionEnvironment}.
*
* @param config the configuration for the service.
*/
public AbstractFlinkService(final Configuration config) {
......@@ -104,7 +105,7 @@ public abstract class AbstractFlinkService {
try {
this.env.execute(this.applicationId);
} catch (final Exception e) { // NOPMD Execution thrown by Flink
} catch (final Exception e) { // NOPMD Exception thrown by Flink
LOGGER.error("An error occured while running this job.", e);
}
}
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment