Невозможно запустить (python) apache Пример луча minimal_wordcount с переносным бегуном (моргание)

Question

Я пытаюсь запустить minimal_wordcount.py пример , используя портативный бегун с flink. (python v3.7.6, apache_beam v2.17.0, flink v1.9.1). Я использую следующие параметры конвейера, остальная часть кода не изменяется никаким образом, кроме предоставления локального файла input.txt:

  pipeline_args.extend([
      "--runner=PortableRunner",
      "--job_endpoint=localhost:8099",
      "--environment_type=LOOPBACK",
      '--job_name=your-wordcount-job',
  ])

Я получаю следующие ошибки
С python код:

grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with:
    status = StatusCode.INVALID_ARGUMENT
    details = ""
    debug_error_string = "{"created":"@1579844359.098732955","description":"Error received from peer ipv6:[::1]:8099","file":"src/core/lib/surface/call.cc","file_line":1056,"grpc_message":"","grpc_status":3}"

Сервер заданий запускается с помощью команды:
./gradlew :runners:flink:1.9:job-server:runShadow -PflinkMasterUrl=localhost:8081. Трассировка стека показывает исключение:
java.lang.RuntimeException: Failed to validate transform
, вызванное:
org.apache.beam.vendor.grpc.v1p26p0.com.google.protobuf.InvalidProtocolBufferException: Protocol message had invalid UTF-8..

Куда я иду не так? Я использую неправильную версию пакета protobuf python?