Отсутствующие метрики для конвейера Apache Beam (через SparkRunner / Dataproc)
В настоящее время я добавляю некоторые метрики в существующий конвейер, который работает в Google Dataproc через Spark Runner, и я пытаюсь определить, как получить доступ...