在Beam中,Metrics.counter用于创建计数器来记录特定事件的数量。如果创建计数器失败,可能是由于以下几个原因:
...
org.apache.beam
beam-sdks-java-core
2.33.0
...
PipelineOptions options = PipelineOptionsFactory.create();
options.setRunner(DirectRunner.class);
Pipeline pipeline = Pipeline.create(options);
pipeline.run();
Counter counter = Metrics.counter("myNamespace", "myCounter");
请确保命名空间和名称是有效的字符串。
总之,要解决"Beam: Metrics.counter 创建计数器失败"的问题,可以检查引入的依赖包、正确初始化PipelineOptions、设置正确的运行环境,并确保使用有效的命名空间和名称来创建计数器。