Dataflow作业报错：已传入output参数仍提示output属性缺失

这问题的核心很明确：你试图给DataflowPipelineOptions传入output参数，但这个Beam内置的选项接口本身并没有定义output这个属性——这就是报错提示它"missing a property named 'output'"的原因。

下面是具体的修复步骤：

1. 自定义PipelineOptions接口 #

创建一个属于你自己的Options接口，继承DataflowPipelineOptions，然后在里面添加output属性的定义，用Beam的注解标记它的描述和必填性：

import org.apache.beam.runners.dataflow.options.DataflowPipelineOptions;
import org.apache.beam.sdk.options.Description;
import org.apache.beam.sdk.options.Required;

public interface CustomPipelineOptions extends DataflowPipelineOptions {
    @Description("输出数据的目标路径或位置")
    @Required
    String getOutput();
    void setOutput(String value);
}

2. 在主类中替换为自定义Options #

把原来代码里使用DataflowPipelineOptions解析参数的逻辑，替换成你刚定义的CustomPipelineOptions：
比如原来的代码可能是这样：

DataflowPipelineOptions options = PipelineOptionsFactory.fromArgs(args).as(DataflowPipelineOptions.class);

现在改成：

CustomPipelineOptions options = PipelineOptionsFactory.fromArgs(args).as(CustomPipelineOptions.class);

3. 确认参数传入格式 #

确保启动命令里的output参数格式正确，比如：

java -jar your-pipeline-jarfile.jar --output=gs://your-gcs-bucket/output-directory

补充说明 #

DataflowPipelineOptions只包含Dataflow运行时的核心配置项（比如项目ID、区域、临时存储路径等），不会包含业务相关的自定义参数。所以必须通过继承它来扩展自定义属性，这样PipelineOptionsFactory才能识别并解析你传入的output参数。

内容的提问来源于stack exchange，提问作者Mohammed Niaz