You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@giraph.apache.org by Maja Kabiljo <ma...@fb.com> on 2013/03/29 22:13:11 UTC

Review Request: GIRAPH-600: Create an option to do output during computation

-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/10201/
-----------------------------------------------------------

Review request for giraph.


Description
-------

https://issues.apache.org/jira/browse/GIRAPH-600


This addresses bug GIRAPH-600.
    https://issues.apache.org/jira/browse/GIRAPH-600


Diffs
-----

  giraph-core/src/main/java/org/apache/giraph/bsp/CentralizedServiceWorker.java 56b5d03 
  giraph-core/src/main/java/org/apache/giraph/conf/GiraphConfiguration.java 963b82a 
  giraph-core/src/main/java/org/apache/giraph/conf/GiraphConstants.java c5b9b93 
  giraph-core/src/main/java/org/apache/giraph/conf/ImmutableClassesGiraphConfiguration.java 76f6105 
  giraph-core/src/main/java/org/apache/giraph/graph/ComputeCallable.java 4840471 
  giraph-core/src/main/java/org/apache/giraph/graph/GraphTaskManager.java 57f7dff 
  giraph-core/src/main/java/org/apache/giraph/io/SimpleVertexWriter.java PRE-CREATION 
  giraph-core/src/main/java/org/apache/giraph/io/VertexWriter.java 38c5548 
  giraph-core/src/main/java/org/apache/giraph/io/superstep_output/MultiThreadedSuperstepOutput.java PRE-CREATION 
  giraph-core/src/main/java/org/apache/giraph/io/superstep_output/NoOpSuperstepOutput.java PRE-CREATION 
  giraph-core/src/main/java/org/apache/giraph/io/superstep_output/SuperstepOutput.java PRE-CREATION 
  giraph-core/src/main/java/org/apache/giraph/io/superstep_output/SynchronizedSuperstepOutput.java PRE-CREATION 
  giraph-core/src/main/java/org/apache/giraph/io/superstep_output/package-info.java PRE-CREATION 
  giraph-core/src/main/java/org/apache/giraph/worker/BspServiceWorker.java 74c1f87 

Diff: https://reviews.apache.org/r/10201/diff/


Testing
-------

mvn clean install
Real application using SynchronizedSuperstepOutput


Thanks,

Maja Kabiljo


Re: Review Request: GIRAPH-600: Create an option to do output during computation

Posted by Maja Kabiljo <ma...@fb.com>.

> On March 29, 2013, 9:32 p.m., Sebastian Schelter wrote:
> > I only had one minor comment in the classes that handles the writers for multithreaded output. Other than that, the patch looks fine.

Sebastian, thank you for a quick review!


- Maja


-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/10201/#review18537
-----------------------------------------------------------


On March 30, 2013, 2:11 a.m., Maja Kabiljo wrote:
> 
> -----------------------------------------------------------
> This is an automatically generated e-mail. To reply, visit:
> https://reviews.apache.org/r/10201/
> -----------------------------------------------------------
> 
> (Updated March 30, 2013, 2:11 a.m.)
> 
> 
> Review request for giraph.
> 
> 
> Description
> -------
> 
> https://issues.apache.org/jira/browse/GIRAPH-600
> 
> 
> This addresses bug GIRAPH-600.
>     https://issues.apache.org/jira/browse/GIRAPH-600
> 
> 
> Diffs
> -----
> 
>   giraph-core/src/main/java/org/apache/giraph/bsp/CentralizedServiceWorker.java 56b5d03 
>   giraph-core/src/main/java/org/apache/giraph/conf/GiraphConfiguration.java 963b82a 
>   giraph-core/src/main/java/org/apache/giraph/conf/GiraphConstants.java c5b9b93 
>   giraph-core/src/main/java/org/apache/giraph/conf/ImmutableClassesGiraphConfiguration.java 76f6105 
>   giraph-core/src/main/java/org/apache/giraph/graph/ComputeCallable.java 4840471 
>   giraph-core/src/main/java/org/apache/giraph/graph/GraphTaskManager.java 57f7dff 
>   giraph-core/src/main/java/org/apache/giraph/io/SimpleVertexWriter.java PRE-CREATION 
>   giraph-core/src/main/java/org/apache/giraph/io/VertexWriter.java 38c5548 
>   giraph-core/src/main/java/org/apache/giraph/io/superstep_output/MultiThreadedSuperstepOutput.java PRE-CREATION 
>   giraph-core/src/main/java/org/apache/giraph/io/superstep_output/NoOpSuperstepOutput.java PRE-CREATION 
>   giraph-core/src/main/java/org/apache/giraph/io/superstep_output/SuperstepOutput.java PRE-CREATION 
>   giraph-core/src/main/java/org/apache/giraph/io/superstep_output/SynchronizedSuperstepOutput.java PRE-CREATION 
>   giraph-core/src/main/java/org/apache/giraph/io/superstep_output/package-info.java PRE-CREATION 
>   giraph-core/src/main/java/org/apache/giraph/worker/BspServiceWorker.java 74c1f87 
> 
> Diff: https://reviews.apache.org/r/10201/diff/
> 
> 
> Testing
> -------
> 
> mvn clean install
> Real application using SynchronizedSuperstepOutput
> 
> 
> Thanks,
> 
> Maja Kabiljo
> 
>


