Hi to all,
running a job with Flink 0/10-SNAPSHOT I got the following Exception: java.lang.IllegalArgumentException: expectedEntries should be > 0 at org.apache.flink.shaded.com.google.common.base.Preconditions.checkArgument(Preconditions.java:122) at org.apache.flink.runtime.operators.util.BloomFilter.<init>(BloomFilter.java:53) at org.apache.flink.runtime.operators.hash.MutableHashTable.initBloomFilter(MutableHashTable.java:711) at org.apache.flink.runtime.operators.hash.MutableHashTable.initTable(MutableHashTable.java:1073) at org.apache.flink.runtime.operators.hash.MutableHashTable.buildTableFromSpilledPartition(MutableHashTable.java:778) at org.apache.flink.runtime.operators.hash.MutableHashTable.prepareNextPartition(MutableHashTable.java:530) at org.apache.flink.runtime.operators.hash.MutableHashTable.nextRecord(MutableHashTable.java:563) at org.apache.flink.runtime.operators.hash.NonReusingBuildFirstHashMatchIterator.callWithNextKey(NonReusingBuildFirstHashMatchIterator.java:104) at org.apache.flink.runtime.operators.JoinDriver.run(JoinDriver.java:208) at org.apache.flink.runtime.operators.RegularPactTask.run(RegularPactTask.java:489) at org.apache.flink.runtime.operators.RegularPactTask.invoke(RegularPactTask.java:354) at org.apache.flink.runtime.taskmanager.Task.run(Task.java:581) at java.lang.Thread.run(Thread.java:745) Is it a bug? Best, Flavio |
Flavio, It looks like your build is older than some recent fixes in that code. Greg On Fri, Sep 4, 2015 at 10:34 AM, Flavio Pompermaier <[hidden email]> wrote:
|
ah ok, Thanks for the support, On 5 Sep 2015 14:56, "Greg Hogan" <[hidden email]> wrote:
|
Free forum by Nabble | Edit this page |