Я вижу, что Scio возвращается к кодеру Kryo, а не к Java Serializer, который является кодером по умолчанию, используемым для потока данных, когда кодер не может быть выведен / найден через CoderRegistry. Я нигде не вижу ссылки на...

У меня есть конвейер с набором PTransforms, и мой метод становится очень длинным. Я хотел бы написать свои DoFns и мои составные преобразования в отдельном пакете и использовать их обратно в моем основном методе. С python это довольно просто, как...

Я выполняю задание потокового луча в кластере flink, где я получаю следующее исключение. Caused by: org.apache.beam.sdk.util.UserCodeException: org.apache.flink.streaming.runtime.tasks.ExceptionInChainedOperatorException: Could not forward element...