diff --git a/theodolite-benchmarks/beam-commons/src/main/java/rocks/theodolite/benchmarks/commons/beam/BeamService.java b/theodolite-benchmarks/beam-commons/src/main/java/rocks/theodolite/benchmarks/commons/beam/BeamService.java index 607f591ffea766041c0472f9995e971f075c31b6..0165fa644e1853353e73caeaf0b9d2df0f8e9aea 100644 --- a/theodolite-benchmarks/beam-commons/src/main/java/rocks/theodolite/benchmarks/commons/beam/BeamService.java +++ b/theodolite-benchmarks/beam-commons/src/main/java/rocks/theodolite/benchmarks/commons/beam/BeamService.java @@ -74,13 +74,13 @@ public class BeamService { if (this.pipelineResult == null) { throw new IllegalStateException("Cannot stop service since it has never been started."); } - LOGGER.info("Stoping Beam pipeline."); + LOGGER.info("Stopping Beam pipeline."); try { this.pipelineResult.cancel(); this.pipelineResult = null; // NOPMD use null to indicate absence } catch (final IOException e) { throw new IllegalStateException( - "Stoping the service failed due to failed stop of Beam pipeline.", e); + "Stopping the service failed due to failed stop of Beam pipeline.", e); } LOGGER.info("Shutdown of Beam service {} complete.", this.applicationName); }