Return-Path: 
 <user-return-2671-apmail-flink-user-archive=flink.apache.org@flink.apache.org>
X-Original-To: apmail-flink-user-archive@minotaur.apache.org
Delivered-To: apmail-flink-user-archive@minotaur.apache.org
Received: from mail.apache.org (hermes.apache.org [140.211.11.3])
	by minotaur.apache.org (Postfix) with SMTP id A1279186CC
	for <apmail-flink-user-archive@minotaur.apache.org>;
 Fri,  4 Sep 2015 14:35:02 +0000 (UTC)
Received: (qmail 5364 invoked by uid 500); 4 Sep 2015 14:35:02 -0000
Delivered-To: apmail-flink-user-archive@flink.apache.org
Received: (qmail 5289 invoked by uid 500); 4 Sep 2015 14:35:02 -0000
Mailing-List: contact user-help@flink.apache.org; run by ezmlm
Precedence: bulk
List-Help: <mailto:user-help@flink.apache.org>
List-Unsubscribe: <mailto:user-unsubscribe@flink.apache.org>
List-Post: <mailto:user@flink.apache.org>
List-Id: <user.flink.apache.org>
Reply-To: user@flink.apache.org
Delivered-To: mailing list user@flink.apache.org
Received: (qmail 5279 invoked by uid 99); 4 Sep 2015 14:35:02 -0000
Received: from Unknown (HELO spamd4-us-west.apache.org) (209.188.14.142)
    by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 04 Sep 2015 14:35:02 +0000
Received: from localhost (localhost [127.0.0.1])
	by spamd4-us-west.apache.org (ASF Mail Server at spamd4-us-west.apache.org)
 with ESMTP id 05B39C0867
	for <user@flink.apache.org>; Fri,  4 Sep 2015 14:35:02 +0000 (UTC)
X-Virus-Scanned: Debian amavisd-new at spamd4-us-west.apache.org
X-Spam-Flag: NO
X-Spam-Score: 3.98
X-Spam-Level: ***
X-Spam-Status: No, score=3.98 tagged_above=-999 required=6.31
	tests=[HTML_MESSAGE=3, KAM_LAZY_DOMAIN_SECURITY=1,
	RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01] autolearn=disabled
Received: from mx1-eu-west.apache.org ([10.40.0.8])
	by localhost (spamd4-us-west.apache.org [10.40.0.11]) (amavisd-new,
 port 10024)
	with ESMTP id xN5aMKpo9Dam for <user@flink.apache.org>;
	Fri,  4 Sep 2015 14:35:00 +0000 (UTC)
Received: from mail-yk0-f182.google.com (mail-yk0-f182.google.com
 [209.85.160.182])
	by mx1-eu-west.apache.org (ASF Mail Server at mx1-eu-west.apache.org) with
 ESMTPS id D938C2770D
	for <user@flink.apache.org>; Fri,  4 Sep 2015 14:34:59 +0000 (UTC)
Received: by ykei199 with SMTP id i199so22509349yke.0
        for <user@flink.apache.org>; Fri, 04 Sep 2015 07:34:53 -0700 (PDT)
X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed;
        d=1e100.net; s=20130820;
        h=x-gm-message-state:mime-version:from:date:message-id:subject:to
         :content-type;
        bh=B9OUzCdmggGsrHSQFO0Ilq8gEYMmDwWS4h3iCaY/VcA=;
        b=gM6VH4KWXBtQbYMUZss01xDxOI6hkj7sZ2gNMvq9/PSaYd+Pz56fVZdiZzAx6pfskF
         IuTRhUnDi5xynCxGyCzhzt3wG5fungq1OPmifYi9Yil8KUHvN9M/quWTFYra7pyO2bri
         G5J3a5U505+2k259E9t4MhN5p2joxXPyYhg7Z2Cdg8RTeCcb4z1NSLwiAxKIcxBnLQfF
         7CM+YhngzjsqsmN3yrbk0N3XqvOXZDl7SnzFhpCI4B2I73ZC6zx4N9f455JDxXYf0GXS
         33QphvhPkRZYg1gON9ePvv+wFJ0NubNC9F0CT73FGJ+qGkqXeaWltieuL61WyX2h+Yy+
         HNPQ==
