Error While loading mysql db

Elastic Stack Logstash
1

Hi All,

i am try to load mysql data into elastic search by using logstash.

when i create a index i am getting below error.
[2015-08-10 09:52:18,417][INFO ][cluster.service ] [Allison Blaire] added {[Robert "Bobby" Drake][sqIHmbFtSzW8-dSJCsR4WQ][WIN-18KR7AJA9OG][inet[/192.168.3.124:9301]],}, reason: zen-disco-receive(join from node[[Robert "Bobby" Drake][sqIHmbFtSzW8-dSJCsR4WQ][WIN-18KR7AJA9OG][inet[/192.168.3.124:9301]]])
[2015-08-10 09:52:47,093][INFO ][cluster.service ] [Allison Blaire] removed {[Robert "Bobby" Drake][sqIHmbFtSzW8-dSJCsR4WQ][][inet[/192.168.3.124:9301]],}, reason: zen-disco-node_failed([Robert "Bobby" Drake][sqIHmbFtSzW8-dSJCsR4WQ][***][inet[/192.168.3.124:9301]]), reason transport disconnected

Please help me.

Regards,
Dinesh.

2

Looks like it cannot connect to ES.

What does your config look like?

3

Hi below is my config file
input {
jdbc {
jdbc_driver_library => "C:\ELK3\logstash-1.5.3\lib\mysql-connector-java-5.1.35-bin.jar"
jdbc_driver_class => "com.mysql.jdbc.Driver"
jdbc_connection_string => "jdbc:mysql://192.168.3.124:3306/datalake"
jdbc_user => "datalake"
jdbc_password => "datalake"
statement => "SELECT * FROM product"
jdbc_paging_enabled => "true"
jdbc_page_size => "50000"
}
}

output {
stdout { codec => rubydebug }
elasticsearch {
embedded => true
index => "lake2"
protocol => "http"
port => "9200"

}

}

4

maybe try to run Elasticsearch externally and not in embedded mode. That may help resolve this issue.

Another thing I should note is that the jdbc_paging options do not preserve transaction or order. This is recommended for using with ordered queries that are not expected to change during the query.