master - improve tests
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/c5a6ea6e Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/c5a6ea6e Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/c5a6ea6e Branch: refs/heads/ignite-1192 Commit: c5a6ea6eb03debc082cf57cf22ac2c7c81814c0c Parents: 067cf8a Author: Sergi Vladykin <sergi.vlady...@gmail.com> Authored: Wed Mar 22 14:17:52 2017 +0300 Committer: Sergi Vladykin <sergi.vlady...@gmail.com> Committed: Wed Mar 22 14:17:52 2017 +0300 ---------------------------------------------------------------------- .../processors/query/IgniteSqlSplitterSelfTest.java | 15 +++++++++++++-- 1 file changed, 13 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/c5a6ea6e/modules/indexing/src/test/java/org/apache/ignite/internal/processors/query/IgniteSqlSplitterSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/indexing/src/test/java/org/apache/ignite/internal/processors/query/IgniteSqlSplitterSelfTest.java b/modules/indexing/src/test/java/org/apache/ignite/internal/processors/query/IgniteSqlSplitterSelfTest.java index 9dd12e1..8c880a3 100644 --- a/modules/indexing/src/test/java/org/apache/ignite/internal/processors/query/IgniteSqlSplitterSelfTest.java +++ b/modules/indexing/src/test/java/org/apache/ignite/internal/processors/query/IgniteSqlSplitterSelfTest.java @@ -153,11 +153,22 @@ public class IgniteSqlSplitterSelfTest extends GridCommonAbstractTest { } /** - * */ public void testReplicatedOnlyTables() { + doTestReplicatedOnlyTables(1); + } + + /** + */ + public void testReplicatedOnlyTablesSegmented() { + doTestReplicatedOnlyTables(5); + } + + /** + */ + private void doTestReplicatedOnlyTables(int segments) { IgniteCache<Integer,Value> p = ignite(0).getOrCreateCache(cacheConfig("p", true, - Integer.class, Value.class)); + Integer.class, Value.class).setQueryParallelism(segments)); IgniteCache<Integer,Value> r = ignite(0).getOrCreateCache(cacheConfig("r", false, Integer.class, Value.class));