flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Flavio Pompermaier <pomperma...@okkam.it>
Subject BloomFilter Exception
Date Fri, 04 Sep 2015 14:34:31 GMT
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

Mime
View raw message