After compiling and running successfully the Word Count
examples with Maven
and direct-runner
, I'm looking for a way to add break point in code and to debug it step by step.
I ran this command:
mvn compile exec:java -D exec.mainClass=org.apache.beam.examples.WordCount -D exec.args="--inputFile=pom.xml --output=counts" -P direct-runner
but I can't find any other way to debug the code with IntelliJ IDE. Is it even possible to run the code in debug mode? is there any 'debug runner' ?
UPDATE
I've created an empty Maven project, added dependencies to pom.xml
file and I've successfully ran the project in Debug Mode (according to this tutorial) - the importat part was the beam-runners-direct-java
dependency.
I still don't know what I've done wrong in the BEAM WordCount project.