MapReduce fails with "wrapped IOException: Broken pipe"

I am trying to implement a MapReduce job with only a map step and no outputs using python. I’ve tested the map logic in a jupyter with c3-remote, but am unable to run it server side.

MyTyp.c3typ

entity type MyType extends MapReduce <MyTargetType, Void, Void, Void> type key 'MYTYP' {

  @py(env = "myRunTime")
  map: ~

}

MyTyp.py

def map(batch, objs, job, subBatch):
    # my map logic here

c3QErrs(MapReduceQueue) returns this error message:

wrapped IOException: Broken pipe

    at java.io.FileOutputStream.writeBytes
    ...
    at c3.love.typesys.obj.pipe.ser.JsonObjValueReceiver.endObj (JsonObjValueReceiver.java:178)
  Broken pipe

Server version is 7.8.8.44. Does anyone know what is causing this?

1 Like