Re: Review Request: GIRAPH-600: Create an option to do output during computation

Posted by Sebastian Schelter <ss...@apache.org>.
-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/10201/#review18537
-----------------------------------------------------------

Ship it!


I only had one minor comment in the classes that handles the writers for multithreaded output. Other than that, the patch looks fine.

- Sebastian Schelter


On March 29, 2013, 9:13 p.m., Maja Kabiljo wrote:
> 
> -----------------------------------------------------------
> This is an automatically generated e-mail. To reply, visit:
> https://reviews.apache.org/r/10201/
> -----------------------------------------------------------
> 
> (Updated March 29, 2013, 9:13 p.m.)
> 
> 
> Review request for giraph.
> 
> 
> Description
> -------
> 
> https://issues.apache.org/jira/browse/GIRAPH-600
> 
> 
> This addresses bug GIRAPH-600.
>     https://issues.apache.org/jira/browse/GIRAPH-600
> 
> 
> Diffs
> -----
> 
>   giraph-core/src/main/java/org/apache/giraph/bsp/CentralizedServiceWorker.java 56b5d03 
>   giraph-core/src/main/java/org/apache/giraph/conf/GiraphConfiguration.java 963b82a 
>   giraph-core/src/main/java/org/apache/giraph/conf/GiraphConstants.java c5b9b93 
>   giraph-core/src/main/java/org/apache/giraph/conf/ImmutableClassesGiraphConfiguration.java 76f6105 
>   giraph-core/src/main/java/org/apache/giraph/graph/ComputeCallable.java 4840471 
>   giraph-core/src/main/java/org/apache/giraph/graph/GraphTaskManager.java 57f7dff 
>   giraph-core/src/main/java/org/apache/giraph/io/SimpleVertexWriter.java PRE-CREATION 
>   giraph-core/src/main/java/org/apache/giraph/io/VertexWriter.java 38c5548 
>   giraph-core/src/main/java/org/apache/giraph/io/superstep_output/MultiThreadedSuperstepOutput.java PRE-CREATION 
>   giraph-core/src/main/java/org/apache/giraph/io/superstep_output/NoOpSuperstepOutput.java PRE-CREATION 
>   giraph-core/src/main/java/org/apache/giraph/io/superstep_output/SuperstepOutput.java PRE-CREATION 
>   giraph-core/src/main/java/org/apache/giraph/io/superstep_output/SynchronizedSuperstepOutput.java PRE-CREATION 
>   giraph-core/src/main/java/org/apache/giraph/io/superstep_output/package-info.java PRE-CREATION 
>   giraph-core/src/main/java/org/apache/giraph/worker/BspServiceWorker.java 74c1f87 
> 
> Diff: https://reviews.apache.org/r/10201/diff/
> 
> 
> Testing
> -------
> 
> mvn clean install
> Real application using SynchronizedSuperstepOutput
> 
> 
> Thanks,
> 
> Maja Kabiljo
> 
>


Re: Review Request: GIRAPH-600: Create an option to do output during computation

Posted by Sebastian Schelter <ss...@apache.org>.
-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/10201/#review18536
-----------------------------------------------------------



giraph-core/src/main/java/org/apache/giraph/io/superstep_output/MultiThreadedSuperstepOutput.java
<https://reviews.apache.org/r/10201/#comment38854>

    Maybe add a check whether all writers were correctly returned?


