From 38e37ecd3819cdc32262dda53a909314be151de2 Mon Sep 17 00:00:00 2001
From: lorenz <stu203404@mail.uni-kiel.de>
Date: Fri, 3 Dec 2021 15:01:35 +0100
Subject: [PATCH] Add logging of Pipeline options
---
.../java/theodolite/commons/beam/AbstractBeamService.java | 4 ++++
1 file changed, 4 insertions(+)
diff --git a/theodolite-benchmarks/beam-commons/src/main/java/theodolite/commons/beam/AbstractBeamService.java b/theodolite-benchmarks/beam-commons/src/main/java/theodolite/commons/beam/AbstractBeamService.java
index 289de6c30..d2b37e54c 100644
--- a/theodolite-benchmarks/beam-commons/src/main/java/theodolite/commons/beam/AbstractBeamService.java
+++ b/theodolite-benchmarks/beam-commons/src/main/java/theodolite/commons/beam/AbstractBeamService.java
@@ -29,6 +29,10 @@ public class AbstractBeamService {
*/
public AbstractBeamService(final String[] args) { //NOPMD
super();
+ LOGGER.info("Pipeline options:");
+ for (final String s : args) {
+ LOGGER.info("{}", s);
+ }
options = PipelineOptionsFactory.fromArgs(args).create();
options.setJobName(applicationName);
LOGGER.info("Starting BeamService with PipelineOptions {}:", this.options.toString());
--
GitLab