# Logstash JDBC input malfunction

**URL:** <https://discuss.elastic.co/t/logstash-jdbc-input-malfunction/38601>\
**Category:** Logstash\
**Created:** [January 7, 2016, 11:05am UTC](https://discuss.elastic.co/t/logstash-jdbc-input-malfunction/38601 "2016-01-07T11:05:52Z")\
**Posts on this page:** 3\
**Page:** 1

<div class="post-metadata">

**Author:** ![tilney](https://avatars.discourse-cdn.com/v4/letter/t/9fc29f/32.png) [@tilney](https://discuss.elastic.co/u/tilney)\
**Post date:** [January 7, 2016, 11:05am UTC](https://discuss.elastic.co/t/logstash-jdbc-input-malfunction/38601/1 "2016-01-07T11:05:52Z")

</div>

configuration below could not finish if I dont specify a limit clause in mysql statement.

input {  
jdbc {  
jdbc\_driver\_library =\> "mysql-connector-java-5.1.38/mysql-connector-java-5.1.38-bin.jar"  
jdbc\_driver\_class =\> "com.mysql.jdbc.Driver"  
jdbc\_connection\_string =\> "jdbc:mysql://localhost:3306/data"  
jdbc\_validate\_connection =\> true  
jdbc\_user =\> "root"  
jdbc\_password =\> "123456"  
jdbc\_paging\_enabled =\> "true"  
jdbc\_page\_size =\> "5000"  
schedule =\> "\* \* \* \* \*"  
statement =\> "select \* from recommend\_refresh\_data4 where time \> 20151215"  
}  
}

filter {  
mutate {  
replace =\> {"@timestamp" =\> "%{time}"}  
remove\_field =\> [time]  
convert =\> { "newsScore" =\> "float" }  
}  
}  
output {  
stdout { codec =\> json\_lines }  
elasticsearch {  
index =\> "recommend\_data"  
document\_type =\> "bi"  
document\_id =\> "%{id}"  
hosts =\> ["10.2.4.126:9200"]  
}  
}

after start logstash, it is stucked,

Settings: Default filter workers: 2  
Logstash startup completed

no record is fetched from mysql. After I press Ctrl + c, it gives warnings:

{:level=\>:warn, "INFLIGHT\_EVENT\_COUNT"=\>{"total"=\>0}, "STALLING\_THREADS"=\>{["LogStash::Inputs::Jdbc", {"jdbc\_driver\_library"=\>"mysql-connector-java-5.1.38/mysql-connector-java-5.1.38-bin.jar", "jdbc\_driver\_class"=\>"com.mysql.jdbc.Driver", "jdbc\_connection\_string"=\>"jdbc:mysql://localhost:3306/data", "jdbc\_validate\_connection"=\>"true", "jdbc\_user"=\>"root", "jdbc\_password"=\>"123456", "jdbc\_paging\_enabled"=\>"true", "jdbc\_page\_size"=\>"5000", "statement"=\>"select \* from recommend\_refresh\_data4 where time \> 20151215"}]=\>[{"thread\_id"=\>17, "name"=\>"\<jdbc", "current\_call"=\>"[...]/vendor/bundle/jruby/1.9/gems/sequel-4.29.0/lib/sequel/adapters/jdbc.rb:251:in `execute'"}]}}

seems like the pagination is not working. Tried to set jdbc\_fetch\_size , no luck.

---

<div class="post-metadata">

**Author:** ![Architha](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/architha/32/92477_2.png) [@Architha](https://discuss.elastic.co/u/Architha)\
**Post date:** [February 11, 2016, 1:32pm UTC](https://discuss.elastic.co/t/logstash-jdbc-input-malfunction/38601/2 "2016-02-11T13:32:48Z")

</div>

@tilney  
Hi did you find solution to this problem of yours ?

---

<div class="post-metadata">

**Author:** ![system](https://us1.discourse-cdn.com/elastic/original/3X/1/a/1ac57faf039f6b580b3f104ef42a2a89e41014de.png) [@system](https://discuss.elastic.co/u/system)\
**Post date:** [July 6, 2017, 5:12am UTC](https://discuss.elastic.co/t/logstash-jdbc-input-malfunction/38601/3 "2017-07-06T05:12:03Z")

</div>