- Sebastian Schelter


On March 29, 2013, 9:13 p.m., Maja Kabiljo wrote:
> 
> -----------------------------------------------------------
> This is an automatically generated e-mail. To reply, visit:
> https://reviews.apache.org/r/10201/
> -----------------------------------------------------------
> 
> (Updated March 29, 2013, 9:13 p.m.)
> 
> 
> Review request for giraph.
> 
> 
> Description
> -------
> 
> https://issues.apache.org/jira/browse/GIRAPH-600
> 
> 
> This addresses bug GIRAPH-600.
>     https://issues.apache.org/jira/browse/GIRAPH-600
> 
> 
> Diffs
> -----
> 
>   giraph-core/src/main/java/org/apache/giraph/bsp/CentralizedServiceWorker.java 56b5d03 
>   giraph-core/src/main/java/org/apache/giraph/conf/GiraphConfiguration.java 963b82a 
>   giraph-core/src/main/java/org/apache/giraph/conf/GiraphConstants.java c5b9b93 
>   giraph-core/src/main/java/org/apache/giraph/conf/ImmutableClassesGiraphConfiguration.java 76f6105 
>   giraph-core/src/main/java/org/apache/giraph/graph/ComputeCallable.java 4840471 
>   giraph-core/src/main/java/org/apache/giraph/graph/GraphTaskManager.java 57f7dff 
>   giraph-core/src/main/java/org/apache/giraph/io/SimpleVertexWriter.java PRE-CREATION 
>   giraph-core/src/main/java/org/apache/giraph/io/VertexWriter.java 38c5548 
>   giraph-core/src/main/java/org/apache/giraph/io/superstep_output/MultiThreadedSuperstepOutput.java PRE-CREATION 
>   giraph-core/src/main/java/org/apache/giraph/io/superstep_output/NoOpSuperstepOutput.java PRE-CREATION 
>   giraph-core/src/main/java/org/apache/giraph/io/superstep_output/SuperstepOutput.java PRE-CREATION 
>   giraph-core/src/main/java/org/apache/giraph/io/superstep_output/SynchronizedSuperstepOutput.java PRE-CREATION 
>   giraph-core/src/main/java/org/apache/giraph/io/superstep_output/package-info.java PRE-CREATION 
>   giraph-core/src/main/java/org/apache/giraph/worker/BspServiceWorker.java 74c1f87 
> 
> Diff: https://reviews.apache.org/r/10201/diff/
> 
> 
> Testing
> -------
> 
> mvn clean install
> Real application using SynchronizedSuperstepOutput
> 
> 
> Thanks,
> 
> Maja Kabiljo
> 
>


Re: Review Request: GIRAPH-600: Create an option to do output during computation

Posted by Eli Reisman <in...@gmail.com>.
-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/10201/#review18555
-----------------------------------------------------------

Ship it!


I am +1 on this


- Eli Reisman


On March 30, 2013, 2:11 a.m., Maja Kabiljo wrote:
> 
> -----------------------------------------------------------
> This is an automatically generated e-mail. To reply, visit:
> https://reviews.apache.org/r/10201/
> -----------------------------------------------------------
> 
> (Updated March 30, 2013, 2:11 a.m.)
> 
> 
> Review request for giraph.
> 
> 
> Description
> -------
> 
> https://issues.apache.org/jira/browse/GIRAPH-600
> 
> 
> This addresses bug GIRAPH-600.
>     https://issues.apache.org/jira/browse/GIRAPH-600
> 
> 
> Diffs
> -----
> 
>   giraph-core/src/main/java/org/apache/giraph/bsp/CentralizedServiceWorker.java 56b5d03 
>   giraph-core/src/main/java/org/apache/giraph/conf/GiraphConfiguration.java 963b82a 
>   giraph-core/src/main/java/org/apache/giraph/conf/GiraphConstants.java c5b9b93 
>   giraph-core/src/main/java/org/apache/giraph/conf/ImmutableClassesGiraphConfiguration.java 76f6105 
>   giraph-core/src/main/java/org/apache/giraph/graph/ComputeCallable.java 4840471 
>   giraph-core/src/main/java/org/apache/giraph/graph/GraphTaskManager.java 57f7dff 
>   giraph-core/src/main/java/org/apache/giraph/io/SimpleVertexWriter.java PRE-CREATION 
>   giraph-core/src/main/java/org/apache/giraph/io/VertexWriter.java 38c5548 
>   giraph-core/src/main/java/org/apache/giraph/io/superstep_output/MultiThreadedSuperstepOutput.java PRE-CREATION 
>   giraph-core/src/main/java/org/apache/giraph/io/superstep_output/NoOpSuperstepOutput.java PRE-CREATION 
>   giraph-core/src/main/java/org/apache/giraph/io/superstep_output/SuperstepOutput.java PRE-CREATION 
>   giraph-core/src/main/java/org/apache/giraph/io/superstep_output/SynchronizedSuperstepOutput.java PRE-CREATION 
>   giraph-core/src/main/java/org/apache/giraph/io/superstep_output/package-info.java PRE-CREATION 
>   giraph-core/src/main/java/org/apache/giraph/worker/BspServiceWorker.java 74c1f87 
> 
> Diff: https://reviews.apache.org/r/10201/diff/
> 
> 
> Testing
> -------
> 
> mvn clean install
> Real application using SynchronizedSuperstepOutput
> 
> 
> Thanks,
> 
> Maja Kabiljo
> 
>


