ELK версия: 5.6.3.
Я использую плагин logstash-jdbc-input, чтобы синхронизировать данные двух таблиц из MySQL вasticsearch с тем же индексом и тем же типом, файл conf выглядит так:
Таблица d_product_set и product_tag имеют одинаковые поля productid.
Результат, который я хочу получить, состоит в том, что в этих двух таблицах агрегация заполняется productid.
Но на самом деле данные одной таблицы всегда покрывают данные другой таблицы, поля одного документа в es совпадают только с одним из полей таблицы.
Может кто-нибудь указать, что не так в моем коде?