{"action":"opened","issue":{"url":"https://api.github.com/repos/logstash-plugins/logstash-input-jdbc/issues/59","labels_url":"https://api.github.com/repos/logstash-plugins/logstash-input-jdbc/issues/59/labels{/name}","comments_url":"https://api.github.com/repos/logstash-plugins/logstash-input-jdbc/issues/59/comments","events_url":"https://api.github.com/repos/logstash-plugins/logstash-input-jdbc/issues/59/events","html_url":"https://github.com/logstash-plugins/logstash-input-jdbc/issues/59","id":111797875,"number":59,"title":"repeat insert data use logstash-input-jdbc plugin dump data from mysql to elasticsearch","user":{"login":"506764932","id":6880877,"avatar_url":"https://avatars.githubusercontent.com/u/6880877?v=3","gravatar_id":"","url":"https://api.github.com/users/506764932","html_url":"https://github.com/506764932","followers_url":"https://api.github.com/users/506764932/followers","following_url":"https://api.github.com/users/506764932/following{/other_user}","gists_url":"https://api.github.com/users/506764932/gists{/gist_id}","starred_url":"https://api.github.com/users/506764932/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/506764932/subscriptions","organizations_url":"https://api.github.com/users/506764932/orgs","repos_url":"https://api.github.com/users/506764932/repos","events_url":"https://api.github.com/users/506764932/events{/privacy}","received_events_url":"https://api.github.com/users/506764932/received_events","type":"User","site_admin":false},"labels":[],"state":"open","locked":false,"assignee":null,"milestone":null,"comments":0,"created_at":"2015-10-16T09:46:30Z","updated_at":"2015-10-16T09:46:30Z","closed_at":null,"body":"hi\r\ni use logstash-input-jdbc plugin dump data from mysql to elasticsearch \r\nhere is my input content inlogstash.conf :\r\n\r\njdbc {\r\n# mysql jdbc connection string to our backup databse\r\njdbc_connection_string => \"jdbc:mysql://192.168.0.49:3306/dfb\"\r\n# the user we wish to excute our statement as\r\njdbc_user => \"test\"\r\njdbc_password => \"test\"\r\n# the path to our downloaded jdbc driver\r\njdbc_driver_library => \"/opt/logstash/mysql-connector-java-5.1.36-bin.jar\"\r\n# the name of the driver class for mysql\r\njdbc_driver_class => \"com.mysql.jdbc.Driver\"\r\njdbc_paging_enabled => \"true\"\r\njdbc_page_size => \"50000\"\r\nstatement_filepath => \"jdbc.sql\"\r\nschedule => \"* * * * *\"\r\ntype => \"jdbc\"\r\n}\r\n\r\nthe jdbc sql is \r\nselect \r\nh.id as id, \r\nh.hotel_name as name, \r\nh.photo_url as img,\r\nha.id as haId, \r\nha.finance_person\r\nfrom \r\nhotel h LEFT JOIN hotel_account ha on h.id = ha.hotel_id\r\nwhere \r\nh.last_modify_time >= :sql_last_start\r\n\r\nwhen i setting well and first start logstash . it running well. all data is dump to es . and the console is waiting.\r\nwhen i execute a insert sql to insert data the console print a message and the data also exist in es. \r\nbut about 30s later . the console print the message again . and es repeat insert the same data again too.\r\ni test update sql . the same !\r\n\r\ni do not konw what is the matter with logstash . and i have konw idea where the :sql_last_start field is worked "}}