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: dev-unsubscr...@drill.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org