Не удалось создать составной индекс, застрявший в INSTALLED

Я не могу создать индекс. Мой код Гремлина выглядит следующим образом:

Я прочитал, что неудавшийся экземпляр может вызвать проблему, но проверка запущенных экземпляров показывает только одно:

Я также попытался выпустить действие REGISTER_INDEX, которое также выдается из кэша транзакций с аналогичным сообщением об ошибке:

Я также пытался перезапустить сервер несколько раз.

Кажется, что процесс регистрации - это просто тайм-аут, вызывающий "выселение" из кэша транзакций. Я ждал 48 часов, чтобы убедиться, что это не медленный процесс. Нормальные чтения, записи и связанные с ними коммиты Titan действительно работают правильно, я просто не могу создать этот индекс. Я застрял, есть ли что-то еще, что я могу попробовать? Есть ли способ продлить время ожидания этой транзакции?

Я запускаю Titan 1.0.0 с использованием бэкэнда DynamoDB (настройка с использованием AWS Template Template).

EDIT: Вот полная команда, которую я вставляю в Гремлин с добавлением шага awaitGraphStatus, предложенного @M-T-A:

Я также буду замечать, что процедура отключения и удаления индекса также терпит неудачу.

ИЗМЕНИТЬ 2: Попытка создать новый ключ свойства и индекс в пределах одной транзакции РАБОТАЕТ! Но означает ли это, что я не могу создавать индексы на существующих ключах свойств?

Ответы

Ответ 1

Если вы используете несколько экземпляров Titan, вы должны знать, что они должны координировать работу до того, как индекс станет доступным.

Кроме того, существуют различные тонкости управления транзакциями и при каких обстоятельствах транзакции будут оставлены открытыми; Я полагаю, что Titan 1.0.0 не имеет последней версии от TinkerPop в этом отношении. Вы пытались создать индекс сразу после загрузки?

Наконец, процесс создания индекса отличается в зависимости от того, были ли ранее использованы индексы свойств. Вы пытаетесь индексировать новые ключи или существующие?

Ответ 2

Вам нужно подождать, пока Titan и DynamoDB не смогут зарегистрировать индекс. Вы можете сделать это:

ManagementSystem.awaitGraphIndexStatus(graph, propertyKeyIndexName)
                    .status(SchemaStatus.REGISTERED)
                    .timeout(10, java.time.temporal.ChronoUnit.MINUTES) // set timeout to 10 min
                    .call();

Тайм-аут по умолчанию обычно не достаточно длинный, поэтому вы можете увеличить его до 10 минут, обычно это трюк с поддержкой Dynamo.

Только когда индекс находится в состоянии REGISTERED, вы можете выполнить переопределение. Когда вы перевернете, вам нужно подождать, пока он не будет включен. повторным использованием примера кода выше и изменением состояния на ENABLED.

Для получения дополнительной информации см. docs.

Изменить

Позвольте мне разделить код, который работает со мной на Berkeley и Dynamo DB backends все время.

    graph.tx().rollback(); //Never create new indexes while a transaction is active
    TitanManagement mgmt=graph.openManagement();
    PropertyKey propertyKey=getOrCreatePropertyKeyIfNotExist(mgmt, propertyKeyName);
    String indexName = makePropertyKeyIndexName(propertyKey);

    if (mgmt.getGraphIndex(indexName)==null) { 
        mgmt.buildIndex(indexName, Vertex.class).addKey(propertyKey).buildCompositeIndex();
        mgmt.commit(); // you MUST commit mgmt
        graph.tx().commit(); // and commit the transaction too
        ManagementSystem.awaitGraphIndexStatus(graph, indexName).status(SchemaStatus.REGISTERED).call();
    }else { // already defined.
        mgmt.rollback();
        graph.tx().rollback();
    }

private static PropertyKey getOrCreatePropertyKeyIfNotExist(TitanManagement mgmt, String s) {
    PropertyKey key = mgmt.getPropertyKey(s);
    if (key != null)
        return key;
    else
        return mgmt.makePropertyKey(s).dataType(String.class).make();
}

private static String makePropertyKeyIndexName(PropertyKey pk) {
    return pk.name() + Tokens.INDEX_SUFFIX;
}

Из ошибки, которую я видел, похоже, что Titan не смог получить индекс, что означает, что вы ожидаете индекса, который даже не определен. Посмотрите на строку, которая вызывает ошибку здесь.

Убедитесь, что вы передаете правильное имя индекса в awaitGraphIndexStatus.