X-Gm-Message-State: 
 ALoCoQm/K8qoCUO70AYOmHSw3rXNygjgEk07eMSk0q5CZXx4es+SmFQEI9c9IDTAGRhTtwwD6r2U
X-Received: by 10.170.212.195 with SMTP id d186mr4516985ykf.124.1441377293267;
 Fri, 04 Sep 2015 07:34:53 -0700 (PDT)
MIME-Version: 1.0
Received: by 10.129.70.195 with HTTP; Fri, 4 Sep 2015 07:34:31 -0700 (PDT)
X-Originating-IP: [213.203.177.29]
From: Flavio Pompermaier <pompermaier@okkam.it>
Date: Fri, 4 Sep 2015 16:34:31 +0200
Message-ID: 
 <CAELUF_DOjuSMcM9agMTvnKODUEarPR2Hz+rwVbcV8YNxz1XePQ@mail.gmail.com>
Subject: BloomFilter Exception
To: user <user@flink.apache.org>
Content-Type: multipart/alternative; boundary=001a1139f6b88da70e051eeccd1b

--001a1139f6b88da70e051eeccd1b
Content-Type: text/plain; charset=UTF-8

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

--001a1139f6b88da70e051eeccd1b
Content-Type: text/html; charset=UTF-8
Content-Transfer-Encoding: quoted-printable

<div dir=3D"ltr">Hi to all,<div>running a job with Flink 0/10-SNAPSHOT I go=
t the following Exception:</div><div><br></div><div><div>java.lang.IllegalA=
rgumentException: expectedEntries should be &gt; 0</div><div>=C2=A0 =C2=A0 =
=C2=A0 =C2=A0 at org.apache.flink.shaded.com.google.common.base.Preconditio=
ns.checkArgument(Preconditions.java:122)</div><div>=C2=A0 =C2=A0 =C2=A0 =C2=
=A0 at org.apache.flink.runtime.operators.util.BloomFilter.&lt;init&gt;(Blo=
omFilter.java:53)</div><div>=C2=A0 =C2=A0 =C2=A0 =C2=A0 at org.apache.flink=
.runtime.operators.hash.MutableHashTable.initBloomFilter(MutableHashTable.j=
ava:711)</div><div>=C2=A0 =C2=A0 =C2=A0 =C2=A0 at org.apache.flink.runtime.=
operators.hash.MutableHashTable.initTable(MutableHashTable.java:1073)</div>=
<div>=C2=A0 =C2=A0 =C2=A0 =C2=A0 at org.apache.flink.runtime.operators.hash=
.MutableHashTable.buildTableFromSpilledPartition(MutableHashTable.java:778)=
</div><div>=C2=A0 =C2=A0 =C2=A0 =C2=A0 at org.apache.flink.runtime.operator=
s.hash.MutableHashTable.prepareNextPartition(MutableHashTable.java:530)</di=
v><div>=C2=A0 =C2=A0 =C2=A0 =C2=A0 at org.apache.flink.runtime.operators.ha=
sh.MutableHashTable.nextRecord(MutableHashTable.java:563)</div><div>=C2=A0 =
=C2=A0 =C2=A0 =C2=A0 at org.apache.flink.runtime.operators.hash.NonReusingB=
uildFirstHashMatchIterator.callWithNextKey(NonReusingBuildFirstHashMatchIte=
rator.java:104)</div><div>=C2=A0 =C2=A0 =C2=A0 =C2=A0 at org.apache.flink.r=
untime.operators.JoinDriver.run(JoinDriver.java:208)</div><div>=C2=A0 =C2=
=A0 =C2=A0 =C2=A0 at org.apache.flink.runtime.operators.RegularPactTask.run=
(RegularPactTask.java:489)</div><div>=C2=A0 =C2=A0 =C2=A0 =C2=A0 at org.apa=
che.flink.runtime.operators.RegularPactTask.invoke(RegularPactTask.java:354=
)</div><div>=C2=A0 =C2=A0 =C2=A0 =C2=A0 at org.apache.flink.runtime.taskman=
ager.Task.run(Task.java:581)</div><div>=C2=A0 =C2=A0 =C2=A0 =C2=A0 at java.=
lang.Thread.run(Thread.java:745)</div></div><div><br></div><div>Is it a bug=
?</div><div><br></div><div>Best,</div><div>Flavio</div></div>

--001a1139f6b88da70e051eeccd1b--