This is an automated email from the ASF dual-hosted git repository. lcwik pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git
commit a467767dd3764a4ca5662557f70cefc41046f6dd Author: Etienne Chauchot <[email protected]> AuthorDate: Mon Dec 4 15:38:51 2017 +0100 [BEAM-2957] increase desiredBundleSize in testSplit so that ES slices are bigger to reduce the probability of empty ES slices (empty splits) --- .../java/org/apache/beam/sdk/io/elasticsearch/ElasticsearchIOTest.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/sdks/java/io/elasticsearch-tests/elasticsearch-tests-5/src/test/java/org/apache/beam/sdk/io/elasticsearch/ElasticsearchIOTest.java b/sdks/java/io/elasticsearch-tests/elasticsearch-tests-5/src/test/java/org/apache/beam/sdk/io/elasticsearch/ElasticsearchIOTest.java index 50a8764..c1d844b 100644 --- a/sdks/java/io/elasticsearch-tests/elasticsearch-tests-5/src/test/java/org/apache/beam/sdk/io/elasticsearch/ElasticsearchIOTest.java +++ b/sdks/java/io/elasticsearch-tests/elasticsearch-tests-5/src/test/java/org/apache/beam/sdk/io/elasticsearch/ElasticsearchIOTest.java @@ -166,7 +166,7 @@ public class ElasticsearchIOTest extends ESIntegTestCase implements Serializable ElasticsearchIO.read().withConnectionConfiguration(connectionConfiguration); BoundedElasticsearchSource initialSource = new BoundedElasticsearchSource(read, null, null, null); - int desiredBundleSizeBytes = 1000; + int desiredBundleSizeBytes = 2000; List<? extends BoundedSource<String>> splits = initialSource.split(desiredBundleSizeBytes, options); SourceTestUtils.assertSourcesEqualReferenceSource(initialSource, splits, options); -- To stop receiving notification emails like this one, please contact "[email protected]" <[email protected]>.
