[ https://issues.apache.org/jira/browse/GIRAPH-745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14001025#comment-14001025 ]
Akila Wajirasena commented on GIRAPH-745: ----------------------------------------- While I was implementing this I found that BspServiceWorker saveEdges has some duplicate code in line 1150 & 1156 {code} ProgressableUtils.getResultsWithNCallables(callableFactory, numThreads, "save-vertices-%d", getContext()); LoggerUtils.setStatusAndLog(getContext(), LOG, Level.INFO, "saveEdges: Done saving edges."); // YARN: must complete the commit the "task" output, Hadoop isn't there. if (conf.isPureYarnJob() && conf.getVertexOutputFormatClass() != null) { try { OutputCommitter outputCommitter = edgeOutputFormat.getOutputCommitter(getContext()); if (outputCommitter.needsTaskCommit(getContext())) { {code} I think {{"save-vertices-%d"}} and {{conf.getVertexOutputFormatClass()}} != null should be changed appropriately. Please comment. > add support for EdgeOutputFormat also for giraph-hive > ----------------------------------------------------- > > Key: GIRAPH-745 > URL: https://issues.apache.org/jira/browse/GIRAPH-745 > Project: Giraph > Issue Type: Improvement > Reporter: Claudio Martella > Assignee: Akila Wajirasena > > should be able to write edges through EdgeOutputFormat to Hive tables. -- This message was sent by Atlassian JIRA (v6.2#6252)