Re: Review Request: GIRAPH-600: Create an option to do output during computation

Posted by Sebastian Schelter <ss...@apache.org>.
-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/10201/#review18556
-----------------------------------------------------------

Ship it!


Ship It!

- Sebastian Schelter


On March 30, 2013, 2:11 a.m., Maja Kabiljo wrote:
> 
> -----------------------------------------------------------
> This is an automatically generated e-mail. To reply, visit:
> https://reviews.apache.org/r/10201/
> -----------------------------------------------------------
> 
> (Updated March 30, 2013, 2:11 a.m.)
> 
> 
> Review request for giraph.
> 
> 
> Description
> -------
> 
> https://issues.apache.org/jira/browse/GIRAPH-600
> 
> 
> This addresses bug GIRAPH-600.
>     https://issues.apache.org/jira/browse/GIRAPH-600
> 
> 
> Diffs
> -----
> 
>   giraph-core/src/main/java/org/apache/giraph/bsp/CentralizedServiceWorker.java 56b5d03 
>   giraph-core/src/main/java/org/apache/giraph/conf/GiraphConfiguration.java 963b82a 
>   giraph-core/src/main/java/org/apache/giraph/conf/GiraphConstants.java c5b9b93 
>   giraph-core/src/main/java/org/apache/giraph/conf/ImmutableClassesGiraphConfiguration.java 76f6105 
>   giraph-core/src/main/java/org/apache/giraph/graph/ComputeCallable.java 4840471 
>   giraph-core/src/main/java/org/apache/giraph/graph/GraphTaskManager.java 57f7dff 
>   giraph-core/src/main/java/org/apache/giraph/io/SimpleVertexWriter.java PRE-CREATION 
>   giraph-core/src/main/java/org/apache/giraph/io/VertexWriter.java 38c5548 
>   giraph-core/src/main/java/org/apache/giraph/io/superstep_output/MultiThreadedSuperstepOutput.java PRE-CREATION 
>   giraph-core/src/main/java/org/apache/giraph/io/superstep_output/NoOpSuperstepOutput.java PRE-CREATION 
>   giraph-core/src/main/java/org/apache/giraph/io/superstep_output/SuperstepOutput.java PRE-CREATION 
>   giraph-core/src/main/java/org/apache/giraph/io/superstep_output/SynchronizedSuperstepOutput.java PRE-CREATION 
>   giraph-core/src/main/java/org/apache/giraph/io/superstep_output/package-info.java PRE-CREATION 
>   giraph-core/src/main/java/org/apache/giraph/worker/BspServiceWorker.java 74c1f87 
> 
> Diff: https://reviews.apache.org/r/10201/diff/
> 
> 
> Testing
> -------
> 
> mvn clean install
> Real application using SynchronizedSuperstepOutput
> 
> 
> Thanks,
> 
> Maja Kabiljo
> 
>


Re: Review Request: GIRAPH-600: Create an option to do output during computation

Posted by Maja Kabiljo <ma...@fb.com>.

