Skip to content
Snippets Groups Projects
Commit 38e37ecd authored by Lorenz Boguhn's avatar Lorenz Boguhn
Browse files

Add logging of Pipeline options

parent 78cf80e8
No related branches found
No related tags found
1 merge request!187Migrate Beam benchmark implementation
......@@ -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());
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment