----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/22374/#review45415 -----------------------------------------------------------
tajo-core/src/main/java/org/apache/tajo/master/querymaster/Repartitioner.java <https://reviews.apache.org/r/22374/#comment80271> For consistency, I'd like to suggest renaming it to 'scheduleScatteredHashShuffledFetches'. tajo-core/src/main/java/org/apache/tajo/master/querymaster/Repartitioner.java <https://reviews.apache.org/r/22374/#comment80270> Many of the parts seem to be similar to the codes of scheduleHashShuffledFetches. Is there any opportunity to make common methods? - Hyunsik Choi On June 12, 2014, 4:09 a.m., Jung JaeHwa wrote: > > ----------------------------------------------------------- > This is an automatically generated e-mail. To reply, visit: > https://reviews.apache.org/r/22374/ > ----------------------------------------------------------- > > (Updated June 12, 2014, 4:09 a.m.) > > > Review request for Tajo. > > > Bugs: TAJO-673 > https://issues.apache.org/jira/browse/TAJO-673 > > > Repository: tajo > > > Description > ------- > > When inserting into partitioned table, if the number of partitions is smaller > than cluster concurrency capacity, a query execution is too slow. > > > Diffs > ----- > > tajo-common/src/main/java/org/apache/tajo/conf/TajoConf.java 3f2b16f > > tajo-core/src/main/java/org/apache/tajo/engine/planner/PhysicalPlannerImpl.java > e508d2c > > tajo-core/src/main/java/org/apache/tajo/engine/planner/global/GlobalPlanner.java > 536dbd8 > > tajo-core/src/main/java/org/apache/tajo/master/querymaster/Repartitioner.java > 3a2e79f > tajo-core/src/main/java/org/apache/tajo/master/querymaster/SubQuery.java > 22817bd > tajo-core/src/main/proto/TajoWorkerProtocol.proto 3bf6e13 > tajo-core/src/test/java/org/apache/tajo/engine/query/TestJoinBroadcast.java > 1581372 > > tajo-core/src/test/java/org/apache/tajo/engine/query/TestTablePartitions.java > 0ec7de0 > > tajo-core/src/test/resources/dataset/TestTablePartitions/customer_large/customer.tbl > PRE-CREATION > > tajo-core/src/test/resources/dataset/TestTablePartitions/lineitem_large/lineitem.tbl > PRE-CREATION > > tajo-core/src/test/resources/queries/TestJoinBroadcast/testBroadcastSubquery3.sql > PRE-CREATION > > tajo-core/src/test/resources/queries/TestTablePartitions/create_customer_large_ddl.sql > PRE-CREATION > > tajo-core/src/test/resources/queries/TestTablePartitions/create_lineitem_large_ddl.sql > PRE-CREATION > > tajo-core/src/test/resources/results/TestJoinBroadcast/testBroadcastSubquery3.result > PRE-CREATION > > tajo-yarn-pullserver/src/main/java/org/apache/tajo/pullserver/PullServerAuxService.java > b8fda29 > > tajo-yarn-pullserver/src/main/java/org/apache/tajo/pullserver/TajoPullServerService.java > cc3cb2e > > Diff: https://reviews.apache.org/r/22374/diff/ > > > Testing > ------- > > mvn clean install > > > Thanks, > > Jung JaeHwa > >
