Daniel Halperin created BEAM-1104: ------------------------------------- Summary: WordCount: Metrics error in the DirectRunner Key: BEAM-1104 URL: https://issues.apache.org/jira/browse/BEAM-1104 Project: Beam Issue Type: Bug Components: runner-direct Reporter: Daniel Halperin Assignee: Davor Bonaci
I'm following the Beam quickstart to analyze the pom.xml for the examples archetype in the DirectRunner: Generate the project: {code} mvn archetype:generate \ -DarchetypeRepository=https://repository.apache.org/content/groups/snapshots \ -DarchetypeGroupId=org.apache.beam \ -DarchetypeArtifactId=beam-sdks-java-maven-archetypes-examples \ -DarchetypeVersion=LATEST \ -DgroupId=org.example \ -DartifactId=word-count-beam \ -Dversion="0.1" \ -Dpackage=org.apache.beam.examples \ -DinteractiveMode=false {code} Count words in the pom.xml: {code} mvn compile exec:java -Dexec.mainClass=org.apache.beam.examples.WordCount \ -Dexec.args="--inputFile=pom.xml --output=direct/counts" -Pdirect-runner {code} The logs: {code} INFO] --- exec-maven-plugin:1.4.0:java (default-cli) @ word-count-beam --- Dec 07, 2016 9:42:03 PM org.apache.beam.sdk.io.FileBasedSource expandFilePattern INFO: Matched 1 files for pattern pom.xml Dec 07, 2016 9:42:03 PM org.apache.beam.sdk.metrics.MetricsEnvironment getCurrentContainer SEVERE: Unable to update metrics on the current thread. Most likely caused by using metrics outside the managed work-execution thread. Dec 07, 2016 9:42:03 PM org.apache.beam.sdk.io.Write$Bound$1 processElement INFO: Initializing write operation org.apache.beam.sdk.io.TextIO$TextSink$TextWriteOperation@26bbd1cf Dec 07, 2016 9:42:04 PM org.apache.beam.sdk.io.Write$Bound$WriteBundles processElement INFO: Opening writer for write operation org.apache.beam.sdk.io.TextIO$TextSink$TextWriteOperation@19371061 Dec 07, 2016 9:42:04 PM org.apache.beam.sdk.io.Write$Bound$WriteBundles processElement INFO: Opening writer for write operation org.apache.beam.sdk.io.TextIO$TextSink$TextWriteOperation@19371061 Dec 07, 2016 9:42:04 PM org.apache.beam.sdk.io.Write$Bound$WriteBundles processElement INFO: Opening writer for write operation org.apache.beam.sdk.io.TextIO$TextSink$TextWriteOperation@19371061 Dec 07, 2016 9:42:04 PM org.apache.beam.sdk.io.Write$Bound$WriteBundles processElement INFO: Opening writer for write operation org.apache.beam.sdk.io.TextIO$TextSink$TextWriteOperation@19371061 Dec 07, 2016 9:42:04 PM org.apache.beam.sdk.io.Write$Bound$2 processElement INFO: Finalizing write operation org.apache.beam.sdk.io.TextIO$TextSink$TextWriteOperation@3701012a. {code} Presumably, this {{SEVERE}} warning is indicative of a bug (or should be masked). -- This message was sent by Atlassian JIRA (v6.3.4#6332)