Невозможно загрузить загруженные данные в Dgraph - PullRequest
0 голосов
/ 15 февраля 2019

Я сгенерировал данные из массового загрузчика, используя --reduce_shards=2, следуя документации на здесь

Это создает 2 p каталогов, в которых я запускал alphas по этой ссылке

Команды, которые я использовал dgraph zero --my=IPADDR:5080 в верхнем каталоге

Затем я перехожу в каталог out и запускаю одну альфу на /0/p, используя dgraph alpha --lru_mb=4096 --my=IPADDR:7080 --zero=localhost:5080

ЕслиНа этом этапе я проверяю ratel, все в порядке

Затем я перехожу в каталог out и запускаю вторую альфу на /1/p, используя dgraph alpha --lru_mb=4096 --my=IPADDR:7081 --zero=localhost:5080 -o=1

Это работает нормально, но данные из этого *Каталог 1027 * не загружен, и Ratel начинает отображать ошибку в схеме

Другие 2 варианта, которые я пробовал

  1. Я сделал массовую загрузку, используя --reduce_shards=1 и просто запустив одну альфа, все работает отлично

  2. Я остановил первую альфу и запустил альфу на /1/p, другие предикаты начинают появляться, и все работает нормально, но теперь /0/p данные пропали

1 Ответ

0 голосов
/ 26 февраля 2019

Существует известная ошибка с массовой загрузкой нескольких групп, когда данные, которые должны обслуживаться другими альфа-группами, не отображаются в запросах.Это будет исправлено в выпуске v1.0.12, который будет доступен на следующий день или около того.

На данный момент вы можете выполнить массовую загрузку для многогрупповых кластеров следующим образом:

  1. Запустите загрузчик Dgraph Bulk Loader для отдельной группы (--reduce_shards=1, которая выводит один каталог данных в ./out/0/p)
  2. Запустите первую альфу с каталогом загруженных данных изатем
  3. Запустите другие альфы, которые присоединяются к кластеру как члены разных групп.

Через 8 минут (или после продолжительности, установленной в --rebalance_interval), Dgraph Zero восстановит балансПредикаты среди разных групп:

$ dgraph zero --help
...
      --rebalance_interval duration   Interval for trying a predicate move. (default 8m0s)
...