DirectOptions 中缺少选项 class

Question

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.access0(PipelineOptionsFactory.java:117)
        at org.apache.beam.sdk.options.PipelineOptionsFactory$Builder.as(PipelineOptionsFactory.java:300)

有人设法使用这些吗？怎么样？

Answer 1

这些选项仅与 Python SDK 相关，实际上并不清楚，因为这些选项记录在两个 sdk 的警告部分中，在记录 Java SDK 时应该隐藏它，请随时报告文档问题。

这些选项是 Python FnApiRunner 的一部分。

DirectOptions 中缺少选项 class

Missing options in DirectOptions class

java

apache-beam

direct-runner