运行字数统计示例时出现错误请求

Question

我是谷歌云数据流的新手。我在我的Windows机器上设置了所有内容，当我尝试使用以下命令运行字数示例时：

mvn compile exec：java -Dexec.mainClass=com.nyt.dataflowPoc.WordCount -Dexec.args=“--project=cdfpoc-1264 --stagingLocation=gs：//poc-location/staging --runner=BlockingDataflowPipelineRunner --output=gs：//poc-location”

它给了我下面的错误。

原因:com . Google . API . client . Google APIs . JSON . googlejsonresponse exception:400错误请求{ "code" : 400，" errors" : [ { "domain" : "global "，" message" : "Invalid Value "，" reason" : "invalid" } ]，" message" : "Invalid Value" }

我看了其他帖子，它说我需要给出投影，它应该是阿尔法数。我已经给出了，但还是同样的错误。

有人能帮忙吗？

提前感谢。

-卡皮尔

Answer 1

问题解决了。我同时给出了暂存和输出位置。当我深入代码时，我发现只需要其中一个。所以当我删除--out参数时，我得到了实际的输出，并且我可以在指定的存储位置看到结果。

谢谢卡皮尔

Answer 2

问题来自于:

--output=gs://poc-location

因此，您只指定了一个bucket。WordCount实际上将其解释为输出的前缀，并尝试写入文件gs://poc-location-00000-of-00001。由于此bucket不存在，因此会出现错误。您的管道将在以下情况下正常运行：

--output=gs://poc-location/