Mailing-List: contact user-help@flink.apache.org; run by ezmlm
Precedence: bulk
Reply-To: user@flink.apache.org
Received-SPF: pass (athena.apache.org: message received from 54.164.171.186
 which is an MX secondary for user@flink.apache.org)
MIME-Version: 1.0
From: Flavio Pompermaier <pompermaier@okkam.it>
Date: Fri, 17 Apr 2015 14:03:11 +0200
Message-ID: 
 <CAELUF_A00D+2n9aaKwMuL8ssEFzObvZdv-j7vMu=CgQf4bSDWw@mail.gmail.com>
Subject: Hash join exceeded exception
To: user <user@flink.apache.org>
Content-Type: multipart/alternative; boundary=047d7bfcec487388460513ea5ef7

--047d7bfcec487388460513ea5ef7
Content-Type: text/plain; charset=UTF-8

Hi to all,
I have this strange exception in my program, do you know what could be the
cause of it?

java.lang.RuntimeException: Hash join exceeded maximum number of
recursions, without reducing partitions enough to be memory resident.
Probably cause: Too many duplicate keys.
at
org.apache.flink.runtime.operators.hash.MutableHashTable.buildTableFromSpilledPartition(MutableHashTable.java:720)
at
org.apache.flink.runtime.operators.hash.MutableHashTable.prepareNextPartition(MutableHashTable.java:508)
at
org.apache.flink.runtime.operators.hash.MutableHashTable.nextRecord(MutableHashTable.java:541)
at
org.apache.flink.runtime.operators.hash.NonReusingBuildSecondHashMatchIterator.callWithNextKey(NonReusingBuildSecondHashMatchIterator.java:102)
at org.apache.flink.runtime.operators.MatchDriver.run(MatchDriver.java:173)
at
org.apache.flink.runtime.operators.RegularPactTask.run(RegularPactTask.java:494)
at
org.apache.flink.runtime.operators.RegularPactTask.invoke(RegularPactTask.java:360)
at
org.apache.flink.runtime.execution.RuntimeEnvironment.run(RuntimeEnvironment.java:221)
at java.lang.Thread.run(Thread.java:745)

Best,
Flavio

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

<div dir=3D"ltr"><div>Hi to all,</div><div>I have this strange exception in=
 my program, do you know what could be the cause of it?</div><div><br><div>=
java.lang.RuntimeException: Hash join exceeded maximum number of recursions=
, without reducing partitions enough to be memory resident. Probably cause:=
 Too many duplicate keys.</div><div><span class=3D"" style=3D"white-space:p=
re">	</span>at org.apache.flink.runtime.operators.hash.MutableHashTable.bui=
ldTableFromSpilledPartition(MutableHashTable.java:720)</div><div><span clas=
s=3D"" style=3D"white-space:pre">	</span>at org.apache.flink.runtime.operat=
ors.hash.MutableHashTable.prepareNextPartition(MutableHashTable.java:508)</=
div><div><span class=3D"" style=3D"white-space:pre">	</span>at org.apache.f=
link.runtime.operators.hash.MutableHashTable.nextRecord(MutableHashTable.ja=
va:541)</div><div><span class=3D"" style=3D"white-space:pre">	</span>at org=
.apache.flink.runtime.operators.hash.NonReusingBuildSecondHashMatchIterator=
.callWithNextKey(NonReusingBuildSecondHashMatchIterator.java:102)</div><div=
><span class=3D"" style=3D"white-space:pre">	</span>at org.apache.flink.run=
time.operators.MatchDriver.run(MatchDriver.java:173)</div><div><span class=
=3D"" style=3D"white-space:pre">	</span>at org.apache.flink.runtime.operato=
rs.RegularPactTask.run(RegularPactTask.java:494)</div><div><span class=3D""=
 style=3D"white-space:pre">	</span>at org.apache.flink.runtime.operators.Re=
gularPactTask.invoke(RegularPactTask.java:360)</div><div><span class=3D"" s=
tyle=3D"white-space:pre">	</span>at org.apache.flink.runtime.execution.Runt=
imeEnvironment.run(RuntimeEnvironment.java:221)</div><div><span class=3D"" =
style=3D"white-space:pre">	</span>at java.lang.Thread.run(Thread.java:745)<=
/div></div><div><br></div><div>Best,</div><div>Flavio</div><div class=3D"gm=
ail_signature"><div dir=3D"ltr"><p></p><p></p><p></p><p></p></div></div>
</div>

--047d7bfcec487388460513ea5ef7--