{"action":"closed","issue":{"url":"https://api.github.com/repos/elastic/elasticsearch/issues/19228","repository_url":"https://api.github.com/repos/elastic/elasticsearch","labels_url":"https://api.github.com/repos/elastic/elasticsearch/issues/19228/labels{/name}","comments_url":"https://api.github.com/repos/elastic/elasticsearch/issues/19228/comments","events_url":"https://api.github.com/repos/elastic/elasticsearch/issues/19228/events","html_url":"https://github.com/elastic/elasticsearch/issues/19228","id":163491547,"number":19228,"title":"BulkProcessor doesn't commit the transaction log even if flush() is called","user":{"login":"panfngsugar","id":7969681,"avatar_url":"https://avatars.githubusercontent.com/u/7969681?v=3","gravatar_id":"","url":"https://api.github.com/users/panfngsugar","html_url":"https://github.com/panfngsugar","followers_url":"https://api.github.com/users/panfngsugar/followers","following_url":"https://api.github.com/users/panfngsugar/following{/other_user}","gists_url":"https://api.github.com/users/panfngsugar/gists{/gist_id}","starred_url":"https://api.github.com/users/panfngsugar/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/panfngsugar/subscriptions","organizations_url":"https://api.github.com/users/panfngsugar/orgs","repos_url":"https://api.github.com/users/panfngsugar/repos","events_url":"https://api.github.com/users/panfngsugar/events{/privacy}","received_events_url":"https://api.github.com/users/panfngsugar/received_events","type":"User","site_admin":false},"labels":[],"state":"closed","locked":false,"assignee":null,"assignees":[],"milestone":null,"comments":1,"created_at":"2016-07-01T23:58:36Z","updated_at":"2016-07-02T06:42:05Z","closed_at":"2016-07-02T06:42:05Z","body":"<!--\r\nGitHub is reserved for bug reports and feature requests. The best place\r\nto ask a general question is at the Elastic Discourse forums at\r\nhttps://discuss.elastic.co. If you are in fact posting a bug report or\r\na feature request, please include one and only one of the below blocks\r\nin your new issue.\r\n-->\r\n\r\n<!--\r\nIf you are filing a bug report, please remove the below feature\r\nrequest block and provide responses for all of the below items.\r\n-->\r\n\r\n**Elasticsearch version**: 2.3.3\r\n\r\n**JVM version**: 1.8\r\n\r\n**OS version**: Mac 10.10.5\r\n\r\n**Description of the problem including expected versus actual behavior**:\r\nExpecting the bulkProcessor to commit the transaction log when calling flush()\r\nbut that's not the case\r\n\r\n\r\n**Steps to reproduce**:\r\nrun following test code:\r\n1. create an index request \r\n2. add it to a bulk processor\r\n3. flush the bulk processor\r\n4. refresh the same index\r\n5. an exception will be thrown saying the index could not be found\r\n``` \r\npublic class testBulkProcessor extends ESIntegTestCase {\r\n    @Test\r\n    public void testBulkProcessor(){\r\n        BulkProcessor bulkProcessor =\r\n                BulkProcessor.builder(client(), new BulkProcessor.Listener() {\r\n                    @Override\r\n                    public void beforeBulk(long executionId, BulkRequest request) {\r\n                    }\r\n                    @Override\r\n                    public void afterBulk(long executionId, BulkRequest request,\r\n                            BulkResponse response) {\r\n                    }\r\n                    @Override\r\n                    public void afterBulk(long executionId, BulkRequest request,\r\n                            Throwable failure) {\r\n                    }\r\n                }).setBulkActions(1000)\r\n                        .setBulkSize(new ByteSizeValue(5, ByteSizeUnit.MB)).setConcurrentRequests(2)\r\n                        .build();\r\n        IndexRequest indexRequest = new IndexRequest(\"test\", \"test\", \"1\");\r\n        indexRequest.source(new HashMap());\r\n        bulkProcessor.add(indexRequest);\r\n        bulkProcessor.flush();\r\n        client().admin().indices().prepareRefresh(\"test\").get();\r\n    }\r\n}\r\n```\r\n\r\n**Provide logs (if relevant)**:\r\n[test] IndexNotFoundException[no such index]\r\nthe exception is thrown at \r\n```\r\nclient().admin().indices().prepareRefresh(\"test\").get();\r\n```\r\n"}}
{"actor":{"display_login":"ywelsch"}}