When you try to execute the following crashes with not-serializable Exception. A = load 'hdfs://localhost:9000/input/' USING PigStorage(',') AS (p, q, r); B = GROUP A BY p; STORE B INTO '/tmp/groupby'; Its happening in Spork streaming.
When you try to execute the following crashes with not-serializable Exception.
A = load 'hdfs://localhost:9000/input/' USING PigStorage(',') AS (p, q, r);
B = GROUP A BY p;
STORE B INTO '/tmp/groupby';
Its happening in Spork streaming.