BloomFilter Exception

[Flavio Pompermaier]

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

[Greg Hogan]

Flavio,

It looks like your build is older than some recent fixes in that code.

https://github.com/apache/flink/commits/2e6e4de5d1d2b5123f4311493763fd84f52779ab/flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash/MutableHashTable.java

Greg

On Fri, Sep 4, 2015 at 10:34 AM, Flavio Pompermaier <[hidden email]> wrote:

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 Pompermaier]

ah ok,
I'll try to force the update my maven dependencies!

Thanks for the support,
Flavio

On 5 Sep 2015 14:56, "Greg Hogan" <[hidden email]> wrote:

Flavio,

It looks like your build is older than some recent fixes in that code.

https://github.com/apache/flink/commits/2e6e4de5d1d2b5123f4311493763fd84f52779ab/flink-runtime/src/main/java/org/apache/flink/runtime/operators/hash/MutableHashTable.java

Greg

On Fri, Sep 4, 2015 at 10:34 AM, Flavio Pompermaier <[hidden email]> wrote:

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