You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pig.apache.org by zl...@apache.org on 2017/04/28 08:55:07 UTC
svn commit: r1793017 -
/pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/SecondaryKeySortUtil.java
Author: zly
Date: Fri Apr 28 08:55:06 2017
New Revision: 1793017
URL: http://svn.apache.org/viewvc?rev=1793017&view=rev
Log:
PIG-5230:Fix the RuntimeException throws in SecondaryKeySortUtil(Liyun)
Modified:
pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/SecondaryKeySortUtil.java
Modified: pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/SecondaryKeySortUtil.java
URL: http://svn.apache.org/viewvc/pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/SecondaryKeySortUtil.java?rev=1793017&r1=1793016&r2=1793017&view=diff
==============================================================================
--- pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/SecondaryKeySortUtil.java (original)
+++ pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/SecondaryKeySortUtil.java Fri Apr 28 08:55:06 2017
@@ -113,8 +113,8 @@ public class SecondaryKeySortUtil {
throw new RuntimeException("AccumulateByKey throw exception: ", e);
}
}
- if (curKey == null) {
- throw new RuntimeException("AccumulateByKey curKey is null");
+ if (!initialized) {
+ throw new RuntimeException("No tuples seen");
}
//if we get here, this should be the last record