-
Type:
Sub-task
-
Status: Closed
-
Priority:
Major
-
Resolution: Fixed
-
Affects Version/s: None
-
Fix Version/s: spark-branch
-
Component/s: spark
-
Labels:None
Scenario:
1. input data:
cat collectedgroup1
1 1 2
2. pig script:
A = LOAD 'collectedgroup1' USING myudfs.DummyCollectableLoader() AS (id); B = GROUP A by $0 USING 'collected'; C = GROUP B by $0 USING 'collected'; DUMP C;
The expected output:
(1,{(1,{(1),(1)})}) (2,{(2,{(2)})})
The actual output:
(1,{(1,{(1),(1)})}) (1,) (2,{(2,{(2)})})
- Is contained by
-
PIG-4876 OutputConsumeIterator can't handle the last buffered tuples for some Operators
-
- Closed
-