2016-03-28 3 views
1

Я новичок в потоке данных Google Cloud. Я настраиваю все на моем компьютере с Windows, и когда я попытался выполнить пример wordcount, используя следующую команду:Плохой запрос во время выполнения примера wordcount

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.googleapis.json.GoogleJsonResponseException: 400 Bad Request { "код": 400, "ошибка": [{ "домен": "глобального", "сообщение": "Invalid Value", "причина": "недействительные" }], "сообщение": "Invalid Value" }

Я посмотрел на другие должности и он сказал, что я должен дать ProjectID который должен быть альфа-номером. Я уже даю эту, но все же ту же ошибку.

Может ли кто-нибудь помочь?

Заранее спасибо.

-Kapil

ответ

0

Проблема решена. Я предоставлял как размещение, так и выход. Когда я больше вычислил код, я обнаружил, что нужен только один из них. Поэтому, когда я удалял параметр -output, я получил фактический вывод, и я мог видеть результаты в указанном месте хранения.

Спасибо, Капил

+0

Вообще говоря, это должно быть хорошо, чтобы указать, как '' stagingLocation' и output' вариант трубопровода. Если вывод не указан, он будет по умолчанию 'gs: // your-staging-location/counts.txt'. Тем не менее, вы должны указать любое другое облако Google Cloud Storage и не должны видеть никаких проблем. –

2

Проблема исходит от:

--output=gs://poc-location 

Таким образом вы только указать ведро. WordCount фактически интерпретирует это как префикс для вашего вывода и пытается записать файл gs: // poc-location-00000-of-00001. Поскольку это ведро не существует, вы получаете ошибку. Ваш трубопровод будет прекрасно работать с:

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

Спасибо Мало! Оно работало завораживающе! – user2846616

Смежные вопросы