Details
-
Bug
-
Status: Closed
-
Major
-
Resolution: Fixed
-
None
-
None
-
Reviewed
Description
In JoinOperator's processOp()
if(alias == numAliases -1){ if (sz == joinEmitInterval) {
should be changed to
if(alias == numAliases - 1 && !(handleSkewJoin && skewJoinKeyContext.currBigKeyTag >= 0)