JdbcIO.read не возвращает результаты в apache beam

#java #apache-beam Вопрос: Я пытаюсь прочитать некоторые данные с помощью jdbIO.read в apache beam, и это работает нормально, если у меня есть следующий код. Pipeline p = createPipeline(options); p.apply(JdbcIO.<TestRow>read() .withDataSourceConfiguration(JdbcIO.DataSourceConfiguration.create(dataSource))…