Объединение потоков во Flink - это то же самое, что и операция объединения на мультимножествах - вы просто получите больший поток всех элементов из двух входных потоков.
Итак, другими словами, Союз не является объединением. ds3.f2 - это значение, которое ранее было ds1.f2 или ds2.f2 для некоторого кортежа в одном из этих потоков.
В зависимости от того, что вы пытаетесь выполнить, вы можете добавить пятый элемент к каждому кортежу, чтобы вы знали его происхождение. Или вы можете использовать какую-то операцию соединения для объединения двух потоков. См. Документацию для объединений окон , объединений таблиц , объединений sql и объединений низкого уровня .