diff options
| author | Aditya Kishore <aditya@maprtech.com> | 2014-05-28 04:56:46 -0700 |
|---|---|---|
| committer | Jacques Nadeau <jacques@apache.org> | 2014-06-02 09:14:42 -0700 |
| commit | d929faace270302c5e00e272775be98d5a8f83e1 (patch) | |
| tree | 0456232ebefa5c44e9f52a371979675ddb30a291 /exec/java-exec/src/test/java/org/apache/drill/exec/pop/TestFragmentChecker.java | |
| parent | 292765e7211d6ddddb64e67bdcff64829a60a615 (diff) | |
DRILL-855: Improve work assignment parallelization
Diffstat (limited to 'exec/java-exec/src/test/java/org/apache/drill/exec/pop/TestFragmentChecker.java')
| -rw-r--r-- | exec/java-exec/src/test/java/org/apache/drill/exec/pop/TestFragmentChecker.java | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/exec/java-exec/src/test/java/org/apache/drill/exec/pop/TestFragmentChecker.java b/exec/java-exec/src/test/java/org/apache/drill/exec/pop/TestFragmentChecker.java index 1b38dcef7..ea193515f 100644 --- a/exec/java-exec/src/test/java/org/apache/drill/exec/pop/TestFragmentChecker.java +++ b/exec/java-exec/src/test/java/org/apache/drill/exec/pop/TestFragmentChecker.java @@ -59,8 +59,8 @@ public class TestFragmentChecker extends PopUnitTestBase{ endpoints.add(b1); } - - QueryWorkUnit qwu = par.getFragments(new OptionList(), localBit, QueryId.getDefaultInstance(), endpoints, ppr, fragmentRoot, planningSet, 10, 5); + par.setGlobalMaxWidth(10).setMaxWidthPerEndpoint(5); + QueryWorkUnit qwu = par.getFragments(new OptionList(), localBit, QueryId.getDefaultInstance(), endpoints, ppr, fragmentRoot, planningSet); System.out.println(String.format("=========ROOT FRAGMENT [%d:%d] =========", qwu.getRootFragment().getHandle().getMajorFragmentId(), qwu.getRootFragment().getHandle().getMinorFragmentId())); System.out.print(qwu.getRootFragment().getFragmentJson()); |