> On March 30, 2013, 6:53 a.m., Eli Reisman wrote:
> > Great idea. Hey have you considered using (or abusing) OutputCommitter#commitTask, which must be called per-task to save each tasks' results for the superstep? It is normally used at the end of a job but could be used per-superstep to just bulk dump all the vertices output data anytime you want in the processing loop.
> >

I tried using that, but for some reason it didn't work for me, maybe I should try again. But I agree with the idea - we do want to have an option to dump these output files per superstep. 


- Maja


-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/10201/#review18554
-----------------------------------------------------------


On March 30, 2013, 2:11 a.m., Maja Kabiljo wrote:
> 
> -----------------------------------------------------------
> This is an automatically generated e-mail. To reply, visit:
> https://reviews.apache.org/r/10201/
> -----------------------------------------------------------
> 
> (Updated March 30, 2013, 2:11 a.m.)
> 
> 
> Review request for giraph.
> 
> 
> Description
> -------
> 
> https://issues.apache.org/jira/browse/GIRAPH-600
> 
> 
> This addresses bug GIRAPH-600.
>     https://issues.apache.org/jira/browse/GIRAPH-600
> 
> 
> Diffs
> -----
> 
>   giraph-core/src/main/java/org/apache/giraph/bsp/CentralizedServiceWorker.java 56b5d03 
>   giraph-core/src/main/java/org/apache/giraph/conf/GiraphConfiguration.java 963b82a 
>   giraph-core/src/main/java/org/apache/giraph/conf/GiraphConstants.java c5b9b93 
>   giraph-core/src/main/java/org/apache/giraph/conf/ImmutableClassesGiraphConfiguration.java 76f6105 
>   giraph-core/src/main/java/org/apache/giraph/graph/ComputeCallable.java 4840471 
>   giraph-core/src/main/java/org/apache/giraph/graph/GraphTaskManager.java 57f7dff 
>   giraph-core/src/main/java/org/apache/giraph/io/SimpleVertexWriter.java PRE-CREATION 
>   giraph-core/src/main/java/org/apache/giraph/io/VertexWriter.java 38c5548 
>   giraph-core/src/main/java/org/apache/giraph/io/superstep_output/MultiThreadedSuperstepOutput.java PRE-CREATION 
>   giraph-core/src/main/java/org/apache/giraph/io/superstep_output/NoOpSuperstepOutput.java PRE-CREATION 
>   giraph-core/src/main/java/org/apache/giraph/io/superstep_output/SuperstepOutput.java PRE-CREATION 
>   giraph-core/src/main/java/org/apache/giraph/io/superstep_output/SynchronizedSuperstepOutput.java PRE-CREATION 
>   giraph-core/src/main/java/org/apache/giraph/io/superstep_output/package-info.java PRE-CREATION 
>   giraph-core/src/main/java/org/apache/giraph/worker/BspServiceWorker.java 74c1f87 
> 
> Diff: https://reviews.apache.org/r/10201/diff/
> 
> 
> Testing
> -------
> 
> mvn clean install
> Real application using SynchronizedSuperstepOutput
> 
> 
> Thanks,
> 
> Maja Kabiljo
> 
>


Re: Review Request: GIRAPH-600: Create an option to do output during computation

Posted by Eli Reisman <in...@gmail.com>.
-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/10201/#review18554
-----------------------------------------------------------


Great idea. Hey have you considered using (or abusing) OutputCommitter#commitTask, which must be called per-task to save each tasks' results for the superstep? It is normally used at the end of a job but could be used per-superstep to just bulk dump all the vertices output data anytime you want in the processing loop.


- Eli Reisman


