[
https://issues.apache.org/jira/browse/TAJO-1519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jerryjung updated TAJO-1519:
----------------------------
Description:
I tested TPC-H with 1TB. When I executed q7 sql, workers did not response.
The query is below.
{noformat}
Running Queries
QueryId Query Master Started Progress Time Status sql Kill
Query
q_1428023002653_0192 jup-g07-07 2015-04-03 15:41:36 27% 1 hrs,
13 mins, 58 sec QUERY_RUNNING select supp_nation, cust_nation, l_year,
sum(volume) as revenue from ( select supp_nation, cust_nation,
substr(l_shipdate, 1, 4) as l_year, l_extendedprice * (1 - l_discount) as
volume from q7_volume_shipping_tmp t join (select l_shipdate, l_extendedprice,
l_discount, c_nationkey, s_nationkey from supplier s join (select l_shipdate,
l_extendedprice, l_discount, l_suppkey, c_nationkey from customer c join
(select l_shipdate, l_extendedprice, l_discount, l_suppkey, o_custkey from
orders o join lineitem l on o.o_orderkey = l.l_orderkey and l.l_shipdate >=
'1995-01-01' and l.l_shipdate <= '1996-12-31' ) l1 on c.c_custkey =
l1.o_custkey ) l2 on s.s_suppkey = l2.l_suppkey ) l3 on l3.c_nationkey =
t.c_nationkey and l3.s_nationkey = t.s_nationkey ) shipping group by
supp_nation, cust_nation, l_year order by supp_nation, cust_nation, l_year
{noformat}
{noformat}
Status: RUNNING
Started: 2015-04-03 15:46:29 ~ -
# Tasks: 6063 (Local Tasks: 0, Rack Local Tasks: 0)
Progress: 99%
# Shuffles: 0
Input Bytes: 94.4 GiB (101,369,366,283 B)
Actual Processed Bytes: 94.2 GiB (101,176,763,849 B)
Input Rows: 3,288,784,087
Output Bytes: 70.5 GiB (75,663,614,467 B)
Output Rows: 1,801,836,518
{noformat}
The error message is below.
{noformat}
2015-04-03 15:47:40,586 ERROR org.apache.tajo.worker.Task: Fetch failed:
http://jup-g07-07:52758/?qid=q_1428023002653_0192&sid=4&p=1053&type=h
java.io.IOException: org.jboss.netty.channel.ConnectTimeoutException:
connection timed out: jup-g07-07/50.1.101.87:52758
at org.apache.tajo.worker.Fetcher.get(Fetcher.java:142)
at org.apache.tajo.worker.Task$FetchRunner.run(Task.java:609)
at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
Caused by: org.jboss.netty.channel.ConnectTimeoutException: connection timed
out: jup-g07-07/50.1.101.87:52758
at
org.jboss.netty.channel.socket.nio.NioClientBoss.processConnectTimeout(NioClientBoss.java:137)
at
org.jboss.netty.channel.socket.nio.NioClientBoss.process(NioClientBoss.java:83)
at
org.jboss.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:312)
at
org.jboss.netty.channel.socket.nio.NioClientBoss.run(NioClientBoss.java:42)
... 3 more
2015-04-03 15:47:40,594 ERROR org.apache.tajo.worker.Fetcher: Fetch failed :
org.jboss.netty.channel.ConnectTimeoutException: connection timed out:
jup-g07-07/50.1.101.87:52758
at
org.jboss.netty.channel.socket.nio.NioClientBoss.processConnectTimeout(NioClientBoss.java:137)
at
org.jboss.netty.channel.socket.nio.NioClientBoss.process(NioClientBoss.java:83)
at
org.jboss.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:312)
at
org.jboss.netty.channel.socket.nio.NioClientBoss.run(NioClientBoss.java:42)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
{noformat}
Test environments
{noformat}
Name Node spec. - R720 x 1Node
- E5-2650 / 2.5GHz, 2 processor / 12 core / 24 thread
- 64GB (8 x 8GB)
- 300GB(3.5”, 15K) x 4
Data Node spec. – R720xd - 10nodes
- E5-2650 v2 / 2.6GHz, 2 processor / 16 core / 32 thread
- 64GB (8 x 8GB)
- 300GB(3.5”, 15K) x 2EA
- 3TB (3.5”, 7.2K) x 10EA
- 10GbE x 2-port
- 1GbE x 4-port @ on-board
{noformat}
Query
{noformat}
create table q7_volume_shipping_tmp(supp_nation text, cust_nation text,
s_nationkey int8, c_nationkey int8);
insert overwrite into q7_volume_shipping_tmp
select
*
from
(
select
n1.n_name as supp_nation, n2.n_name as cust_nation, n1.n_nationkey as
s_nationkey,
n2.n_nationkey as c_nationkey
from
nation n1 join nation n2
on
n1.n_name = 'FRANCE' and n2.n_name = 'GERMANY'
UNION ALL
select
n1.n_name as supp_nation, n2.n_name as cust_nation, n1.n_nationkey as
s_nationkey,
n2.n_nationkey as c_nationkey
from
nation n1 join nation n2
on
n2.n_name = 'FRANCE' and n1.n_name = 'GERMANY'
) a;
select
supp_nation, cust_nation, l_year, sum(volume) as revenue
from
(
select
supp_nation, cust_nation, substr(l_shipdate, 1, 4) as l_year,
l_extendedprice * (1 - l_discount) as volume
from
q7_volume_shipping_tmp t join
(select l_shipdate, l_extendedprice, l_discount, c_nationkey, s_nationkey
from supplier s join
(select l_shipdate, l_extendedprice, l_discount, l_suppkey, c_nationkey
from customer c join
(select l_shipdate, l_extendedprice, l_discount, l_suppkey, o_custkey
from orders o join lineitem l
on
o.o_orderkey = l.l_orderkey and l.l_shipdate >= '1995-01-01'
and l.l_shipdate <= '1996-12-31'
) l1 on c.c_custkey = l1.o_custkey
) l2 on s.s_suppkey = l2.l_suppkey
) l3 on l3.c_nationkey = t.c_nationkey and l3.s_nationkey = t.s_nationkey
) shipping
group by supp_nation, cust_nation, l_year
order by supp_nation, cust_nation, l_year;
{noformat}
tajo configurations
{noformat}
export TAJO_MASTER_HEAPSIZE=10240
export TAJO_WORKER_HEAPSIZE=40960
export TAJO_QUERYMASTER_HEAPSIZE=4096
export TAJO_WORKER_OPTS="-server -Xms40960m -XX:+UseParallelOldGC"
export TAJO_WORKER_STANDBY_MODE=true
export TAJO_PULLSERVER_MODE=true
export TAJO_PULLSERVER_STANDALONE=true
<property>
<name>tajo.worker.resource.cpu-cores</name>
<value>30</value>
</property>
<property>
<name>tajo.worker.resource.disks</name>
<value>20</value>
</property>
<property>
<name>tajo.executor.groupby.in-memory-hash-threshold-bytes</name>
<value>1073741824</value>
</property>
<property>
<name>tajo.worker.resource.memory-mb</name>
<value>10240</value>
</property>
<property>
<name>tajo.shuffle.fetcher.read.timeout-sec</name>
<value>120</value>
</property>
<property>
<name>tajo.dist-query.groupby.partition-volume-mb</name>
<value>8</value>
</property>
<property>
<name>tajo.shuffle.fetcher.read.retry.max-num</name>
<value>30</value>
</property>
<property>
<name>tajo.querymaster.rpc.server.worker-thread-num</name>
<value>100</value>
</property>
{noformat}
was:
I tested TPC-H with 1TB. When I executed q7 sql, workers did not response.
The query is below.
{noformat}
Running Queries
QueryId Query Master Started Progress Time Status sql Kill
Query
q_1428023002653_0192 jup-g07-07 2015-04-03 15:41:36 27% 1 hrs,
13 mins, 58 sec QUERY_RUNNING select supp_nation, cust_nation, l_year,
sum(volume) as revenue from ( select supp_nation, cust_nation,
substr(l_shipdate, 1, 4) as l_year, l_extendedprice * (1 - l_discount) as
volume from q7_volume_shipping_tmp t join (select l_shipdate, l_extendedprice,
l_discount, c_nationkey, s_nationkey from supplier s join (select l_shipdate,
l_extendedprice, l_discount, l_suppkey, c_nationkey from customer c join
(select l_shipdate, l_extendedprice, l_discount, l_suppkey, o_custkey from
orders o join lineitem l on o.o_orderkey = l.l_orderkey and l.l_shipdate >=
'1995-01-01' and l.l_shipdate <= '1996-12-31' ) l1 on c.c_custkey =
l1.o_custkey ) l2 on s.s_suppkey = l2.l_suppkey ) l3 on l3.c_nationkey =
t.c_nationkey and l3.s_nationkey = t.s_nationkey ) shipping group by
supp_nation, cust_nation, l_year order by supp_nation, cust_nation, l_year
{noformat}
{noformat}
Status: RUNNING
Started: 2015-04-03 15:46:29 ~ -
# Tasks: 6063 (Local Tasks: 0, Rack Local Tasks: 0)
Progress: 99%
# Shuffles: 0
Input Bytes: 94.4 GiB (101,369,366,283 B)
Actual Processed Bytes: 94.2 GiB (101,176,763,849 B)
Input Rows: 3,288,784,087
Output Bytes: 70.5 GiB (75,663,614,467 B)
Output Rows: 1,801,836,518
{noformat}
The error message is below.
{noformat}
2015-04-03 15:47:40,586 ERROR org.apache.tajo.worker.Task: Fetch failed:
http://jup-g07-07:52758/?qid=q_1428023002653_0192&sid=4&p=1053&type=h
java.io.IOException: org.jboss.netty.channel.ConnectTimeoutException:
connection timed out: jup-g07-07/50.1.101.87:52758
at org.apache.tajo.worker.Fetcher.get(Fetcher.java:142)
at org.apache.tajo.worker.Task$FetchRunner.run(Task.java:609)
at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
Caused by: org.jboss.netty.channel.ConnectTimeoutException: connection timed
out: jup-g07-07/50.1.101.87:52758
at
org.jboss.netty.channel.socket.nio.NioClientBoss.processConnectTimeout(NioClientBoss.java:137)
at
org.jboss.netty.channel.socket.nio.NioClientBoss.process(NioClientBoss.java:83)
at
org.jboss.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:312)
at
org.jboss.netty.channel.socket.nio.NioClientBoss.run(NioClientBoss.java:42)
... 3 more
2015-04-03 15:47:40,594 ERROR org.apache.tajo.worker.Fetcher: Fetch failed :
org.jboss.netty.channel.ConnectTimeoutException: connection timed out:
jup-g07-07/50.1.101.87:52758
at
org.jboss.netty.channel.socket.nio.NioClientBoss.processConnectTimeout(NioClientBoss.java:137)
at
org.jboss.netty.channel.socket.nio.NioClientBoss.process(NioClientBoss.java:83)
at
org.jboss.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:312)
at
org.jboss.netty.channel.socket.nio.NioClientBoss.run(NioClientBoss.java:42)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
{noformat}
Test environments
{noformat}
Name Node spec. - R720 x 1Node
- E5-2650 / 2.5GHz, 2 processor / 12 core / 24 thread
- 64GB (8 x 8GB)
- 300GB(3.5”, 15K) x 4
Data Node spec. – R720xd - 10nodes
- E5-2650 v2 / 2.6GHz, 2 processor / 16 core / 32 thread
- 64GB (8 x 8GB)
- 300GB(3.5”, 15K) x 2EA
- 3TB (3.5”, 7.2K) x 10EA
- 10GbE x 2-port
- 1GbE x 4-port @ on-board
{noformat}
Query
{noformat}
create table q7_volume_shipping_tmp(supp_nation text, cust_nation text,
s_nationkey int8, c_nationkey int8);
insert overwrite into q7_volume_shipping_tmp
select
*
from
(
select
n1.n_name as supp_nation, n2.n_name as cust_nation, n1.n_nationkey as
s_nationkey,
n2.n_nationkey as c_nationkey
from
nation n1 join nation n2
on
n1.n_name = 'FRANCE' and n2.n_name = 'GERMANY'
UNION ALL
select
n1.n_name as supp_nation, n2.n_name as cust_nation, n1.n_nationkey as
s_nationkey,
n2.n_nationkey as c_nationkey
from
nation n1 join nation n2
on
n2.n_name = 'FRANCE' and n1.n_name = 'GERMANY'
) a;
select
supp_nation, cust_nation, l_year, sum(volume) as revenue
from
(
select
supp_nation, cust_nation, substr(l_shipdate, 1, 4) as l_year,
l_extendedprice * (1 - l_discount) as volume
from
q7_volume_shipping_tmp t join
(select l_shipdate, l_extendedprice, l_discount, c_nationkey, s_nationkey
from supplier s join
(select l_shipdate, l_extendedprice, l_discount, l_suppkey, c_nationkey
from customer c join
(select l_shipdate, l_extendedprice, l_discount, l_suppkey, o_custkey
from orders o join lineitem l
on
o.o_orderkey = l.l_orderkey and l.l_shipdate >= '1995-01-01'
and l.l_shipdate <= '1996-12-31'
) l1 on c.c_custkey = l1.o_custkey
) l2 on s.s_suppkey = l2.l_suppkey
) l3 on l3.c_nationkey = t.c_nationkey and l3.s_nationkey = t.s_nationkey
) shipping
group by supp_nation, cust_nation, l_year
order by supp_nation, cust_nation, l_year;
{noformat}
tajo configurations
{noformat}
export TAJO_MASTER_HEAPSIZE=10240
export TAJO_WORKER_HEAPSIZE=40960
export TAJO_QUERYMASTER_HEAPSIZE=4096
export TAJO_WORKER_OPTS="-server -Xms40960m -XX:+UseParallelOldGC"
export TAJO_WORKER_STANDBY_MODE=true
export TAJO_PULLSERVER_MODE=true
export TAJO_PULLSERVER_STANDALONE=true
<property>
<name>tajo.worker.resource.cpu-cores</name>
<value>30</value>
</property>
<property>
<name>tajo.worker.resource.disks</name>
<value>20</value>
</property>
<property>
<name>tajo.executor.groupby.in-memory-hash-threshold-bytes</name>
<value>1073741824</value>
</property>
<property>
<name>tajo.worker.resource.memory-mb</name>
<value>10240</value>
</property>
<property>
<name>tajo.shuffle.fetcher.read.timeout-sec</name>
<value>120</value>
</property>
<property>
<name>tajo.dist-query.groupby.partition-volume-mb</name>
<value>8</value>
</property>
<property>
<name>tajo.shuffle.fetcher.read.retry.max-num</name>
<value>30</value>
</property>
<property>
<name>tajo.querymaster.rpc.server.worker-thread-num</name>
<value>100</value>
</property>
> Tajo workers did not working normally.
> ---------------------------------------
>
> Key: TAJO-1519
> URL: https://issues.apache.org/jira/browse/TAJO-1519
> Project: Tajo
> Issue Type: Bug
> Environment: os : centOS 6.6
> hadoop : 2.5.0-cdh5.2.0
> tajo : 0.10.0
> Reporter: Jerryjung
>
> I tested TPC-H with 1TB. When I executed q7 sql, workers did not response.
> The query is below.
> {noformat}
> Running Queries
> QueryId Query Master Started Progress Time Status sql
> Kill Query
> q_1428023002653_0192 jup-g07-07 2015-04-03 15:41:36 27% 1 hrs,
> 13 mins, 58 sec QUERY_RUNNING select supp_nation, cust_nation, l_year,
> sum(volume) as revenue from ( select supp_nation, cust_nation,
> substr(l_shipdate, 1, 4) as l_year, l_extendedprice * (1 - l_discount) as
> volume from q7_volume_shipping_tmp t join (select l_shipdate,
> l_extendedprice, l_discount, c_nationkey, s_nationkey from supplier s join
> (select l_shipdate, l_extendedprice, l_discount, l_suppkey, c_nationkey from
> customer c join (select l_shipdate, l_extendedprice, l_discount, l_suppkey,
> o_custkey from orders o join lineitem l on o.o_orderkey = l.l_orderkey and
> l.l_shipdate >= '1995-01-01' and l.l_shipdate <= '1996-12-31' ) l1 on
> c.c_custkey = l1.o_custkey ) l2 on s.s_suppkey = l2.l_suppkey ) l3 on
> l3.c_nationkey = t.c_nationkey and l3.s_nationkey = t.s_nationkey ) shipping
> group by supp_nation, cust_nation, l_year order by supp_nation, cust_nation,
> l_year
> {noformat}
> {noformat}
> Status: RUNNING
> Started: 2015-04-03 15:46:29 ~ -
> # Tasks: 6063 (Local Tasks: 0, Rack Local Tasks: 0)
> Progress: 99%
> # Shuffles: 0
> Input Bytes: 94.4 GiB (101,369,366,283 B)
> Actual Processed Bytes: 94.2 GiB (101,176,763,849 B)
> Input Rows: 3,288,784,087
> Output Bytes: 70.5 GiB (75,663,614,467 B)
> Output Rows: 1,801,836,518
> {noformat}
> The error message is below.
> {noformat}
> 2015-04-03 15:47:40,586 ERROR org.apache.tajo.worker.Task: Fetch failed:
> http://jup-g07-07:52758/?qid=q_1428023002653_0192&sid=4&p=1053&type=h
> java.io.IOException: org.jboss.netty.channel.ConnectTimeoutException:
> connection timed out: jup-g07-07/50.1.101.87:52758
> at org.apache.tajo.worker.Fetcher.get(Fetcher.java:142)
> at org.apache.tajo.worker.Task$FetchRunner.run(Task.java:609)
> at
> java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
> at java.util.concurrent.FutureTask.run(FutureTask.java:262)
> at
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
> at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
> at java.lang.Thread.run(Thread.java:745)
> Caused by: org.jboss.netty.channel.ConnectTimeoutException: connection timed
> out: jup-g07-07/50.1.101.87:52758
> at
> org.jboss.netty.channel.socket.nio.NioClientBoss.processConnectTimeout(NioClientBoss.java:137)
> at
> org.jboss.netty.channel.socket.nio.NioClientBoss.process(NioClientBoss.java:83)
> at
> org.jboss.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:312)
> at
> org.jboss.netty.channel.socket.nio.NioClientBoss.run(NioClientBoss.java:42)
> ... 3 more
> 2015-04-03 15:47:40,594 ERROR org.apache.tajo.worker.Fetcher: Fetch failed :
> org.jboss.netty.channel.ConnectTimeoutException: connection timed out:
> jup-g07-07/50.1.101.87:52758
> at
> org.jboss.netty.channel.socket.nio.NioClientBoss.processConnectTimeout(NioClientBoss.java:137)
> at
> org.jboss.netty.channel.socket.nio.NioClientBoss.process(NioClientBoss.java:83)
> at
> org.jboss.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:312)
> at
> org.jboss.netty.channel.socket.nio.NioClientBoss.run(NioClientBoss.java:42)
> at
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
> at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
> at java.lang.Thread.run(Thread.java:745)
> {noformat}
> Test environments
> {noformat}
> Name Node spec. - R720 x 1Node
> - E5-2650 / 2.5GHz, 2 processor / 12 core / 24 thread
> - 64GB (8 x 8GB)
> - 300GB(3.5”, 15K) x 4
> Data Node spec. – R720xd - 10nodes
> - E5-2650 v2 / 2.6GHz, 2 processor / 16 core / 32 thread
> - 64GB (8 x 8GB)
> - 300GB(3.5”, 15K) x 2EA
> - 3TB (3.5”, 7.2K) x 10EA
> - 10GbE x 2-port
> - 1GbE x 4-port @ on-board
> {noformat}
> Query
> {noformat}
> create table q7_volume_shipping_tmp(supp_nation text, cust_nation text,
> s_nationkey int8, c_nationkey int8);
> insert overwrite into q7_volume_shipping_tmp
> select
> *
> from
> (
> select
> n1.n_name as supp_nation, n2.n_name as cust_nation, n1.n_nationkey as
> s_nationkey,
> n2.n_nationkey as c_nationkey
> from
> nation n1 join nation n2
> on
> n1.n_name = 'FRANCE' and n2.n_name = 'GERMANY'
> UNION ALL
> select
> n1.n_name as supp_nation, n2.n_name as cust_nation, n1.n_nationkey as
> s_nationkey,
> n2.n_nationkey as c_nationkey
> from
> nation n1 join nation n2
> on
> n2.n_name = 'FRANCE' and n1.n_name = 'GERMANY'
> ) a;
> select
> supp_nation, cust_nation, l_year, sum(volume) as revenue
> from
> (
> select
> supp_nation, cust_nation, substr(l_shipdate, 1, 4) as l_year,
> l_extendedprice * (1 - l_discount) as volume
> from
> q7_volume_shipping_tmp t join
> (select l_shipdate, l_extendedprice, l_discount, c_nationkey, s_nationkey
> from supplier s join
> (select l_shipdate, l_extendedprice, l_discount, l_suppkey, c_nationkey
> from customer c join
> (select l_shipdate, l_extendedprice, l_discount, l_suppkey, o_custkey
> from orders o join lineitem l
> on
> o.o_orderkey = l.l_orderkey and l.l_shipdate >= '1995-01-01'
> and l.l_shipdate <= '1996-12-31'
> ) l1 on c.c_custkey = l1.o_custkey
> ) l2 on s.s_suppkey = l2.l_suppkey
> ) l3 on l3.c_nationkey = t.c_nationkey and l3.s_nationkey = t.s_nationkey
> ) shipping
> group by supp_nation, cust_nation, l_year
> order by supp_nation, cust_nation, l_year;
> {noformat}
> tajo configurations
> {noformat}
> export TAJO_MASTER_HEAPSIZE=10240
> export TAJO_WORKER_HEAPSIZE=40960
> export TAJO_QUERYMASTER_HEAPSIZE=4096
> export TAJO_WORKER_OPTS="-server -Xms40960m -XX:+UseParallelOldGC"
> export TAJO_WORKER_STANDBY_MODE=true
> export TAJO_PULLSERVER_MODE=true
> export TAJO_PULLSERVER_STANDALONE=true
> <property>
> <name>tajo.worker.resource.cpu-cores</name>
> <value>30</value>
> </property>
> <property>
> <name>tajo.worker.resource.disks</name>
> <value>20</value>
> </property>
> <property>
> <name>tajo.executor.groupby.in-memory-hash-threshold-bytes</name>
> <value>1073741824</value>
> </property>
> <property>
> <name>tajo.worker.resource.memory-mb</name>
> <value>10240</value>
> </property>
> <property>
> <name>tajo.shuffle.fetcher.read.timeout-sec</name>
> <value>120</value>
> </property>
> <property>
> <name>tajo.dist-query.groupby.partition-volume-mb</name>
> <value>8</value>
> </property>
> <property>
> <name>tajo.shuffle.fetcher.read.retry.max-num</name>
> <value>30</value>
> </property>
> <property>
> <name>tajo.querymaster.rpc.server.worker-thread-num</name>
> <value>100</value>
> </property>
> {noformat}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
