I have a mapper that implement ProgramLifeCycle<MapReduceTaskContext> and I am attempting to write to a Table in the mapper’s destroy method. The writes to the table are not available when I scan the table later. I have also tried calling close on the table and that does not fix the problem. I have tried moving the code to the mapper's cleanup method and there is a NPE when the dataset is accessed.
My setup is a workflow where my MapReduce job runs first and writes to a local dataset created by the workflow and then a workflow action is executed next and attempts to read from the table. If I write to the table in the mapper's map method the workflow action is able to read those rows.