问题描述
docs提到以下选项:
direct_num_workers
和direct_running_mode
,以及设置streaming
选项。
此外,当尝试从args
进行设置时,会引发以下异常:
java.lang.IllegalArgumentException: Class interface org.apache.beam.runners.direct.DirectOptions missing a property named 'direct_running_mode'.
at org.apache.beam.sdk.options.PipelineOptionsFactory.parSEObjects(PipelineOptionsFactory.java:1613)
at org.apache.beam.sdk.options.PipelineOptionsFactory.access$400(PipelineOptionsFactory.java:117)
at org.apache.beam.sdk.options.PipelineOptionsFactory$Builder.as(PipelineOptionsFactory.java:300)
有人设法使用了这些吗?怎么样?
解决方法
这些选项仅与Python SDK相关,实际上并不清楚,因为这些选项已在两个SDK的注意事项部分中进行了记录,在记录Java SDK时应将其隐藏,请随时报告文档问题。
这些选项是Python FnApiRunner的一部分。