Hi folks,

I am new to Tez. I am trying to execute a simple application using "local
mode". I wrote a simple job with two vertices and one output. Stage1Vertex
generates one k-v pair and sends it to Stage2Vertex, which prints it to a
file.

Currently, the job blocks at ShuffleManager.getNextInput(). I have verified
that a file is written out by Stage1Vertex in the Tez staging directory
with the correct value.

Code is here:
https://github.com/ktzoumas/tez/blob/simple_tez_app/tez-simple-app/src/main/java/org/apache/tez/simpleapp/SimpleLocalJob.java

Any ideas on what I am doing wrong?

Kostas

Reply via email to