A = load 'a.txt' as (id, a1);
B = load 'b.txt as (id, b1);
C = join A by id, B by id;
D = foreach C generate id,a1,b1;
dump D;
4-я строка выходит из строя:
Invalid field projection. Projected field [id] does not exist in schema
Я попытался перейти на A.id, но тогда последняя строка не срабатывает: ERROR 0: Scalar has more than one row in the output.