weijunlu commented on issue #2723:
URL: https://github.com/apache/drill/issues/2723#issuecomment-1366575973
2022-12-28 19:03:07,204 [main] DEBUG o.a.d.j.impl.DrillStatementRegistry -
Adding to open-statements registry:
org.apache.drill.jdbc.impl.DrillStatementImpl@71df3d2b
2022-12-28 19:03:07,204 [main] DEBUG o.a.d.j.i.DrillCursor$ResultsListener -
[#2] Query listener created.
2022-12-28 19:03:07,204 [main] DEBUG o.apache.drill.jdbc.impl.DrillCursor -
Setting timeout as 0
2022-12-28 19:03:07,206 [UserServer-1] DEBUG
o.a.d.e.r.u.UserServerRequestHandler - Received query to run. Returning query
handle.
2022-12-28 19:03:07,215 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] DEBUG
o.a.d.e.w.f.QueryStateProcessor - 1c53dd94-4277-9ab0-effe-18b1ab8989ac: State
change requested PREPARING --> PLANNING
2022-12-28 19:03:07,215 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] INFO
o.a.drill.exec.work.foreman.Foreman - Query text for query with id
1c53dd94-4277-9ab0-effe-18b1ab8989ac issued by anonymous: insert into
pg.public.t1 select c1, c2 from mysql.test.t1
2022-12-28 19:03:07,215 [Client-1] DEBUG
o.a.d.j.i.DrillCursor$ResultsListener - [#2] Received query ID:
1c53dd94-4277-9ab0-effe-18b1ab8989ac.
2022-12-28 19:03:07,215 [Client-1] DEBUG o.a.d.e.rpc.user.QueryResultHandler
- Received QueryId 1c53dd94-4277-9ab0-effe-18b1ab8989ac successfully. Adding
results listener
org.apache.drill.jdbc.impl.DrillCursor$ResultsListener@29741514.
2022-12-28 19:03:07,222 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
org.apache.calcite.sql.parser - After unconditional rewrite: INSERT INTO
`pg`.`public`.`t1`
(SELECT `c1`, `c2`
FROM `mysql`.`test`.`t1`)
2022-12-28 19:03:07,308 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
org.apache.calcite.sql.parser - After validation: INSERT INTO `pg`.`public`.`t1`
(SELECT `t1`.`c1`, `t1`.`c2`
FROM `mysql`.`test`.`t1` AS `t1`)
2022-12-28 19:03:07,308 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is 'INSERT INTO'; result is false
2022-12-28 19:03:07,309 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is 'pg'; result is false
2022-12-28 19:03:07,309 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is '.'; result is false
2022-12-28 19:03:07,309 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is 'public'; result is false
2022-12-28 19:03:07,309 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is '.'; result is false
2022-12-28 19:03:07,309 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is 't1'; result is false
2022-12-28 19:03:07,309 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is ''; result is false
2022-12-28 19:03:07,309 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is '('; result is false
2022-12-28 19:03:07,309 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is 'SELECT'; result is false
2022-12-28 19:03:07,309 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is 't1'; result is false
2022-12-28 19:03:07,309 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is '.'; result is false
2022-12-28 19:03:07,309 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is 'c1'; result is false
2022-12-28 19:03:07,309 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is ''; result is false
2022-12-28 19:03:07,309 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is ','; result is false
2022-12-28 19:03:07,309 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is 't1'; result is false
2022-12-28 19:03:07,309 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is '.'; result is false
2022-12-28 19:03:07,309 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is 'c2'; result is false
2022-12-28 19:03:07,309 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is ''; result is false
2022-12-28 19:03:07,309 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is ''; result is false
2022-12-28 19:03:07,309 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is 'FROM'; result is false
2022-12-28 19:03:07,309 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is 'mysql'; result is false
2022-12-28 19:03:07,309 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is '.'; result is false
2022-12-28 19:03:07,309 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is 'test'; result is false
2022-12-28 19:03:07,309 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is '.'; result is false
2022-12-28 19:03:07,309 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is 't1'; result is false
2022-12-28 19:03:07,309 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is ''; result is false
2022-12-28 19:03:07,309 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is 'AS'; result is false
2022-12-28 19:03:07,309 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is 't1'; result is false
2022-12-28 19:03:07,309 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is ''; result is false
2022-12-28 19:03:07,309 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is ''; result is false
2022-12-28 19:03:07,309 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is ''; result is false
2022-12-28 19:03:07,309 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is ''; result is false
2022-12-28 19:03:07,309 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is ')'; result is false
2022-12-28 19:03:07,312 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is 'INSERT INTO'; result is false
2022-12-28 19:03:07,312 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is 'pg'; result is false
2022-12-28 19:03:07,313 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is '.'; result is false
2022-12-28 19:03:07,313 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is 'public'; result is false
2022-12-28 19:03:07,313 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is '.'; result is false
2022-12-28 19:03:07,313 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is 't1'; result is false
2022-12-28 19:03:07,313 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is ''; result is false
2022-12-28 19:03:07,313 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is '('; result is false
2022-12-28 19:03:07,313 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is 'SELECT'; result is false
2022-12-28 19:03:07,313 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is 't1'; result is false
2022-12-28 19:03:07,313 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is '.'; result is false
2022-12-28 19:03:07,313 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is 'c1'; result is false
2022-12-28 19:03:07,313 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is ''; result is false
2022-12-28 19:03:07,313 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is ','; result is false
2022-12-28 19:03:07,313 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is 't1'; result is false
2022-12-28 19:03:07,313 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is '.'; result is false
2022-12-28 19:03:07,313 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is 'c2'; result is false
2022-12-28 19:03:07,313 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is ''; result is false
2022-12-28 19:03:07,313 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is ''; result is false
2022-12-28 19:03:07,313 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is 'FROM'; result is false
2022-12-28 19:03:07,313 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is 'mysql'; result is false
2022-12-28 19:03:07,313 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is '.'; result is false
2022-12-28 19:03:07,313 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is 'test'; result is false
2022-12-28 19:03:07,313 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is '.'; result is false
2022-12-28 19:03:07,313 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is 't1'; result is false
2022-12-28 19:03:07,313 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is ''; result is false
2022-12-28 19:03:07,313 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is 'AS'; result is false
2022-12-28 19:03:07,313 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is 't1'; result is false
2022-12-28 19:03:07,313 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is ''; result is false
2022-12-28 19:03:07,313 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is ''; result is false
2022-12-28 19:03:07,313 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is ''; result is false
2022-12-28 19:03:07,313 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is ''; result is false
2022-12-28 19:03:07,313 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is ')'; result is false
2022-12-28 19:03:07,313 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is 'INSERT INTO'; result is false
2022-12-28 19:03:07,313 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is 'pg'; result is false
2022-12-28 19:03:07,313 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is '.'; result is false
2022-12-28 19:03:07,313 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is 'public'; result is false
2022-12-28 19:03:07,313 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is '.'; result is false
2022-12-28 19:03:07,313 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is 't1'; result is false
2022-12-28 19:03:07,313 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is ''; result is false
2022-12-28 19:03:07,313 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is '('; result is false
2022-12-28 19:03:07,313 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is 'SELECT'; result is false
2022-12-28 19:03:07,313 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is 't1'; result is false
2022-12-28 19:03:07,313 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is '.'; result is false
2022-12-28 19:03:07,313 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is 'c1'; result is false
2022-12-28 19:03:07,313 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is ''; result is false
2022-12-28 19:03:07,313 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is ','; result is false
2022-12-28 19:03:07,313 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is 't1'; result is false
2022-12-28 19:03:07,313 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is '.'; result is false
2022-12-28 19:03:07,313 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is 'c2'; result is false
2022-12-28 19:03:07,313 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is ''; result is false
2022-12-28 19:03:07,313 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is ''; result is false
2022-12-28 19:03:07,313 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is 'FROM'; result is false
2022-12-28 19:03:07,313 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is 'mysql'; result is false
2022-12-28 19:03:07,313 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is '.'; result is false
2022-12-28 19:03:07,313 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is 'test'; result is false
2022-12-28 19:03:07,313 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is '.'; result is false
2022-12-28 19:03:07,313 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is 't1'; result is false
2022-12-28 19:03:07,313 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is ''; result is false
2022-12-28 19:03:07,313 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is 'AS'; result is false
2022-12-28 19:03:07,313 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is 't1'; result is false
2022-12-28 19:03:07,313 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is ''; result is false
2022-12-28 19:03:07,313 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is ''; result is false
2022-12-28 19:03:07,313 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is ''; result is false
2022-12-28 19:03:07,313 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is ''; result is false
2022-12-28 19:03:07,313 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.a.c.sql.pretty.SqlPrettyWriter - Token is ')'; result is false
2022-12-28 19:03:07,315 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] DEBUG
org.apache.calcite.sql2rel - Plan after converting SqlNode to RelNode
LogicalTableModify(table=[[pg, public, t1]], operation=[INSERT],
flattened=[false])
LogicalProject(c1=[$0], c2=[$1])
JdbcTableScan(table=[[mysql, test, t1]])
2022-12-28 19:03:07,316 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] DEBUG
o.a.d.e.p.s.h.DefaultSqlHandler - INITIAL:
LogicalTableModify(table=[[pg, public, t1]], operation=[INSERT],
flattened=[true]): rowcount = 1.0E9, cumulative cost = {2.0000001E9 rows,
2.000000101E9 cpu, 0.0 io, 0.0 network, 0.0 memory}, id = 91
LogicalProject(c1=[$0], c2=[$1]): rowcount = 1.0E9, cumulative cost =
{1.0000001E9 rows, 2.000000101E9 cpu, 0.0 io, 0.0 network, 0.0 memory}, id = 90
JdbcTableScan(table=[[mysql, test, t1]]): rowcount = 1.0E9, cumulative
cost = {100.0 rows, 101.0 cpu, 0.0 io, 0.0 network, 0.0 memory}, id = 89
2022-12-28 19:03:07,317 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.apache.calcite.plan.RelOptPlanner -
Breadth-first from root: {
rel#96:HepRelVertex(rel#95:LogicalTableModify.NONE.ANY([]).[](input=HepRelVertex#94,table=[pg,
public, t1],operation=INSERT,flattened=true)) =
rel#95:LogicalTableModify.NONE.ANY([]).[](input=HepRelVertex#94,table=[pg,
public, t1],operation=INSERT,flattened=true), rowcount=1.0E9, cumulative
cost={2.0000001E9 rows, 2.000000101E9 cpu, 0.0 io, 0.0 network, 0.0 memory}
rel#94:HepRelVertex(rel#93:LogicalProject.NONE.ANY([]).[](input=HepRelVertex#92,inputs=0..1))
= rel#93:LogicalProject.NONE.ANY([]).[](input=HepRelVertex#92,inputs=0..1),
rowcount=1.0E9, cumulative cost={1.0000001E9 rows, 2.000000101E9 cpu, 0.0 io,
0.0 network, 0.0 memory}
rel#92:HepRelVertex(rel#89:JdbcTableScan.JDBC.mysql.ANY([]).[](table=[mysql,
test, t1])) = rel#89:JdbcTableScan.JDBC.mysql.ANY([]).[](table=[mysql, test,
t1]), rowcount=1.0E9, cumulative cost={100.0 rows, 101.0 cpu, 0.0 io, 0.0
network, 0.0 memory}
}
2022-12-28 19:03:07,318 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.apache.calcite.plan.RelOptPlanner - Applying rule set
[SubQueryRemoveRule:Filter]
2022-12-28 19:03:07,318 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.apache.calcite.plan.RelOptPlanner - collecting garbage
2022-12-28 19:03:07,318 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.apache.calcite.plan.RelOptPlanner - Applying rule set
[SubQueryRemoveRule:Project]
2022-12-28 19:03:07,318 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.apache.calcite.plan.RelOptPlanner - Applying rule set
[SubQueryRemoveRule:Join]
2022-12-28 19:03:07,318 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] DEBUG
o.a.c.p.A.rule_execution_summary - Rule Attempts Info for HepPlanner
2022-12-28 19:03:07,318 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] DEBUG
o.a.c.p.A.rule_execution_summary -
Rules
Attempts Time (us)
* Total
0 0
2022-12-28 19:03:07,318 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] DEBUG
o.apache.calcite.plan.RelOptPlanner - For final plan, using
rel#95:LogicalTableModify.NONE.ANY([]).[](input=HepRelVertex#94,table=[pg,
public, t1],operation=INSERT,flattened=true)
2022-12-28 19:03:07,318 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] DEBUG
o.apache.calcite.plan.RelOptPlanner - For final plan, using
rel#93:LogicalProject.NONE.ANY([]).[](input=HepRelVertex#92,inputs=0..1)
2022-12-28 19:03:07,318 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] DEBUG
o.apache.calcite.plan.RelOptPlanner - For final plan, using
rel#89:JdbcTableScan.JDBC.mysql.ANY([]).[](table=[mysql, test, t1])
2022-12-28 19:03:07,318 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] DEBUG
o.a.d.e.p.s.h.DefaultSqlHandler - HEP:Sub-queries rewrites (1ms):
LogicalTableModify(table=[[pg, public, t1]], operation=[INSERT],
flattened=[true]): rowcount = 1.0E9, cumulative cost = {2.0000001E9 rows,
2.000000101E9 cpu, 0.0 io, 0.0 network, 0.0 memory}, id = 95
LogicalProject(c1=[$0], c2=[$1]): rowcount = 1.0E9, cumulative cost =
{1.0000001E9 rows, 2.000000101E9 cpu, 0.0 io, 0.0 network, 0.0 memory}, id = 93
JdbcTableScan(table=[[mysql, test, t1]]): rowcount = 1.0E9, cumulative
cost = {100.0 rows, 101.0 cpu, 0.0 io, 0.0 network, 0.0 memory}, id = 89
2022-12-28 19:03:07,319 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.apache.calcite.plan.RelOptPlanner -
Breadth-first from root: {
rel#101:HepRelVertex(rel#100:LogicalTableModify.NONE.ANY([]).[](input=HepRelVertex#99,table=[pg,
public, t1],operation=INSERT,flattened=true)) =
rel#100:LogicalTableModify.NONE.ANY([]).[](input=HepRelVertex#99,table=[pg,
public, t1],operation=INSERT,flattened=true), rowcount=1.0E9, cumulative
cost={2.0000001E9 rows, 2.000000101E9 cpu, 0.0 io, 0.0 network, 0.0 memory}
rel#99:HepRelVertex(rel#98:LogicalProject.NONE.ANY([]).[](input=HepRelVertex#97,inputs=0..1))
= rel#98:LogicalProject.NONE.ANY([]).[](input=HepRelVertex#97,inputs=0..1),
rowcount=1.0E9, cumulative cost={1.0000001E9 rows, 2.000000101E9 cpu, 0.0 io,
0.0 network, 0.0 memory}
rel#97:HepRelVertex(rel#89:JdbcTableScan.JDBC.mysql.ANY([]).[](table=[mysql,
test, t1])) = rel#89:JdbcTableScan.JDBC.mysql.ANY([]).[](table=[mysql, test,
t1]), rowcount=1.0E9, cumulative cost={100.0 rows, 101.0 cpu, 0.0 io, 0.0
network, 0.0 memory}
}
2022-12-28 19:03:07,319 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.apache.calcite.plan.RelOptPlanner - Applying rule set
[ReduceExpressionsRule(Calc)]
2022-12-28 19:03:07,319 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.apache.calcite.plan.RelOptPlanner - collecting garbage
2022-12-28 19:03:07,319 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.apache.calcite.plan.RelOptPlanner - Applying rule set
[ProjectToWindowRule:project]
2022-12-28 19:03:07,319 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] DEBUG
o.a.c.p.A.rule_execution_summary - Rule Attempts Info for HepPlanner
2022-12-28 19:03:07,319 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] DEBUG
o.a.c.p.A.rule_execution_summary -
Rules
Attempts Time (us)
* Total
0 0
2022-12-28 19:03:07,319 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] DEBUG
o.apache.calcite.plan.RelOptPlanner - For final plan, using
rel#100:LogicalTableModify.NONE.ANY([]).[](input=HepRelVertex#99,table=[pg,
public, t1],operation=INSERT,flattened=true)
2022-12-28 19:03:07,319 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] DEBUG
o.apache.calcite.plan.RelOptPlanner - For final plan, using
rel#98:LogicalProject.NONE.ANY([]).[](input=HepRelVertex#97,inputs=0..1)
2022-12-28 19:03:07,319 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] DEBUG
o.apache.calcite.plan.RelOptPlanner - For final plan, using
rel#89:JdbcTableScan.JDBC.mysql.ANY([]).[](table=[mysql, test, t1])
2022-12-28 19:03:07,319 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] DEBUG
o.a.d.e.p.s.h.DefaultSqlHandler - HEP:Window Function rewrites (1ms):
LogicalTableModify(table=[[pg, public, t1]], operation=[INSERT],
flattened=[true]): rowcount = 1.0E9, cumulative cost = {2.0000001E9 rows,
2.000000101E9 cpu, 0.0 io, 0.0 network, 0.0 memory}, id = 100
LogicalProject(c1=[$0], c2=[$1]): rowcount = 1.0E9, cumulative cost =
{1.0000001E9 rows, 2.000000101E9 cpu, 0.0 io, 0.0 network, 0.0 memory}, id = 98
JdbcTableScan(table=[[mysql, test, t1]]): rowcount = 1.0E9, cumulative
cost = {100.0 rows, 101.0 cpu, 0.0 io, 0.0 network, 0.0 memory}, id = 89
2022-12-28 19:03:07,321 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.apache.calcite.plan.RelOptPlanner -
Breadth-first from root: {
rel#108:HepRelVertex(rel#107:LogicalTableModify.NONE.ANY([]).[](input=HepRelVertex#106,table=[pg,
public, t1],operation=INSERT,flattened=true)) =
rel#107:LogicalTableModify.NONE.ANY([]).[](input=HepRelVertex#106,table=[pg,
public, t1],operation=INSERT,flattened=true), rowcount=1.0E9, cumulative
cost={2.0000001E9 rows, 2.000000101E9 cpu, 0.0 io, 0.0 network, 0.0 memory}
rel#106:HepRelVertex(rel#105:LogicalProject.NONE.ANY([]).[](input=HepRelVertex#104,inputs=0..1))
= rel#105:LogicalProject.NONE.ANY([]).[](input=HepRelVertex#104,inputs=0..1),
rowcount=1.0E9, cumulative cost={1.0000001E9 rows, 2.000000101E9 cpu, 0.0 io,
0.0 network, 0.0 memory}
rel#104:HepRelVertex(rel#89:JdbcTableScan.JDBC.mysql.ANY([]).[](table=[mysql,
test, t1])) = rel#89:JdbcTableScan.JDBC.mysql.ANY([]).[](table=[mysql, test,
t1]), rowcount=1.0E9, cumulative cost={100.0 rows, 101.0 cpu, 0.0 io, 0.0
network, 0.0 memory}
}
2022-12-28 19:03:07,321 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.apache.calcite.plan.RelOptPlanner - Setting match order to BOTTOM_UP
2022-12-28 19:03:07,321 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.apache.calcite.plan.RelOptPlanner - collecting garbage
2022-12-28 19:03:07,321 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.apache.calcite.plan.RelOptPlanner - Applying rule set
[DrillFilterItemStarReWriterRule.ProjectOnScan]
2022-12-28 19:03:07,321 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.apache.calcite.plan.RelOptPlanner - Applying rule set
[DrillFilterItemStarReWriterRule.FilterOnScan]
2022-12-28 19:03:07,321 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.apache.calcite.plan.RelOptPlanner - Applying rule set
[DrillFilterItemStarReWriterRule.FilterProjectScan]
2022-12-28 19:03:07,321 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.apache.calcite.plan.RelOptPlanner - Applying rule set
[DirPruneScanRule:Filter_On_Project]
2022-12-28 19:03:07,321 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.apache.calcite.plan.RelOptPlanner - Applying rule set
[DirPruneScanRule:Filter_On_Scan]
2022-12-28 19:03:07,321 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.apache.calcite.plan.RelOptPlanner - Applying rule set
[PartitionColumnScanPruningRule:Prune_On_Scan]
2022-12-28 19:03:07,321 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.apache.calcite.plan.RelOptPlanner - Applying rule set
[ConvertCountToDirectScanRule:Agg_on_proj_on_scan]
2022-12-28 19:03:07,321 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.apache.calcite.plan.RelOptPlanner - Applying rule set
[ConvertCountToDirectScanRule:Agg_on_scan]
2022-12-28 19:03:07,321 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] DEBUG
o.a.c.p.A.rule_execution_summary - Rule Attempts Info for HepPlanner
2022-12-28 19:03:07,322 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] DEBUG
o.a.c.p.A.rule_execution_summary -
Rules
Attempts Time (us)
* Total
0 0
2022-12-28 19:03:07,322 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] DEBUG
o.apache.calcite.plan.RelOptPlanner - For final plan, using
rel#107:LogicalTableModify.NONE.ANY([]).[](input=HepRelVertex#106,table=[pg,
public, t1],operation=INSERT,flattened=true)
2022-12-28 19:03:07,322 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] DEBUG
o.apache.calcite.plan.RelOptPlanner - For final plan, using
rel#105:LogicalProject.NONE.ANY([]).[](input=HepRelVertex#104,inputs=0..1)
2022-12-28 19:03:07,322 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] DEBUG
o.apache.calcite.plan.RelOptPlanner - For final plan, using
rel#89:JdbcTableScan.JDBC.mysql.ANY([]).[](table=[mysql, test, t1])
2022-12-28 19:03:07,322 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] DEBUG
o.a.d.e.p.s.h.DefaultSqlHandler - HEP_BOTTOM_UP:Directory Prune Planning (1ms):
LogicalTableModify(table=[[pg, public, t1]], operation=[INSERT],
flattened=[true]): rowcount = 1.0E9, cumulative cost = {2.0000001E9 rows,
2.000000101E9 cpu, 0.0 io, 0.0 network, 0.0 memory}, id = 107
LogicalProject(c1=[$0], c2=[$1]): rowcount = 1.0E9, cumulative cost =
{1.0000001E9 rows, 2.000000101E9 cpu, 0.0 io, 0.0 network, 0.0 memory}, id = 105
JdbcTableScan(table=[[mysql, test, t1]]): rowcount = 1.0E9, cumulative
cost = {100.0 rows, 101.0 cpu, 0.0 io, 0.0 network, 0.0 memory}, id = 89
2022-12-28 19:03:07,323 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.apache.calcite.plan.RelOptPlanner - Subset cost changed: subset
[rel#109:RelSubset#0.JDBC.mysql.ANY([]).[]] cost was {inf} now {100.0 rows,
101.0 cpu, 0.0 io, 0.0 network, 0.0 memory}
2022-12-28 19:03:07,324 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.apache.calcite.plan.RelOptPlanner - Register
rel#89:JdbcTableScan.JDBC.mysql.ANY([]).[](table=[mysql, test, t1]) in
rel#109:RelSubset#0.JDBC.mysql.ANY([]).[]
2022-12-28 19:03:07,324 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.apache.calcite.plan.RelOptPlanner - Rule-match queued: rule
[VertexDrelConverterRuleJDBC.mysql(in:JDBC.mysql,out:LOGICAL)] rels [#89]
2022-12-28 19:03:07,324 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.apache.calcite.plan.RelOptPlanner - Register
rel#110:LogicalProject.NONE.ANY([]).[](input=RelSubset#109,inputs=0..1) in
rel#111:RelSubset#1.NONE.ANY([]).[]
2022-12-28 19:03:07,324 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.apache.calcite.plan.RelOptPlanner - Rule-match queued: rule
[ProjectRemoveRule] rels [#110]
2022-12-28 19:03:07,324 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.apache.calcite.plan.RelOptPlanner - Rule-match queued: rule
[DrillProjectRule] rels [#110]
2022-12-28 19:03:07,324 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.apache.calcite.plan.RelOptPlanner - Rule-match queued: rule
[ReduceAndSimplifyProjectRule] rels [#110]
2022-12-28 19:03:07,324 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.apache.calcite.plan.RelOptPlanner - Rule-match queued: rule
[ReduceExpressionsRule(Project)] rels [#110]
2022-12-28 19:03:07,325 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.apache.calcite.plan.RelOptPlanner - Rule-match queued: rule
[DrillJdbcProjectRule(in:NONE,out:JDBC.mysql)] rels [#110]
2022-12-28 19:03:07,325 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.apache.calcite.plan.RelOptPlanner - Rule-match queued: rule
[DrillJdbcProjectRule(in:NONE,out:JDBC.pg)] rels [#110]
2022-12-28 19:03:07,325 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.apache.calcite.plan.RelOptPlanner - Register
rel#112:LogicalTableModify.NONE.ANY([]).[](input=RelSubset#111,table=[pg,
public, t1],operation=INSERT,flattened=true) in
rel#113:RelSubset#2.NONE.ANY([]).[]
2022-12-28 19:03:07,325 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.apache.calcite.plan.RelOptPlanner - Rule-match queued: rule
[DrillTableModifyRule] rels [#112]
2022-12-28 19:03:07,325 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.apache.calcite.plan.RelOptPlanner - Rule-match queued: rule
[JdbcTableModificationRule(in:NONE,out:JDBC.mysql)(in:NONE,out:JDBC.mysql)]
rels [#112]
2022-12-28 19:03:07,325 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.apache.calcite.plan.RelOptPlanner - Rule-match queued: rule
[JdbcTableModificationRule(in:NONE,out:JDBC.pg)(in:NONE,out:JDBC.pg)] rels
[#112]
2022-12-28 19:03:07,326 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.apache.calcite.plan.RelOptPlanner - Register
rel#115:AbstractConverter.LOGICAL.ANY([]).[](input=RelSubset#113,convention=LOGICAL,DrillDistributionTraitDef=ANY([]),sort=[])
in rel#114:RelSubset#2.LOGICAL.ANY([]).[]
2022-12-28 19:03:07,326 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.apache.calcite.plan.RelOptPlanner - Rule-match queued: rule
[ExpandConversionRule] rels [#115]
2022-12-28 19:03:07,326 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] DEBUG
o.apache.calcite.plan.RelOptPlanner - Best cost before rule match: {inf}
2022-12-28 19:03:07,326 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.apache.calcite.plan.RelOptPlanner - Root:
rel#114:RelSubset#2.LOGICAL.ANY([]).[]
Original rel:
LogicalTableModify(subset=[rel#114:RelSubset#2.LOGICAL.ANY([]).[]],
table=[[pg, public, t1]], operation=[INSERT], flattened=[true]): rowcount =
1.0E9, cumulative cost = {1.0E9 rows, 0.0 cpu, 0.0 io, 0.0 network, 0.0
memory}, id = 112
LogicalProject(subset=[rel#111:RelSubset#1.NONE.ANY([]).[]], c1=[$0],
c2=[$1]): rowcount = 1.0E9, cumulative cost = {1.0E9 rows, 2.0E9 cpu, 0.0 io,
0.0 network, 0.0 memory}, id = 110
JdbcTableScan(subset=[rel#109:RelSubset#0.JDBC.mysql.ANY([]).[]],
table=[[mysql, test, t1]]): rowcount = 1.0E9, cumulative cost = {100.0 rows,
101.0 cpu, 0.0 io, 0.0 network, 0.0 memory}, id = 89
Sets:
Set#0, type: RecordType(INTEGER c1, INTEGER c2)
rel#109:RelSubset#0.JDBC.mysql.ANY([]).[], best=rel#89
rel#89:JdbcTableScan.JDBC.mysql.ANY([]).[](table=[mysql, test,
t1]), rowcount=1.0E9, cumulative cost={100.0 rows, 101.0 cpu, 0.0 io, 0.0
network, 0.0 memory}
Set#1, type: RecordType(INTEGER c1, INTEGER c2)
rel#111:RelSubset#1.NONE.ANY([]).[], best=null
rel#110:LogicalProject.NONE.ANY([]).[](input=RelSubset#109,inputs=0..1),
rowcount=1.0E9, cumulative cost={inf}
Set#2, type: RecordType(BIGINT ROWCOUNT)
rel#113:RelSubset#2.NONE.ANY([]).[], best=null
rel#112:LogicalTableModify.NONE.ANY([]).[](input=RelSubset#111,table=[pg,
public, t1],operation=INSERT,flattened=true), rowcount=1.0E9, cumulative
cost={inf}
rel#114:RelSubset#2.LOGICAL.ANY([]).[], best=null
rel#115:AbstractConverter.LOGICAL.ANY([]).[](input=RelSubset#113,convention=LOGICAL,DrillDistributionTraitDef=ANY([]),sort=[]),
rowcount=1.0E9, cumulative cost={inf}
Graphviz:
digraph G {
root [style=filled,label="Root"];
subgraph cluster0{
label="Set 0 RecordType(INTEGER c1, INTEGER c2)";
rel89 [label="rel#89:JdbcTableScan\ntable=[mysql, test,
t1]\nrows=1.0E9, cost={100.0 rows, 101.0 cpu, 0.0 io, 0.0 network, 0.0
memory}",color=blue,shape=box]
subset109 [label="rel#109:RelSubset#0.JDBC.mysql.ANY([]).[]"]
}
subgraph cluster1{
label="Set 1 RecordType(INTEGER c1, INTEGER c2)";
rel110
[label="rel#110:LogicalProject\ninput=RelSubset#109,inputs=0..1\nrows=1.0E9,
cost={inf}",shape=box]
subset111 [label="rel#111:RelSubset#1.NONE.ANY([]).[]"]
}
subgraph cluster2{
label="Set 2 RecordType(BIGINT ROWCOUNT)";
rel112
[label="rel#112:LogicalTableModify\ninput=RelSubset#111,table=[pg, public,
t1],operation=INSERT,flattened=true\nrows=1.0E9, cost={inf}",shape=box]
rel115
[label="rel#115:AbstractConverter\ninput=RelSubset#113,convention=LOGICAL,DrillDistributionTraitDef=ANY([]),sort=[]\nrows=1.0E9,
cost={inf}",shape=box]
subset113 [label="rel#113:RelSubset#2.NONE.ANY([]).[]"]
subset114
[label="rel#114:RelSubset#2.LOGICAL.ANY([]).[]",color=red]
}
root -> subset114;
subset109 -> rel89[color=blue];
subset111 -> rel110; rel110 -> subset109;
subset113 -> rel112; rel112 -> subset111;
subset114 -> rel115; rel115 -> subset113;
}
2022-12-28 19:03:07,326 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.apache.calcite.plan.RelOptPlanner - Rule queue:
rule [ProjectRemoveRule] rels [#110]
rule [ReduceAndSimplifyProjectRule] rels [#110]
rule [ReduceExpressionsRule(Project)] rels [#110]
rule [VertexDrelConverterRuleJDBC.mysql(in:JDBC.mysql,out:LOGICAL)] rels
[#89]
rule [DrillProjectRule] rels [#110]
rule [DrillJdbcProjectRule(in:NONE,out:JDBC.mysql)] rels [#110]
rule [DrillJdbcProjectRule(in:NONE,out:JDBC.pg)] rels [#110]
rule [DrillTableModifyRule] rels [#112]
rule
[JdbcTableModificationRule(in:NONE,out:JDBC.mysql)(in:NONE,out:JDBC.mysql)]
rels [#112]
rule [JdbcTableModificationRule(in:NONE,out:JDBC.pg)(in:NONE,out:JDBC.pg)]
rels [#112]
rule [ExpandConversionRule] rels [#115]
2022-12-28 19:03:07,326 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] DEBUG
o.apache.calcite.plan.RelOptPlanner - Pop match: rule [ProjectRemoveRule] rels
[#110]
2022-12-28 19:03:07,326 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] DEBUG
o.apache.calcite.plan.RelOptPlanner - call#169: Apply rule [ProjectRemoveRule]
to [rel#110:LogicalProject]
2022-12-28 19:03:07,326 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] DEBUG
o.apache.calcite.plan.RelOptPlanner - Transform to: rel#116 via
ProjectRemoveRule
2022-12-28 19:03:07,327 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] DEBUG
o.apache.calcite.plan.RelOptPlanner - call#169: Full plan for rule input
[rel#110:LogicalProject]:
LogicalProject(c1=[$0], c2=[$1])
JdbcTableScan(subset=[rel#109:RelSubset#0.JDBC.mysql.ANY([]).[]],
table=[[mysql, test, t1]])
2022-12-28 19:03:07,327 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] DEBUG
o.apache.calcite.plan.RelOptPlanner - call#169: Rule [ProjectRemoveRule]
produced [rel#116:RelSubset]
2022-12-28 19:03:07,327 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] DEBUG
o.apache.calcite.plan.RelOptPlanner - call#169: Full plan for
[rel#116:RelSubset]:
JdbcTableScan(subset=[rel#116:RelSubset#0.NONE.ANY([]).[]], table=[[mysql,
test, t1]])
2022-12-28 19:03:07,327 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.apache.calcite.plan.RelOptPlanner - Merge set#1 into set#0
2022-12-28 19:03:07,327 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.apache.calcite.plan.RelOptPlanner - Rename #112 from
'LogicalTableModify.NONE.ANY([]).[](input=RelSubset#111,table=[pg, public,
t1],operation=INSERT,flattened=true)' to
'LogicalTableModify.NONE.ANY([]).[](input=RelSubset#116,table=[pg, public,
t1],operation=INSERT,flattened=true)'
2022-12-28 19:03:07,327 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] DEBUG
o.apache.calcite.plan.RelOptPlanner - call#169 generated 1 successors:
[rel#116:RelSubset#0.NONE.ANY([]).[]]
2022-12-28 19:03:07,327 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] DEBUG
o.apache.calcite.plan.RelOptPlanner - Best cost before rule match: {inf}
2022-12-28 19:03:07,327 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.apache.calcite.plan.RelOptPlanner - Root:
rel#114:RelSubset#2.LOGICAL.ANY([]).[]
Original rel:
LogicalTableModify(subset=[rel#114:RelSubset#2.LOGICAL.ANY([]).[]],
table=[[pg, public, t1]], operation=[INSERT], flattened=[true]): rowcount =
1.0E9, cumulative cost = {1.0E9 rows, 0.0 cpu, 0.0 io, 0.0 network, 0.0
memory}, id = 112
JdbcTableScan(subset=[rel#116:RelSubset#0.NONE.ANY([]).[]], table=[[mysql,
test, t1]]): rowcount = 1.0E9, cumulative cost = {100.0 rows, 101.0 cpu, 0.0
io, 0.0 network, 0.0 memory}, id = 89
Sets:
Set#0, type: RecordType(INTEGER c1, INTEGER c2)
rel#109:RelSubset#0.JDBC.mysql.ANY([]).[], best=rel#89
rel#89:JdbcTableScan.JDBC.mysql.ANY([]).[](table=[mysql, test,
t1]), rowcount=1.0E9, cumulative cost={100.0 rows, 101.0 cpu, 0.0 io, 0.0
network, 0.0 memory}
rel#116:RelSubset#0.NONE.ANY([]).[], best=null
Set#2, type: RecordType(BIGINT ROWCOUNT)
rel#113:RelSubset#2.NONE.ANY([]).[], best=null
rel#112:LogicalTableModify.NONE.ANY([]).[](input=RelSubset#116,table=[pg,
public, t1],operation=INSERT,flattened=true), rowcount=1.0E9, cumulative
cost={inf}
rel#114:RelSubset#2.LOGICAL.ANY([]).[], best=null
rel#115:AbstractConverter.LOGICAL.ANY([]).[](input=RelSubset#113,convention=LOGICAL,DrillDistributionTraitDef=ANY([]),sort=[]),
rowcount=1.0E9, cumulative cost={inf}
Graphviz:
digraph G {
root [style=filled,label="Root"];
subgraph cluster0{
label="Set 0 RecordType(INTEGER c1, INTEGER c2)";
rel89 [label="rel#89:JdbcTableScan\ntable=[mysql, test,
t1]\nrows=1.0E9, cost={100.0 rows, 101.0 cpu, 0.0 io, 0.0 network, 0.0
memory}",color=blue,shape=box]
subset109 [label="rel#109:RelSubset#0.JDBC.mysql.ANY([]).[]"]
subset116
[label="rel#116:RelSubset#0.NONE.ANY([]).[]",color=red]
}
subgraph cluster2{
label="Set 2 RecordType(BIGINT ROWCOUNT)";
rel112
[label="rel#112:LogicalTableModify\ninput=RelSubset#116,table=[pg, public,
t1],operation=INSERT,flattened=true\nrows=1.0E9, cost={inf}",shape=box]
rel115
[label="rel#115:AbstractConverter\ninput=RelSubset#113,convention=LOGICAL,DrillDistributionTraitDef=ANY([]),sort=[]\nrows=1.0E9,
cost={inf}",shape=box]
subset113 [label="rel#113:RelSubset#2.NONE.ANY([]).[]"]
subset114
[label="rel#114:RelSubset#2.LOGICAL.ANY([]).[]",color=red]
}
root -> subset114;
subset109 -> rel89[color=blue];
subset113 -> rel112; rel112 -> subset116;
subset114 -> rel115; rel115 -> subset113;
}
2022-12-28 19:03:07,327 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.apache.calcite.plan.RelOptPlanner - Rule queue:
rule [ReduceAndSimplifyProjectRule] rels [#110]
rule [ReduceExpressionsRule(Project)] rels [#110]
rule [VertexDrelConverterRuleJDBC.mysql(in:JDBC.mysql,out:LOGICAL)] rels
[#89]
rule [DrillProjectRule] rels [#110]
rule [DrillJdbcProjectRule(in:NONE,out:JDBC.mysql)] rels [#110]
rule [DrillJdbcProjectRule(in:NONE,out:JDBC.pg)] rels [#110]
rule [DrillTableModifyRule] rels [#112]
rule
[JdbcTableModificationRule(in:NONE,out:JDBC.mysql)(in:NONE,out:JDBC.mysql)]
rels [#112]
rule [JdbcTableModificationRule(in:NONE,out:JDBC.pg)(in:NONE,out:JDBC.pg)]
rels [#112]
rule [ExpandConversionRule] rels [#115]
2022-12-28 19:03:07,327 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] DEBUG
o.apache.calcite.plan.RelOptPlanner - Skip match: rule
[ReduceAndSimplifyProjectRule] rels [#110]
2022-12-28 19:03:07,327 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.apache.calcite.plan.RelOptPlanner - Rule queue:
rule [ReduceExpressionsRule(Project)] rels [#110]
rule [VertexDrelConverterRuleJDBC.mysql(in:JDBC.mysql,out:LOGICAL)] rels
[#89]
rule [DrillProjectRule] rels [#110]
rule [DrillJdbcProjectRule(in:NONE,out:JDBC.mysql)] rels [#110]
rule [DrillJdbcProjectRule(in:NONE,out:JDBC.pg)] rels [#110]
rule [DrillTableModifyRule] rels [#112]
rule
[JdbcTableModificationRule(in:NONE,out:JDBC.mysql)(in:NONE,out:JDBC.mysql)]
rels [#112]
rule [JdbcTableModificationRule(in:NONE,out:JDBC.pg)(in:NONE,out:JDBC.pg)]
rels [#112]
rule [ExpandConversionRule] rels [#115]
2022-12-28 19:03:07,327 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] DEBUG
o.apache.calcite.plan.RelOptPlanner - Skip match: rule
[ReduceExpressionsRule(Project)] rels [#110]
2022-12-28 19:03:07,327 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.apache.calcite.plan.RelOptPlanner - Rule queue:
rule [VertexDrelConverterRuleJDBC.mysql(in:JDBC.mysql,out:LOGICAL)] rels
[#89]
rule [DrillProjectRule] rels [#110]
rule [DrillJdbcProjectRule(in:NONE,out:JDBC.mysql)] rels [#110]
rule [DrillJdbcProjectRule(in:NONE,out:JDBC.pg)] rels [#110]
rule [DrillTableModifyRule] rels [#112]
rule
[JdbcTableModificationRule(in:NONE,out:JDBC.mysql)(in:NONE,out:JDBC.mysql)]
rels [#112]
rule [JdbcTableModificationRule(in:NONE,out:JDBC.pg)(in:NONE,out:JDBC.pg)]
rels [#112]
rule [ExpandConversionRule] rels [#115]
2022-12-28 19:03:07,327 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] DEBUG
o.apache.calcite.plan.RelOptPlanner - Pop match: rule
[VertexDrelConverterRuleJDBC.mysql(in:JDBC.mysql,out:LOGICAL)] rels [#89]
2022-12-28 19:03:07,327 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] DEBUG
o.apache.calcite.plan.RelOptPlanner - call#165: Apply rule
[VertexDrelConverterRuleJDBC.mysql(in:JDBC.mysql,out:LOGICAL)] to
[rel#89:JdbcTableScan]
2022-12-28 19:03:07,328 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] DEBUG
o.apache.calcite.plan.RelOptPlanner - Transform to: rel#117 via
VertexDrelConverterRuleJDBC.mysql(in:JDBC.mysql,out:LOGICAL)
2022-12-28 19:03:07,328 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] DEBUG
o.apache.calcite.plan.RelOptPlanner - call#165: Full plan for rule input
[rel#89:JdbcTableScan]:
JdbcTableScan(table=[[mysql, test, t1]])
2022-12-28 19:03:07,328 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] DEBUG
o.apache.calcite.plan.RelOptPlanner - call#165: Rule
[VertexDrelConverterRuleJDBC.mysql(in:JDBC.mysql,out:LOGICAL)] produced
[rel#117:VertexDrel]
2022-12-28 19:03:07,328 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] DEBUG
o.apache.calcite.plan.RelOptPlanner - call#165: Full plan for
[rel#117:VertexDrel]:
VertexDrel
JdbcTableScan(table=[[mysql, test, t1]])
2022-12-28 19:03:07,328 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.apache.calcite.plan.RelOptPlanner - Subset cost changed: subset
[rel#119:RelSubset#0.LOGICAL.ANY([]).[]] cost was {inf} now {1.000001E8 rows,
2.00000101E8 cpu, 0.0 io, 0.0 network, 0.0 memory}
2022-12-28 19:03:07,328 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.apache.calcite.plan.RelOptPlanner - Register
rel#118:VertexDrel.LOGICAL.ANY([]).[](input=RelSubset#109) in
rel#119:RelSubset#0.LOGICAL.ANY([]).[]
2022-12-28 19:03:07,328 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.apache.calcite.plan.RelOptPlanner - Rule-match queued: rule
[JDBC_PREL_ConverterJDBC.mysql] rels [#118,#89]
2022-12-28 19:03:07,328 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] DEBUG
o.apache.calcite.plan.RelOptPlanner - call#165 generated 1 successors:
[rel#117:VertexDrel.LOGICAL.ANY([]).[](input=JdbcTableScan#89)]
2022-12-28 19:03:07,328 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] DEBUG
o.apache.calcite.plan.RelOptPlanner - Best cost before rule match: {inf}
2022-12-28 19:03:07,329 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.apache.calcite.plan.RelOptPlanner - Root:
rel#114:RelSubset#2.LOGICAL.ANY([]).[]
Original rel:
LogicalTableModify(subset=[rel#114:RelSubset#2.LOGICAL.ANY([]).[]],
table=[[pg, public, t1]], operation=[INSERT], flattened=[true]): rowcount =
1.0E9, cumulative cost = {1.0E9 rows, 0.0 cpu, 0.0 io, 0.0 network, 0.0
memory}, id = 112
JdbcTableScan(subset=[rel#116:RelSubset#0.NONE.ANY([]).[]], table=[[mysql,
test, t1]]): rowcount = 1.0E9, cumulative cost = {100.0 rows, 101.0 cpu, 0.0
io, 0.0 network, 0.0 memory}, id = 89
Sets:
Set#0, type: RecordType(INTEGER c1, INTEGER c2)
rel#109:RelSubset#0.JDBC.mysql.ANY([]).[], best=rel#89
rel#89:JdbcTableScan.JDBC.mysql.ANY([]).[](table=[mysql, test,
t1]), rowcount=1.0E9, cumulative cost={100.0 rows, 101.0 cpu, 0.0 io, 0.0
network, 0.0 memory}
rel#116:RelSubset#0.NONE.ANY([]).[], best=null
rel#119:RelSubset#0.LOGICAL.ANY([]).[], best=rel#118
rel#118:VertexDrel.LOGICAL.ANY([]).[](input=RelSubset#109),
rowcount=1.0E9, cumulative cost={1.000001E8 rows, 2.00000101E8 cpu, 0.0 io, 0.0
network, 0.0 memory}
Set#2, type: RecordType(BIGINT ROWCOUNT)
rel#113:RelSubset#2.NONE.ANY([]).[], best=null
rel#112:LogicalTableModify.NONE.ANY([]).[](input=RelSubset#116,table=[pg,
public, t1],operation=INSERT,flattened=true), rowcount=1.0E9, cumulative
cost={inf}
rel#114:RelSubset#2.LOGICAL.ANY([]).[], best=null
rel#115:AbstractConverter.LOGICAL.ANY([]).[](input=RelSubset#113,convention=LOGICAL,DrillDistributionTraitDef=ANY([]),sort=[]),
rowcount=1.0E9, cumulative cost={inf}
Graphviz:
digraph G {
root [style=filled,label="Root"];
subgraph cluster0{
label="Set 0 RecordType(INTEGER c1, INTEGER c2)";
rel89 [label="rel#89:JdbcTableScan\ntable=[mysql, test,
t1]\nrows=1.0E9, cost={100.0 rows, 101.0 cpu, 0.0 io, 0.0 network, 0.0
memory}",color=blue,shape=box]
rel118
[label="rel#118:VertexDrel\ninput=RelSubset#109\nrows=1.0E9, cost={1.000001E8
rows, 2.00000101E8 cpu, 0.0 io, 0.0 network, 0.0 memory}",color=blue,shape=box]
subset109 [label="rel#109:RelSubset#0.JDBC.mysql.ANY([]).[]"]
subset116
[label="rel#116:RelSubset#0.NONE.ANY([]).[]",color=red]
subset119 [label="rel#119:RelSubset#0.LOGICAL.ANY([]).[]"]
}
subgraph cluster2{
label="Set 2 RecordType(BIGINT ROWCOUNT)";
rel112
[label="rel#112:LogicalTableModify\ninput=RelSubset#116,table=[pg, public,
t1],operation=INSERT,flattened=true\nrows=1.0E9, cost={inf}",shape=box]
rel115
[label="rel#115:AbstractConverter\ninput=RelSubset#113,convention=LOGICAL,DrillDistributionTraitDef=ANY([]),sort=[]\nrows=1.0E9,
cost={inf}",shape=box]
subset113 [label="rel#113:RelSubset#2.NONE.ANY([]).[]"]
subset114
[label="rel#114:RelSubset#2.LOGICAL.ANY([]).[]",color=red]
}
root -> subset114;
subset109 -> rel89[color=blue];
subset119 -> rel118[color=blue]; rel118 -> subset109[color=blue];
subset113 -> rel112; rel112 -> subset116;
subset114 -> rel115; rel115 -> subset113;
}
2022-12-28 19:03:07,329 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.apache.calcite.plan.RelOptPlanner - Rule queue:
rule [DrillProjectRule] rels [#110]
rule [DrillJdbcProjectRule(in:NONE,out:JDBC.mysql)] rels [#110]
rule [DrillJdbcProjectRule(in:NONE,out:JDBC.pg)] rels [#110]
rule [DrillTableModifyRule] rels [#112]
rule
[JdbcTableModificationRule(in:NONE,out:JDBC.mysql)(in:NONE,out:JDBC.mysql)]
rels [#112]
rule [JdbcTableModificationRule(in:NONE,out:JDBC.pg)(in:NONE,out:JDBC.pg)]
rels [#112]
rule [ExpandConversionRule] rels [#115]
rule [JDBC_PREL_ConverterJDBC.mysql] rels [#118,#89]
2022-12-28 19:03:07,329 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] DEBUG
o.apache.calcite.plan.RelOptPlanner - Skip match: rule [DrillProjectRule] rels
[#110]
2022-12-28 19:03:07,329 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.apache.calcite.plan.RelOptPlanner - Rule queue:
rule [DrillJdbcProjectRule(in:NONE,out:JDBC.mysql)] rels [#110]
rule [DrillJdbcProjectRule(in:NONE,out:JDBC.pg)] rels [#110]
rule [DrillTableModifyRule] rels [#112]
rule
[JdbcTableModificationRule(in:NONE,out:JDBC.mysql)(in:NONE,out:JDBC.mysql)]
rels [#112]
rule [JdbcTableModificationRule(in:NONE,out:JDBC.pg)(in:NONE,out:JDBC.pg)]
rels [#112]
rule [ExpandConversionRule] rels [#115]
rule [JDBC_PREL_ConverterJDBC.mysql] rels [#118,#89]
2022-12-28 19:03:07,329 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] DEBUG
o.apache.calcite.plan.RelOptPlanner - Skip match: rule
[DrillJdbcProjectRule(in:NONE,out:JDBC.mysql)] rels [#110]
2022-12-28 19:03:07,329 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.apache.calcite.plan.RelOptPlanner - Rule queue:
rule [DrillJdbcProjectRule(in:NONE,out:JDBC.pg)] rels [#110]
rule [DrillTableModifyRule] rels [#112]
rule
[JdbcTableModificationRule(in:NONE,out:JDBC.mysql)(in:NONE,out:JDBC.mysql)]
rels [#112]
rule [JdbcTableModificationRule(in:NONE,out:JDBC.pg)(in:NONE,out:JDBC.pg)]
rels [#112]
rule [ExpandConversionRule] rels [#115]
rule [JDBC_PREL_ConverterJDBC.mysql] rels [#118,#89]
2022-12-28 19:03:07,329 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] DEBUG
o.apache.calcite.plan.RelOptPlanner - Skip match: rule
[DrillJdbcProjectRule(in:NONE,out:JDBC.pg)] rels [#110]
2022-12-28 19:03:07,329 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.apache.calcite.plan.RelOptPlanner - Rule queue:
rule [DrillTableModifyRule] rels [#112]
rule
[JdbcTableModificationRule(in:NONE,out:JDBC.mysql)(in:NONE,out:JDBC.mysql)]
rels [#112]
rule [JdbcTableModificationRule(in:NONE,out:JDBC.pg)(in:NONE,out:JDBC.pg)]
rels [#112]
rule [ExpandConversionRule] rels [#115]
rule [JDBC_PREL_ConverterJDBC.mysql] rels [#118,#89]
2022-12-28 19:03:07,329 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] DEBUG
o.apache.calcite.plan.RelOptPlanner - Pop match: rule [DrillTableModifyRule]
rels [#112]
2022-12-28 19:03:07,329 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] DEBUG
o.apache.calcite.plan.RelOptPlanner - call#198: Apply rule
[DrillTableModifyRule] to [rel#112:LogicalTableModify]
2022-12-28 19:03:07,329 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] DEBUG
o.apache.calcite.plan.RelOptPlanner - Transform to: rel#120 via
DrillTableModifyRule
2022-12-28 19:03:07,329 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] DEBUG
o.apache.calcite.plan.RelOptPlanner - call#198: Full plan for rule input
[rel#112:LogicalTableModify]:
LogicalTableModify(table=[[pg, public, t1]], operation=[INSERT],
flattened=[true])
JdbcTableScan(subset=[rel#116:RelSubset#0.NONE.ANY([]).[]], table=[[mysql,
test, t1]])
2022-12-28 19:03:07,329 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] DEBUG
o.apache.calcite.plan.RelOptPlanner - call#198: Rule [DrillTableModifyRule]
produced [rel#120:DrillTableModify]
2022-12-28 19:03:07,329 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] DEBUG
o.apache.calcite.plan.RelOptPlanner - call#198: Full plan for
[rel#120:DrillTableModify]:
DrillTableModify(table=[[pg, public, t1]], operation=[INSERT],
flattened=[true])
VertexDrel(subset=[rel#119:RelSubset#0.LOGICAL.ANY([]).[]])
JdbcTableScan(subset=[rel#109:RelSubset#0.JDBC.mysql.ANY([]).[]],
table=[[mysql, test, t1]])
2022-12-28 19:03:07,330 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.apache.calcite.plan.RelOptPlanner - Subset cost changed: subset
[rel#114:RelSubset#2.LOGICAL.ANY([]).[]] cost was {inf} now {1.01000001E10
rows, 2.00000101E8 cpu, 1.000000001E10 io, 0.0 network, 0.0 memory}
2022-12-28 19:03:07,330 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.apache.calcite.plan.RelOptPlanner - Register
rel#120:DrillTableModify.LOGICAL.ANY([]).[](input=RelSubset#119,table=[pg,
public, t1],operation=INSERT,flattened=true) in
rel#114:RelSubset#2.LOGICAL.ANY([]).[]
2022-12-28 19:03:07,330 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.apache.calcite.plan.RelOptPlanner - Rule-match queued: rule
[JdbcTableModificationRule(in:NONE,out:JDBC.mysql)(in:LOGICAL,out:JDBC.mysql)]
rels [#120]
2022-12-28 19:03:07,330 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.apache.calcite.plan.RelOptPlanner - Rule-match queued: rule
[JdbcTableModificationRule(in:NONE,out:JDBC.pg)(in:LOGICAL,out:JDBC.pg)] rels
[#120]
2022-12-28 19:03:07,330 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] DEBUG
o.apache.calcite.plan.RelOptPlanner - call#198 generated 1 successors:
[rel#120:DrillTableModify.LOGICAL.ANY([]).[](input=RelSubset#119,table=[pg,
public, t1],operation=INSERT,flattened=true)]
2022-12-28 19:03:07,330 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] DEBUG
o.apache.calcite.plan.RelOptPlanner - Best cost before rule match:
{1.01000001E10 rows, 2.00000101E8 cpu, 1.000000001E10 io, 0.0 network, 0.0
memory}
2022-12-28 19:03:07,330 [1c53dd94-4277-9ab0-effe-18b1ab8989ac:foreman] TRACE
o.apache.calcite.plan.RelOptPlanner - Root:
rel#114:RelSubset#2.LOGICAL.ANY([]).[]
Original rel:
DrillTableModify(subset=[rel#114:RelSubset#2.LOGICAL.ANY([]).[]],
table=[[pg, public, t1]], operation=[INSERT], flattened=[true]): rowcount =
1.0E9, cumulative cost = {1.0E10 rows, 0.0 cpu, 1.000000001E10 io, 0.0 network,
0.0 memory}, id = 120
VertexDrel(subset=[rel#119:RelSubset#0.LOGICAL.ANY([]).[]]): rowcount =
1.0E9, cumulative cost = {1.0E8 rows, 2.0E8 cpu, 0.0 io, 0.0 network, 0.0
memory}, id = 118
JdbcTableScan(subset=[rel#109:RelSubset#0.JDBC.mysql.ANY([]).[]],
table=[[mysql, test, t1]]): rowcount = 1.0E9, cumulative cost = {100.0 rows,
101.0 cpu, 0.0 io, 0.0 network, 0.0 memory}, id = 89
Sets:
Set#0, type: RecordType(INTEGER c1, INTEGER c2)
rel#109:RelSubset#0.JDBC.mysql.ANY([]).[], best=rel#89
rel#89:JdbcTableScan.JDBC.mysql.ANY([]).[](table=[mysql, test,
t1]), rowcount=1.0E9, cumulative cost={100.0 rows, 101.0 cpu, 0.0 io, 0.0
network, 0.0 memory}
rel#116:RelSubset#0.NONE.ANY([]).[], best=null
rel#119:RelSubset#0.LOGICAL.ANY([]).[], best=rel#118
rel#118:VertexDrel.LOGICAL.ANY([]).[](input=RelSubset#109),
rowcount=1.0E9, cumulative cost={1.000001E8 rows, 2.00000101E8 cpu, 0.0 io, 0.0
network, 0.0 memory}
Set#2, type: RecordType(BIGINT ROWCOUNT)
rel#113:RelSubset#2.NONE.ANY([]).[], best=null
rel#112:LogicalTableModify.NONE.ANY([]).[](input=RelSubset#116,table=[pg,
public, t1],operation=INSERT,flattened=true), rowcount=1.0E9, cumulative
cost={inf}
rel#114:RelSubset#2.LOGICAL.ANY([]).[], best=rel#120
rel#115:AbstractConverter.LOGICAL.ANY([]).[](input=RelSubset#113,convention=LOGICAL,DrillDistributionTraitDef=ANY([]),sort=[]),
rowcount=1.0E9, cumulative cost={inf}
rel#120:DrillTableModify.LOGICAL.ANY([]).[](input=RelSubset#119,table=[pg,
public, t1],operation=INSERT,flattened=true), rowcount=1.0E9, cumulative
cost={1.01000001E10 rows, 2.00000101E8 cpu, 1.000000001E10 io, 0.0 network, 0.0
memory}
Graphviz:
digraph G {
root [style=filled,label="Root"];
subgraph cluster0{
label="Set 0 RecordType(INTEGER c1, INTEGER c2)";
rel89 [label="rel#89:JdbcTableScan\ntable=[mysql, test,
t1]\nrows=1.0E9, cost={100.0 rows, 101.0 cpu, 0.0 io, 0.0 network, 0.0
memory}",color=blue,shape=box]
rel118
[label="rel#118:VertexDrel\ninput=RelSubset#109\nrows=1.0E9, cost={1.000001E8
rows, 2.00000101E8 cpu, 0.0 io, 0.0 network, 0.0 memory}",color=blue,shape=box]
subset109 [label="rel#109:RelSubset#0.JDBC.mysql.ANY([]).[]"]
subset116
[label="rel#116:RelSubset#0.NONE.ANY([]).[]",color=red]
subset119 [label="rel#119:RelSubset#0.LOGICAL.ANY([]).[]"]
}
subgraph cluster2{
label="Set 2 RecordType(BIGINT ROWCOUNT)";
rel112
[label="rel#112:LogicalTableModify\ninput=RelSubset#116,table=[pg, public,
t1],operation=INSERT,flattened=true\nrows=1.0E9, cost={inf}",shape=box]
rel115
[label="rel#115:AbstractConverter\ninput=RelSubset#113,convention=LOGICAL,DrillDistributionTraitDef=ANY([]),sort=[]\nrows=1.0E9,
cost={inf}",shape=box]
rel120
[label="rel#120:DrillTableModify\ninput=RelSubset#119,table=[pg, public,
t1],operation=INSERT,flattened=true\nrows=1.0E9, cost={1.01000001E10 rows,
2.00000101E8 cpu, 1.000000001E10 io, 0.0 network, 0.0
memory}",color=blue,shape=box]
subset113 [label="rel#113:RelSubset#2.NONE.ANY([]).[]"]
subset114 [label="rel#114:RelSubset#2.LOGICAL.ANY([]).[]"]
}
root -> subset114;
subset109 -> rel89[color=blue];
subset119 -> rel118[color=blue]; rel118 -> subset109[color=blue];
subset113 -> rel112; rel112 -> subset116;
subset114 -> rel115; rel115 -> subset113;
subset114 -> rel120[color=blue]; rel120 -> subset119[color=blue];
}
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
