[
https://issues.apache.org/jira/browse/DRILL-1769?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14233425#comment-14233425
]
Steven Phillips commented on DRILL-1769:
----------------------------------------
I just looked into this, and my suspicion is correct. The alter session is
taking affect, but querying the system table does not reflect the change.
0: jdbc:drill:schema=dfs.par100> alter session set `planner.disable_exchanges`
= true;
+------------+------------+
| ok | summary |
+------------+------------+
| true | planner.disable_exchanges updated. |
+------------+------------+
1 row selected (0.051 seconds)
0: jdbc:drill:schema=dfs.par100> select * from sys.options where name =
'planner.disable_exchanges';
+------------+------------+------------+------------+------------+------------+------------+
| name | kind | type | num_val | string_val | bool_val |
float_val |
+------------+------------+------------+------------+------------+------------+------------+
| planner.disable_exchanges | BOOLEAN | SYSTEM | null | null
| false | null |
+------------+------------+------------+------------+------------+------------+------------+
0: jdbc:drill:schema=dfs.par100> explain plan for
. . . . . . . . . . . . . . . .> select
. . . . . . . . . . . . . . . .> l_returnflag,
. . . . . . . . . . . . . . . .> l_linestatus,
. . . . . . . . . . . . . . . .> sum(l_quantity) as sum_qty,
. . . . . . . . . . . . . . . .> sum(l_extendedprice) as sum_base_price,
. . . . . . . . . . . . . . . .> sum(l_extendedprice * (1 - l_discount)) as
sum_disc_price,
. . . . . . . . . . . . . . . .> sum(l_extendedprice * (1 - l_discount) * (1
+ l_tax)) as sum_charge,
. . . . . . . . . . . . . . . .> avg(l_quantity) as avg_qty,
. . . . . . . . . . . . . . . .> avg(l_extendedprice) as avg_price,
. . . . . . . . . . . . . . . .> avg(l_discount) as avg_disc,
. . . . . . . . . . . . . . . .> count(*) as count_order
. . . . . . . . . . . . . . . .> from
. . . . . . . . . . . . . . . .> lineitem
. . . . . . . . . . . . . . . .> where
. . . . . . . . . . . . . . . .> l_shipdate <= date '1998-12-01' - interval
'120' day (3)
. . . . . . . . . . . . . . . .> group by
. . . . . . . . . . . . . . . .> l_returnflag,
. . . . . . . . . . . . . . . .> l_linestatus
. . . . . . . . . . . . . . . .>
. . . . . . . . . . . . . . . .> order by
. . . . . . . . . . . . . . . .> l_returnflag,
. . . . . . . . . . . . . . . .> l_linestatus;
+------------+------------+
| text | json |
+------------+------------+
| 00-00 Screen
00-01 Project(l_returnflag=[$0], l_linestatus=[$1], sum_qty=[$2],
sum_base_price=[$3], sum_disc_price=[$4], sum_charge=[$5], avg_qty=[$6],
avg_price=[$7], avg_disc=[$8], count_order=[$9])
00-02 SelectionVectorRemover
00-03 Sort(sort0=[$0], sort1=[$1], dir0=[ASC], dir1=[ASC])
00-04 Project(l_returnflag=[$0], l_linestatus=[$1],
sum_qty=[CASE(=($3, 0), null, $2)], sum_base_price=[CASE(=($5, 0), null, $4)],
sum_disc_price=[CASE(=($7, 0), null, $6)], sum_charge=[CASE(=($9, 0), null,
$8)], avg_qty=[CAST(/(CastHigh(CASE(=($3, 0), null, $2)), $3)):ANY],
avg_price=[CAST(/(CastHigh(CASE(=($5, 0), null, $4)), $5)):ANY],
avg_disc=[CAST(/(CastHigh(CASE(=($11, 0), null, $10)), $11)):ANY],
count_order=[$12])
00-05 HashAgg(group=[{0, 1}], agg#0=[$SUM0($2)],
agg#1=[COUNT($2)], agg#2=[$SUM0($3)], agg#3=[COUNT($3)], agg#4=[$SUM0($4)],
agg#5=[COUNT($4)], agg#6=[$SUM0($5)], agg#7=[COUNT($5)], agg#8=[$SUM0($6)],
agg#9=[COUNT($6)], count_order=[COUNT()])
00-06 Project(l_returnflag=[$0], l_linestatus=[$1],
l_quantity=[$3], l_extendedprice=[$4], $f4=[*($4, -(1, $5))], $f5=[*(*($4, -(1,
$5)), +(1, $6))], l_discount=[$5])
00-07 Filter(condition=[<=($2, -(1998-12-01, 10368000000))])
00-08 Project(l_returnflag=[$1], l_linestatus=[$6],
l_shipdate=[$5], l_quantity=[$2], l_extendedprice=[$3], l_discount=[$0],
l_tax=[$4])
00-09 Scan(groupscan=[ParquetGroupScan
[entries=[ReadEntryWithPath [path=maprfs:/tpchParquet/SF100/lineitem]],
selectionRoot=/tpchParquet/SF100/lineitem, numFiles=1, columns=[`l_returnflag`,
`l_linestatus`, `l_shipdate`, `l_quantity`, `l_extendedprice`, `l_discount`,
`l_tax`]]])
> alter session appears not working anymore
> -----------------------------------------
>
> Key: DRILL-1769
> URL: https://issues.apache.org/jira/browse/DRILL-1769
> Project: Apache Drill
> Issue Type: Bug
> Components: Storage - Information Schema
> Affects Versions: 0.7.0
> Reporter: Chun Chang
>
> #Thu Nov 20 16:40:45 PST 2014
> git.commit.id.abbrev=fc58c69
> The alter session set returns ok and value updated, but no session entry
> added.
> 0: jdbc:drill:schema=dfs.drillTestDir> ALTER SESSION SET
> `planner.enable_hashagg` = false;
> +------------+------------+
> | ok | summary |
> +------------+------------+
> | true | planner.enable_hashagg updated. |
> +------------+------------+
> 0: jdbc:drill:schema=dfs.drillTestDir> select * from sys.options where name
> like 'planner%';
> +------------+------------+------------+------------+------------+------------+------------+
> | name | kind | type | num_val | string_val | bool_val
> | float_val |
> +------------+------------+------------+------------+------------+------------+------------+
> | planner.memory.max_query_memory_per_node | LONG | SYSTEM | 2048
> | null | null | null |
> | planner.affinity_factor | DOUBLE | SYSTEM | null | null
> | null | 1.2 |
> | planner.join.row_count_estimate_factor | DOUBLE | SYSTEM | null
> | null | null | 1.0 |
> | planner.disable_exchanges | BOOLEAN | SYSTEM | null | null
> | false | null |
> | planner.enable_mergejoin | BOOLEAN | SYSTEM | null | null
> | true | null |
> | planner.enable_broadcast_join | BOOLEAN | SYSTEM | null | null
> | true | null |
> | planner.enable_hashagg | BOOLEAN | SYSTEM | null | null
> | true | null |
> | planner.memory.average_field_width | LONG | SYSTEM | 8 |
> null | null | null |
> | planner.broadcast_threshold | LONG | SYSTEM | 1000000 | null
> | null | null |
> | planner.add_producer_consumer | BOOLEAN | SYSTEM | null | null
> | false | null |
> | planner.producer_consumer_queue_size | LONG | SYSTEM | 10
> | null | null | null |
> | planner.enable_hash_single_key | BOOLEAN | SYSTEM | null |
> null | true | null |
> | planner.memory.hash_agg_table_factor | DOUBLE | SYSTEM | null
> | null | null | 1.1 |
> | planner.width.max_per_node | LONG | SYSTEM | 17 | null
> | null | null |
> | planner.slice_target | LONG | SYSTEM | 100000 | null |
> null | null |
> | planner.enable_multiphase_agg | BOOLEAN | SYSTEM | null | null
> | true | null |
> | planner.memory.enable_memory_estimation | BOOLEAN | SYSTEM | null
> | null | false | null |
> | planner.memory.non_blocking_operators_memory | LONG | SYSTEM | 64
> | null | null | null |
> | planner.enable_streamagg | BOOLEAN | SYSTEM | null | null
> | true | null |
> | planner.memory.hash_join_table_factor | DOUBLE | SYSTEM | null
> | null | null | 1.1 |
> | planner.width.max_per_query | LONG | SYSTEM | 1000 | null
> | null | null |
> | planner.enable_hashjoin | BOOLEAN | SYSTEM | null | null
> | true | null |
> +------------+------------+------------+------------+------------+------------+------------+
> 22 rows selected (0.106 seconds)
> Alter system set works.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
