[BEAM-2410] This closes #3328
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/1c6861f2 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/1c6861f2 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/1c6861f2 Branch: refs/heads/gearpump-runner Commit: 1c6861f22249dadacb34994564d33b14f1d57d3d Parents: e980ae9 7caea7a Author: Jean-Baptiste Onofré <jbono...@apache.org> Authored: Fri Jun 9 07:31:27 2017 +0200 Committer: Jean-Baptiste Onofré <jbono...@apache.org> Committed: Fri Jun 9 07:31:27 2017 +0200 ---------------------------------------------------------------------- .../sdk/io/common/IOTestPipelineOptions.java | 6 +- .../sdk/io/elasticsearch/ElasticsearchIO.java | 4 +- .../elasticsearch/ElasticSearchIOTestUtils.java | 81 +++++++++++--------- .../sdk/io/elasticsearch/ElasticsearchIOIT.java | 14 ++-- .../io/elasticsearch/ElasticsearchIOTest.java | 36 +++++---- .../elasticsearch/ElasticsearchTestDataSet.java | 37 ++++----- 6 files changed, 87 insertions(+), 91 deletions(-) ----------------------------------------------------------------------