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
