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-й строки:
Недопустимая проекция поля. Спроецированное поле [id] не существует в схеме
. Я попытался изменить на A.id, но затем произошел сбой последней строки: ОШИБКА 0: Scalar содержит более одной строки на выходе.