On March 30, 2013, 2:11 a.m., Maja Kabiljo wrote:
> 
> -----------------------------------------------------------
> This is an automatically generated e-mail. To reply, visit:
> https://reviews.apache.org/r/10201/
> -----------------------------------------------------------
> 
> (Updated March 30, 2013, 2:11 a.m.)
> 
> 
> Review request for giraph.
> 
> 
> Description
> -------
> 
> https://issues.apache.org/jira/browse/GIRAPH-600
> 
> 
> This addresses bug GIRAPH-600.
>     https://issues.apache.org/jira/browse/GIRAPH-600
> 
> 
> Diffs
> -----
> 
>   giraph-core/src/main/java/org/apache/giraph/bsp/CentralizedServiceWorker.java 56b5d03 
>   giraph-core/src/main/java/org/apache/giraph/conf/GiraphConfiguration.java 963b82a 
>   giraph-core/src/main/java/org/apache/giraph/conf/GiraphConstants.java c5b9b93 
>   giraph-core/src/main/java/org/apache/giraph/conf/ImmutableClassesGiraphConfiguration.java 76f6105 
>   giraph-core/src/main/java/org/apache/giraph/graph/ComputeCallable.java 4840471 
>   giraph-core/src/main/java/org/apache/giraph/graph/GraphTaskManager.java 57f7dff 
>   giraph-core/src/main/java/org/apache/giraph/io/SimpleVertexWriter.java PRE-CREATION 
>   giraph-core/src/main/java/org/apache/giraph/io/VertexWriter.java 38c5548 
>   giraph-core/src/main/java/org/apache/giraph/io/superstep_output/MultiThreadedSuperstepOutput.java PRE-CREATION 
>   giraph-core/src/main/java/org/apache/giraph/io/superstep_output/NoOpSuperstepOutput.java PRE-CREATION 
>   giraph-core/src/main/java/org/apache/giraph/io/superstep_output/SuperstepOutput.java PRE-CREATION 
>   giraph-core/src/main/java/org/apache/giraph/io/superstep_output/SynchronizedSuperstepOutput.java PRE-CREATION 
>   giraph-core/src/main/java/org/apache/giraph/io/superstep_output/package-info.java PRE-CREATION 
>   giraph-core/src/main/java/org/apache/giraph/worker/BspServiceWorker.java 74c1f87 
> 
> Diff: https://reviews.apache.org/r/10201/diff/
> 
> 
> Testing
> -------
> 
> mvn clean install
> Real application using SynchronizedSuperstepOutput
> 
> 
> Thanks,
> 
> Maja Kabiljo
> 
>


Re: Review Request: GIRAPH-600: Create an option to do output during computation

Posted by Maja Kabiljo <ma...@fb.com>.
-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/10201/
-----------------------------------------------------------

(Updated March 30, 2013, 2:11 a.m.)


Review request for giraph.


Changes
-------

Add tracking for occupied VertexWriters in MultiThreadedSuperstepOutput.


Description
-------

https://issues.apache.org/jira/browse/GIRAPH-600


This addresses bug GIRAPH-600.
    https://issues.apache.org/jira/browse/GIRAPH-600


Diffs (updated)
-----

  giraph-core/src/main/java/org/apache/giraph/bsp/CentralizedServiceWorker.java 56b5d03 
  giraph-core/src/main/java/org/apache/giraph/conf/GiraphConfiguration.java 963b82a 
  giraph-core/src/main/java/org/apache/giraph/conf/GiraphConstants.java c5b9b93 
  giraph-core/src/main/java/org/apache/giraph/conf/ImmutableClassesGiraphConfiguration.java 76f6105 
  giraph-core/src/main/java/org/apache/giraph/graph/ComputeCallable.java 4840471 
  giraph-core/src/main/java/org/apache/giraph/graph/GraphTaskManager.java 57f7dff 
  giraph-core/src/main/java/org/apache/giraph/io/SimpleVertexWriter.java PRE-CREATION 
  giraph-core/src/main/java/org/apache/giraph/io/VertexWriter.java 38c5548 
  giraph-core/src/main/java/org/apache/giraph/io/superstep_output/MultiThreadedSuperstepOutput.java PRE-CREATION 
  giraph-core/src/main/java/org/apache/giraph/io/superstep_output/NoOpSuperstepOutput.java PRE-CREATION 
  giraph-core/src/main/java/org/apache/giraph/io/superstep_output/SuperstepOutput.java PRE-CREATION 
  giraph-core/src/main/java/org/apache/giraph/io/superstep_output/SynchronizedSuperstepOutput.java PRE-CREATION 
  giraph-core/src/main/java/org/apache/giraph/io/superstep_output/package-info.java PRE-CREATION 
  giraph-core/src/main/java/org/apache/giraph/worker/BspServiceWorker.java 74c1f87 

Diff: https://reviews.apache.org/r/10201/diff/


Testing
-------

mvn clean install
Real application using SynchronizedSuperstepOutput


Thanks,

Maja Kabiljo