Logstash sync mysql data to es: can't aggregation two tables' fields with id

Elastic Stack Logstash
1

ELK version: 5.6.3.

I'm using logstash-jdbc-input plugin to sync two tables data from MySQL to elasticsearch with same index and same type, the conf file is like this:
logstash.conf

The table d_product_set and d_product_tag have the same filed productid.

The result I want is in these two tables fill aggregation with the productid.

But in fact, one table's data always cover another table's data, one doc's fields in es only same with one of table's fields.

Can someone point what's wrong in my code?

2

This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.