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)
