Почему ошибка при createIndex elasticsearch используя ElasticsearchOperations?

Question

[poznavaka]

Я использовал org.elasticsearch:elasticsearch версии 6.8, а для подключения использовал TransportClient. Затем решил обновиться до версии 7.6, и так как TransportClient является Deprecated, был вынужден использовать подключение к elastic через RestHighLevelClient. После этого после запуска появилась следующая ошибка:

java.lang.IncompatibleClassChangeError: Found interface org.elasticsearch.common.bytes.BytesReference, but class was expected
at org.elasticsearch.client.RequestConverters.createEntity(RequestConverters.java:689)
at org.elasticsearch.client.RequestConverters.createEntity(RequestConverters.java:684)
at org.elasticsearch.client.IndicesRequestConverters.createIndex(IndicesRequestConverters.java:128)
at org.elasticsearch.client.RestHighLevelClient.internalPerformRequest(RestHighLevelClient.java:1760)
at org.elasticsearch.client.RestHighLevelClient.performRequest(RestHighLevelClient.java:1734)
at org.elasticsearch.client.RestHighLevelClient.performRequestAndParseEntity(RestHighLevelClient.java:1696)
at org.elasticsearch.client.IndicesClient.create(IndicesClient.java:191)
at org.springframework.data.elasticsearch.core.ElasticsearchRestTemplate.createIndex(ElasticsearchRestTemplate.java:1248)
at org.springframework.data.elasticsearch.core.ElasticsearchRestTemplate.createIndex(ElasticsearchRestTemplate.java:1256)

Она возникает на строчке создания index:

elasticsearchOperations.deleteIndex(clazz);
elasticsearchOperations.createIndex(clazz, loadFromFileSetting(pathSetting, someParams));

Использую следующий конфиг-класс для подключения:

@Slf4j
@Configuration
@EnableElasticsearchRepositories(basePackages = "com.project.elastic.repository")
public class ElasticConfig extends AbstractElasticsearchConfiguration {

    @Value("${spring.data.elastic.url}")
    private String url;

    @Override
    public RestHighLevelClient elasticsearchClient() {
        return RestClients.create(ClientConfiguration.create(url)).rest();
    }
}

Что я делаю не так? Судя по ошибке дело совсем не в создании индекс...

Comments

[poznavaka]

Bavashi, clazz это переменная типа Class<?>.
Спасибо за ответ, я просто не подключил все библиотеки.
Простите за мою вялость. Но у меня к вам еще один вопрос. Кажется, я не решил проблему. Я использую repository для работы с данными в spring. Как вы знаете, я отказался от TransportClient в пользу RestHighLevelClient. Мой repository унаследован от интерфейса ElasticsearchRepository. Я использую стандартный метод saveAll.

У меня есть list из MyPostgresModel и мне нужно сохранить его в Elastic. Я хочу сделать это быстро, поэтому я использую @Transactional и использую метод saveAll с Iterable. MyPostgresModel имеет метод toDocument для возврата объекта MyElasticModel.

И вот пошли странности:
Это работает: myElasticRepository.save(users.get(0).toDocument());
И вот это не работает: myElasticRepository.saveAll(() -> users.stream().map(MyPostgresModel::toDocument).iterator());

Понятия не имею. Почему нет? Возвращается ошибка "type is missing;7930: type is missing;7931:...". Debuger сообщает мне, что elastic возвращает "400 Bad Request", типа не проходит валидация данных.
До того как я использовал TransportClient все было ок, а ведь TransportClient и RestHighLevelClient используют общий интерфейс elasticsearchOperations...

[poznavaka]

Bavashi, не, stream тут не причем. Короче проблема решилась тем, что я сравнял версии java-client и Elasticsearch

[axce1]

poznavaka почему Settings через loadFromFileSetting(pathSetting, someParams) кладете в индекс,а не через аннотацию @Settings?

[poznavaka]

axce1, потому что он у меня динамически меняется. Я не проверял, как подгружается json файл в объект используя @Settings - во время создания индекса или вовремя создания бина компоненты. Как думаете? Но мне это не подходит, потому что файл у меня при запуске всегда должен быть один, а меняться он может в зависимости от текущих данных.

[axce1]

poznavaka, @Settings используется во время создания индекса, но с 7-й версией она у меня не завелась пришлось откатываться на 6-ю. И вообще много странностей было с ней например, https://discuss.elastic.co/t/error-java-lang-nosuc... сталкивались с подобным? зы у через spirng-boot-data-elastic взаимодействую

[poznavaka]

axce1, да, сталкивался, откатился на 6.8.6 клиент, хотя elasticsearch юзаю 7.6.2 Проблема в том что TransportClient выкуривают, с ним есть проблемы и полностью навязывают HighLeverRest. В клиенте 7.6.2 TransportClient уже Deprecated, а с 8й он будет полностью удален. В итоге не хватает некоторой реализации. Короче spring-data-elasticsearch 3.2.6 совместим с клиентом 6.8.6, а с 7.6.2 нет. Скоро выйдет spring-data-elasticsearch 4.0, там добавится несколько интересных плюшек, в том числе будет и исправлен баг о котором вы написали.

[axce1]

poznavaka, я уже вкусил 4.0 сырой еще и тоже пару багов получил, пришлось даунгейдиться
зы спрошу не сталкивались как suggest через spring-data работать, а то вся дока старая и заточена под транспорт протокол?

[poznavaka]

axce1, с этим я испытываю трудности. :) Только божими наставлениями и силой воли моей, ступаю я по просторам неведанных классов либы сеей. Ну в смысле не приходилось еще работать с suggest ES в spring-data.

Answer 1

[poznavaka]

Описанная здесь проблема решена добавлением implementation "org.elasticsearch.client:elasticsearch-rest-high-levell-client:7.6.2". в gradle.build. После этого вам следует указать тип индекса как _doc и убедиться, что ваша версия java-клиента соответствует версии Elasticsearch.