Невозможно вызвать getSchema, если схема отсутствует при объединении двух коллекций Pcollections. ⇐ JAVA

[Гость]

Надеюсь, у вас все хорошо.

У меня есть две PCollection, и я хочу применить leftOuterJoin, но когда я это применяю, у меня возникает эта ошибка, и я не понимаю, почему: java.lang.IllegalStateException: невозможно вызвать getSchema, когда нет схемы

final PCollection classA = BigQueryReader.getClassA(pipeline, Configuration.getBigQueryOptions()); окончательный PCollection classB = BigQueryReader.getClassB(pipeline, Configuration.getBigQueryOptions()); окончательный PCollection join = classA .apply("Применить присоединение", Join.leftOuterJoin(classB).using("id1", "id2"); Кто-нибудь может помочь понять, почему возникает эта ошибка.

Большое спасибо.