shpark commented on a change in pull request #81: [NEMO-151] Add OutputWriters
for additional tagged outputs
URL: https://github.com/apache/incubator-nemo/pull/81#discussion_r203946134
##########
File path:
compiler/optimizer/src/main/java/edu/snu/nemo/compiler/optimizer/pass/compiletime/reshaping/SailfishRelayReshapingPass.java
##########
@@ -60,6 +62,21 @@ public SailfishRelayReshapingPass() {
// before the vertex receiving shuffled data.
final OperatorVertex iFileMergerVertex = new OperatorVertex(new
RelayTransform());
iFileMergerVertex.getExecutionProperties().put(SkipSerDesProperty.of());
+
+ // Update additional tagged output property of the source vertex
if necessary.
Review comment:
Due to current implementation that relies on execution property to route
additional outputs to different children, we must update the execution property
to send data to the inserted vertex, properly. Even if we store information
directly to the vertex and edges, without using execution property (similar to
`isSideInput()` for runtime edges), we should always update destination
information every time we insert a new vertex. In this context,
[NEMO-162](https://issues.apache.org/jira/projects/NEMO/issues/NEMO-162)
suggest that we provide a high-level api for inserting a new vertex, which can
perform these kinds of checks internally.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
With regards,
Apache Git Services
