pig-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From z..@apache.org
Subject svn commit: r1793017 - /pig/branches/spark/src/org/apache/pig/backend/hadoop/executionengine/spark/converter/SecondaryKeySortUtil.java
Date Fri, 28 Apr 2017 08:55:07 GMT
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



Mime
View raw message