[
https://issues.apache.org/jira/browse/FLINK-1520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14900370#comment-14900370
]
ASF GitHub Bot commented on FLINK-1520:
---------------------------------------
Github user vasia commented on a diff in the pull request:
https://github.com/apache/flink/pull/1149#discussion_r39948730
--- Diff:
flink-staging/flink-gelly/src/main/java/org/apache/flink/graph/example/IncrementalSSSP.java
---
@@ -110,24 +105,20 @@ public static void main(String [] args) throws
Exception {
// Emit results
if(fileOutput) {
resultedVertices.writeAsCsv(outputPath, "\n",
",");
-
- // since file sinks are lazy, we trigger the
execution explicitly
- env.execute("Incremental SSSP Example");
} else {
resultedVertices.print();
}
+ env.execute("Incremental SSSP Example");
--- End diff --
That's result of auto-merge I guess. Thanks for spotting it!
> Read edges and vertices from CSV files
> --------------------------------------
>
> Key: FLINK-1520
> URL: https://issues.apache.org/jira/browse/FLINK-1520
> Project: Flink
> Issue Type: New Feature
> Components: Gelly
> Reporter: Vasia Kalavri
> Assignee: Vasia Kalavri
> Priority: Minor
> Labels: easyfix, newbie
>
> Add methods to create Vertex and Edge Datasets directly from CSV file inputs.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
