[
https://issues.apache.org/jira/browse/FLINK-2293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14620116#comment-14620116
]
Stephan Ewen commented on FLINK-2293:
-------------------------------------
[~andralungu] The line numbers in your stack trace (where the exception occurs,
and the frame below as well) correspond to empty lines or comment lines in the
source code of the latest master.
See here:
https://github.com/apache/flink/blob/master/flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash/MutableHashTable.java#L836
Are you sure you are using the code after I added the patch?
> Division by Zero Exception
> --------------------------
>
> Key: FLINK-2293
> URL: https://issues.apache.org/jira/browse/FLINK-2293
> Project: Flink
> Issue Type: Bug
> Components: Local Runtime
> Affects Versions: 0.9, 0.10
> Reporter: Andra Lungu
> Assignee: Stephan Ewen
> Priority: Critical
> Fix For: 0.10, 0.9.1
>
>
> I am basically running an algorithm that simulates a Gather Sum Apply
> Iteration that performs Traingle Count (Why simulate it? Because you just
> need a superstep -> useless overhead if you use the runGatherSumApply
> function in Graph).
> What happens, at a high level:
> 1). Select neighbors with ID greater than the one corresponding to the
> current vertex;
> 2). Propagate the received values to neighbors with higher ID;
> 3). compute the number of triangles by checking whether
> trgVertex.getValue().get(srcVertex.getId());
> As you can see, I *do not* perform any division at all;
> code is here:
> https://github.com/andralungu/gelly-partitioning/blob/master/src/main/java/example/GSATriangleCount.java
> Now for small graphs, 50MB max, the computation finishes nicely with the
> correct result. For a 10GB graph, however, I got this:
> java.lang.ArithmeticException: / by zero
> at
> org.apache.flink.runtime.operators.hash.MutableHashTable.insertIntoTable(MutableHashTable.java:836)
> at
> org.apache.flink.runtime.operators.hash.MutableHashTable.buildTableFromSpilledPartition(MutableHashTable.java:819)
> at
> org.apache.flink.runtime.operators.hash.MutableHashTable.prepareNextPartition(MutableHashTable.java:508)
> at
> org.apache.flink.runtime.operators.hash.MutableHashTable.nextRecord(MutableHashTable.java:544)
> at
> org.apache.flink.runtime.operators.hash.NonReusingBuildFirstHashMatchIterator.callWithNextKey(NonReusingBuildFirstHashMatchIterator.java:104)
> at
> org.apache.flink.runtime.operators.MatchDriver.run(MatchDriver.java:173)
> at
> org.apache.flink.runtime.operators.RegularPactTask.run(RegularPactTask.java:496)
> at
> org.apache.flink.runtime.operators.RegularPactTask.invoke(RegularPactTask.java:362)
> at org.apache.flink.runtime.taskmanager.Task.run(Task.java:559)
> at java.lang.Thread.run(Thread.java:722)
> see the full log here: https://gist.github.com/andralungu/984774f6348269df7951
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
