You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@xtable.apache.org by "alberttwong (via GitHub)" <gi...@apache.org> on 2024/07/15 19:51:16 UTC

Re: [I] no rows in Trino when pyspark xtable source from delta and write into Hudi and Iceberg with S3 + HMS [incubator-xtable]

alberttwong commented on issue #460:
URL: https://github.com/apache/incubator-xtable/issues/460#issuecomment-2229265244

   Downgrade doesn't work.
   
   ```
   2024-07-15 12:46:25 2024-07-15T19:46:25.953Z    DEBUG   Query-20240715_194625_00000_23mm5-188   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 38.21ms
   2024-07-15 12:46:26 2024-07-15T19:46:26.327Z    DEBUG   Query-20240715_194625_00000_23mm5-188   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 10.50ms
   2024-07-15 12:46:26 2024-07-15T19:46:26.341Z    DEBUG   Query-20240715_194625_00000_23mm5-188   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 9.13ms
   2024-07-15 12:46:26 2024-07-15T19:46:26.343Z    DEBUG   Query-20240715_194625_00000_23mm5-188   io.trino.security.AccessControl Invocation of getColumnMask(context=SecurityContext{identity=Identity{user='trino', principal=trino}, queryId=20240715_194625_00000_23mm5}, tableName=hudi.hudi_db.people, columnName='_hoodie_commit_time', type=varchar) succeeded in 389.13us
   2024-07-15 12:46:26 2024-07-15T19:46:26.343Z    DEBUG   Query-20240715_194625_00000_23mm5-188   io.trino.security.AccessControl Invocation of getColumnMask(context=SecurityContext{identity=Identity{user='trino', principal=trino}, queryId=20240715_194625_00000_23mm5}, tableName=hudi.hudi_db.people, columnName='_hoodie_commit_seqno', type=varchar) succeeded in 15.96us
   2024-07-15 12:46:26 2024-07-15T19:46:26.343Z    DEBUG   Query-20240715_194625_00000_23mm5-188   io.trino.security.AccessControl Invocation of getColumnMask(context=SecurityContext{identity=Identity{user='trino', principal=trino}, queryId=20240715_194625_00000_23mm5}, tableName=hudi.hudi_db.people, columnName='_hoodie_record_key', type=varchar) succeeded in 14.75us
   2024-07-15 12:46:26 2024-07-15T19:46:26.343Z    DEBUG   Query-20240715_194625_00000_23mm5-188   io.trino.security.AccessControl Invocation of getColumnMask(context=SecurityContext{identity=Identity{user='trino', principal=trino}, queryId=20240715_194625_00000_23mm5}, tableName=hudi.hudi_db.people, columnName='_hoodie_partition_path', type=varchar) succeeded in 9.96us
   2024-07-15 12:46:26 2024-07-15T19:46:26.343Z    DEBUG   Query-20240715_194625_00000_23mm5-188   io.trino.security.AccessControl Invocation of getColumnMask(context=SecurityContext{identity=Identity{user='trino', principal=trino}, queryId=20240715_194625_00000_23mm5}, tableName=hudi.hudi_db.people, columnName='_hoodie_file_name', type=varchar) succeeded in 10.83us
   2024-07-15 12:46:26 2024-07-15T19:46:26.343Z    DEBUG   Query-20240715_194625_00000_23mm5-188   io.trino.security.AccessControl Invocation of getColumnMask(context=SecurityContext{identity=Identity{user='trino', principal=trino}, queryId=20240715_194625_00000_23mm5}, tableName=hudi.hudi_db.people, columnName='id', type=integer) succeeded in 11.58us
   2024-07-15 12:46:26 2024-07-15T19:46:26.343Z    DEBUG   Query-20240715_194625_00000_23mm5-188   io.trino.security.AccessControl Invocation of getColumnMask(context=SecurityContext{identity=Identity{user='trino', principal=trino}, queryId=20240715_194625_00000_23mm5}, tableName=hudi.hudi_db.people, columnName='name', type=varchar) succeeded in 20.00us
   2024-07-15 12:46:26 2024-07-15T19:46:26.344Z    DEBUG   Query-20240715_194625_00000_23mm5-188   io.trino.security.AccessControl Invocation of getColumnMask(context=SecurityContext{identity=Identity{user='trino', principal=trino}, queryId=20240715_194625_00000_23mm5}, tableName=hudi.hudi_db.people, columnName='age', type=integer) succeeded in 13.67us
   2024-07-15 12:46:26 2024-07-15T19:46:26.344Z    DEBUG   Query-20240715_194625_00000_23mm5-188   io.trino.security.AccessControl Invocation of getColumnMask(context=SecurityContext{identity=Identity{user='trino', principal=trino}, queryId=20240715_194625_00000_23mm5}, tableName=hudi.hudi_db.people, columnName='create_ts', type=varchar) succeeded in 34.17us
   2024-07-15 12:46:26 2024-07-15T19:46:26.344Z    DEBUG   Query-20240715_194625_00000_23mm5-188   io.trino.security.AccessControl Invocation of getColumnMask(context=SecurityContext{identity=Identity{user='trino', principal=trino}, queryId=20240715_194625_00000_23mm5}, tableName=hudi.hudi_db.people, columnName='city', type=varchar) succeeded in 12.17us
   2024-07-15 12:46:26 2024-07-15T19:46:26.344Z    DEBUG   Query-20240715_194625_00000_23mm5-188   io.trino.security.AccessControl Invocation of getColumnMask(context=SecurityContext{identity=Identity{user='trino', principal=trino}, queryId=20240715_194625_00000_23mm5}, tableName=hudi.hudi_db.people, columnName='$path', type=varchar) succeeded in 9.58us
   2024-07-15 12:46:26 2024-07-15T19:46:26.344Z    DEBUG   Query-20240715_194625_00000_23mm5-188   io.trino.security.AccessControl Invocation of getColumnMask(context=SecurityContext{identity=Identity{user='trino', principal=trino}, queryId=20240715_194625_00000_23mm5}, tableName=hudi.hudi_db.people, columnName='$file_size', type=bigint) succeeded in 10.63us
   2024-07-15 12:46:26 2024-07-15T19:46:26.344Z    DEBUG   Query-20240715_194625_00000_23mm5-188   io.trino.security.AccessControl Invocation of getColumnMask(context=SecurityContext{identity=Identity{user='trino', principal=trino}, queryId=20240715_194625_00000_23mm5}, tableName=hudi.hudi_db.people, columnName='$file_modified_time', type=timestamp(3) with time zone) succeeded in 19.75us
   2024-07-15 12:46:26 2024-07-15T19:46:26.344Z    DEBUG   Query-20240715_194625_00000_23mm5-188   io.trino.security.AccessControl Invocation of getColumnMask(context=SecurityContext{identity=Identity{user='trino', principal=trino}, queryId=20240715_194625_00000_23mm5}, tableName=hudi.hudi_db.people, columnName='$partition', type=varchar) succeeded in 16.50us
   2024-07-15 12:46:26 2024-07-15T19:46:26.344Z    DEBUG   Query-20240715_194625_00000_23mm5-188   io.trino.security.AccessControl Invocation of getRowFilters(context=SecurityContext{identity=Identity{user='trino', principal=trino}, queryId=20240715_194625_00000_23mm5}, tableName=hudi.hudi_db.people) succeeded in 199.46us
   2024-07-15 12:46:26 2024-07-15T19:46:26.356Z    DEBUG   Query-20240715_194625_00000_23mm5-188   io.trino.security.AccessControl Invocation of checkCanSelectFromColumns(context=SecurityContext{identity=Identity{user='trino', principal=trino}, queryId=20240715_194625_00000_23mm5}, tableName=hudi.hudi_db.people, columnNames=[_hoodie_commit_time, _hoodie_partition_path, city, _hoodie_record_key, name, create_ts, _hoodie_commit_seqno, id, _hoodie_file_name, age]) succeeded in 189.13us
   2024-07-15 12:46:26 2024-07-15T19:46:26.358Z    DEBUG   dispatcher-query-4      io.trino.execution.QueryStateMachine    Query 20240715_194625_00000_23mm5 is DISPATCHING
   2024-07-15 12:46:26 2024-07-15T19:46:26.359Z    DEBUG   dispatcher-query-4      io.trino.execution.QueryStateMachine    Query 20240715_194625_00000_23mm5 is PLANNING
   2024-07-15 12:46:26 2024-07-15T19:46:26.400Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 9.64ms
   2024-07-15 12:46:26 2024-07-15T19:46:26.411Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 9.05ms
   2024-07-15 12:46:26 2024-07-15T19:46:26.415Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.LogicalPlanner     Initial plan:
   2024-07-15 12:46:26 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ Project[]
   2024-07-15 12:46:26    │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar, $path:varchar, $file_size:bigint, $file_modified_time:timestamp(3) with time zone, $partition:varchar]
   2024-07-15 12:46:26    └─ Project[]
   2024-07-15 12:46:26       │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar, $path:varchar, $file_size:bigint, $file_modified_time:timestamp(3) with time zone, $partition:varchar]
   2024-07-15 12:46:26       └─ Project[]
   2024-07-15 12:46:26          │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar, $path:varchar, $file_size:bigint, $file_modified_time:timestamp(3) with time zone, $partition:varchar]
   2024-07-15 12:46:26          └─ ScanProject[table = hudi:hudi_db.people]
   2024-07-15 12:46:26                 Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar, $path:varchar, $file_size:bigint, $file_modified_time:timestamp(3) with time zone, $partition:varchar]
   2024-07-15 12:46:26                 _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:26                 _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:26                 _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:26                 _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:26                 _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:26                 id := id:int:REGULAR
   2024-07-15 12:46:26                 name := name:string:REGULAR
   2024-07-15 12:46:26                 age := age:int:REGULAR
   2024-07-15 12:46:26                 create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:26                 city := city:string:PARTITION_KEY
   2024-07-15 12:46:26                 $path := $path:string:SYNTHESIZED
   2024-07-15 12:46:26                 $file_size := $file_size:bigint:SYNTHESIZED
   2024-07-15 12:46:26                 $file_modified_time := $file_modified_time:timestamp:SYNTHESIZED
   2024-07-15 12:46:26                 $partition := $partition:string:SYNTHESIZED
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 2024-07-15T19:46:26.432Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 8.42ms
   2024-07-15 12:46:26 2024-07-15T19:46:26.441Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 7.74ms
   2024-07-15 12:46:26 2024-07-15T19:46:26.442Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.LogicalPlanner     io.trino.sql.planner.iterative.IterativeOptimizer:
   2024-07-15 12:46:26 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ Project[]
   2024-07-15 12:46:26    │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar, $path:varchar, $file_size:bigint, $file_modified_time:timestamp(3) with time zone, $partition:varchar]
   2024-07-15 12:46:26    └─ Project[]
   2024-07-15 12:46:26       │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar, $path:varchar, $file_size:bigint, $file_modified_time:timestamp(3) with time zone, $partition:varchar]
   2024-07-15 12:46:26       └─ Project[]
   2024-07-15 12:46:26          │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar, $path:varchar, $file_size:bigint, $file_modified_time:timestamp(3) with time zone, $partition:varchar]
   2024-07-15 12:46:26          └─ ScanProject[table = hudi:hudi_db.people]
   2024-07-15 12:46:26                 Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar, $path:varchar, $file_size:bigint, $file_modified_time:timestamp(3) with time zone, $partition:varchar]
   2024-07-15 12:46:26                 _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:26                 _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:26                 _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:26                 _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:26                 _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:26                 id := id:int:REGULAR
   2024-07-15 12:46:26                 name := name:string:REGULAR
   2024-07-15 12:46:26                 age := age:int:REGULAR
   2024-07-15 12:46:26                 create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:26                 city := city:string:PARTITION_KEY
   2024-07-15 12:46:26                 $path := $path:string:SYNTHESIZED
   2024-07-15 12:46:26                 $file_size := $file_size:bigint:SYNTHESIZED
   2024-07-15 12:46:26                 $file_modified_time := $file_modified_time:timestamp:SYNTHESIZED
   2024-07-15 12:46:26                 $partition := $partition:string:SYNTHESIZED
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 2024-07-15T19:46:26.452Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 7.94ms
   2024-07-15 12:46:26 2024-07-15T19:46:26.461Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 7.57ms
   2024-07-15 12:46:26 2024-07-15T19:46:26.462Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.LogicalPlanner     io.trino.sql.planner.iterative.IterativeOptimizer:
   2024-07-15 12:46:26 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ Project[]
   2024-07-15 12:46:26    │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar, $path:varchar, $file_size:bigint, $file_modified_time:timestamp(3) with time zone, $partition:varchar]
   2024-07-15 12:46:26    └─ Project[]
   2024-07-15 12:46:26       │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar, $path:varchar, $file_size:bigint, $file_modified_time:timestamp(3) with time zone, $partition:varchar]
   2024-07-15 12:46:26       └─ Project[]
   2024-07-15 12:46:26          │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar, $path:varchar, $file_size:bigint, $file_modified_time:timestamp(3) with time zone, $partition:varchar]
   2024-07-15 12:46:26          └─ ScanProject[table = hudi:hudi_db.people]
   2024-07-15 12:46:26                 Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar, $path:varchar, $file_size:bigint, $file_modified_time:timestamp(3) with time zone, $partition:varchar]
   2024-07-15 12:46:26                 _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:26                 _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:26                 _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:26                 _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:26                 _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:26                 id := id:int:REGULAR
   2024-07-15 12:46:26                 name := name:string:REGULAR
   2024-07-15 12:46:26                 age := age:int:REGULAR
   2024-07-15 12:46:26                 create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:26                 city := city:string:PARTITION_KEY
   2024-07-15 12:46:26                 $path := $path:string:SYNTHESIZED
   2024-07-15 12:46:26                 $file_size := $file_size:bigint:SYNTHESIZED
   2024-07-15 12:46:26                 $file_modified_time := $file_modified_time:timestamp:SYNTHESIZED
   2024-07-15 12:46:26                 $partition := $partition:string:SYNTHESIZED
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 2024-07-15T19:46:26.463Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.iterative.IterativeOptimizer       Rule: io.trino.sql.planner.iterative.rule.PruneOutputSourceColumns
   2024-07-15 12:46:26 Before:
   2024-07-15 12:46:26 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ GroupReference[groupId = 2]
   2024-07-15 12:46:26        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar, $path:varchar, $file_size:bigint, $file_modified_time:timestamp(3) with time zone, $partition:varchar]
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 After:
   2024-07-15 12:46:26 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ Project[]
   2024-07-15 12:46:26    │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26    └─ GroupReference[groupId = 2]
   2024-07-15 12:46:26           Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar, $path:varchar, $file_size:bigint, $file_modified_time:timestamp(3) with time zone, $partition:varchar]
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 2024-07-15T19:46:26.467Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.iterative.IterativeOptimizer       Rule: io.trino.sql.planner.iterative.rule.PruneProjectColumns
   2024-07-15 12:46:26 Before:
   2024-07-15 12:46:26 Project[]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ GroupReference[groupId = 2]
   2024-07-15 12:46:26        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar, $path:varchar, $file_size:bigint, $file_modified_time:timestamp(3) with time zone, $partition:varchar]
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 After:
   2024-07-15 12:46:26 Project[]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ Project[]
   2024-07-15 12:46:26    │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26    └─ GroupReference[groupId = 3]
   2024-07-15 12:46:26           Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar, $path:varchar, $file_size:bigint, $file_modified_time:timestamp(3) with time zone, $partition:varchar]
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 2024-07-15T19:46:26.471Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.iterative.IterativeOptimizer       Rule: io.trino.sql.planner.iterative.rule.InlineProjections
   2024-07-15 12:46:26 Before:
   2024-07-15 12:46:26 Project[]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ GroupReference[groupId = 8]
   2024-07-15 12:46:26        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 After:
   2024-07-15 12:46:26 Project[]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ GroupReference[groupId = 3]
   2024-07-15 12:46:26        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar, $path:varchar, $file_size:bigint, $file_modified_time:timestamp(3) with time zone, $partition:varchar]
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 2024-07-15T19:46:26.471Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.iterative.IterativeOptimizer       Rule: io.trino.sql.planner.iterative.rule.PruneProjectColumns
   2024-07-15 12:46:26 Before:
   2024-07-15 12:46:26 Project[]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ GroupReference[groupId = 3]
   2024-07-15 12:46:26        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar, $path:varchar, $file_size:bigint, $file_modified_time:timestamp(3) with time zone, $partition:varchar]
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 After:
   2024-07-15 12:46:26 Project[]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ Project[]
   2024-07-15 12:46:26    │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26    └─ GroupReference[groupId = 4]
   2024-07-15 12:46:26           Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar, $path:varchar, $file_size:bigint, $file_modified_time:timestamp(3) with time zone, $partition:varchar]
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 2024-07-15T19:46:26.472Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.iterative.IterativeOptimizer       Rule: io.trino.sql.planner.iterative.rule.InlineProjections
   2024-07-15 12:46:26 Before:
   2024-07-15 12:46:26 Project[]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ GroupReference[groupId = 9]
   2024-07-15 12:46:26        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 After:
   2024-07-15 12:46:26 Project[]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ GroupReference[groupId = 4]
   2024-07-15 12:46:26        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar, $path:varchar, $file_size:bigint, $file_modified_time:timestamp(3) with time zone, $partition:varchar]
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 2024-07-15T19:46:26.473Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.iterative.IterativeOptimizer       Rule: io.trino.sql.planner.iterative.rule.PruneProjectColumns
   2024-07-15 12:46:26 Before:
   2024-07-15 12:46:26 Project[]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ GroupReference[groupId = 4]
   2024-07-15 12:46:26        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar, $path:varchar, $file_size:bigint, $file_modified_time:timestamp(3) with time zone, $partition:varchar]
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 After:
   2024-07-15 12:46:26 Project[]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ Project[]
   2024-07-15 12:46:26    │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26    └─ GroupReference[groupId = 5]
   2024-07-15 12:46:26           Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar, $path:varchar, $file_size:bigint, $file_modified_time:timestamp(3) with time zone, $partition:varchar]
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 2024-07-15T19:46:26.474Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.iterative.IterativeOptimizer       Rule: io.trino.sql.planner.iterative.rule.InlineProjections
   2024-07-15 12:46:26 Before:
   2024-07-15 12:46:26 Project[]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ GroupReference[groupId = 10]
   2024-07-15 12:46:26        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 After:
   2024-07-15 12:46:26 Project[]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ GroupReference[groupId = 5]
   2024-07-15 12:46:26        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar, $path:varchar, $file_size:bigint, $file_modified_time:timestamp(3) with time zone, $partition:varchar]
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 2024-07-15T19:46:26.475Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.iterative.IterativeOptimizer       Rule: io.trino.sql.planner.iterative.rule.PruneProjectColumns
   2024-07-15 12:46:26 Before:
   2024-07-15 12:46:26 Project[]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ GroupReference[groupId = 5]
   2024-07-15 12:46:26        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar, $path:varchar, $file_size:bigint, $file_modified_time:timestamp(3) with time zone, $partition:varchar]
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 After:
   2024-07-15 12:46:26 Project[]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ Project[]
   2024-07-15 12:46:26    │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26    └─ GroupReference[groupId = 6]
   2024-07-15 12:46:26           Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar, $path:varchar, $file_size:bigint, $file_modified_time:timestamp(3) with time zone, $partition:varchar]
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 2024-07-15T19:46:26.476Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.iterative.IterativeOptimizer       Rule: io.trino.sql.planner.iterative.rule.InlineProjections
   2024-07-15 12:46:26 Before:
   2024-07-15 12:46:26 Project[]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ GroupReference[groupId = 11]
   2024-07-15 12:46:26        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 After:
   2024-07-15 12:46:26 Project[]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ GroupReference[groupId = 6]
   2024-07-15 12:46:26        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar, $path:varchar, $file_size:bigint, $file_modified_time:timestamp(3) with time zone, $partition:varchar]
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 2024-07-15T19:46:26.486Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 8.15ms
   2024-07-15 12:46:26 2024-07-15T19:46:26.495Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 7.63ms
   2024-07-15 12:46:26 2024-07-15T19:46:26.496Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.iterative.IterativeOptimizer       Rule: io.trino.sql.planner.iterative.rule.PruneTableScanColumns
   2024-07-15 12:46:26 Before:
   2024-07-15 12:46:26 Project[]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ GroupReference[groupId = 6]
   2024-07-15 12:46:26        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar, $path:varchar, $file_size:bigint, $file_modified_time:timestamp(3) with time zone, $partition:varchar]
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 After:
   2024-07-15 12:46:26 ScanProject[table = hudi:hudi_db.people]
   2024-07-15 12:46:26     Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26     _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:26     _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:26     _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:26     _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:26     _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:26     id := id:int:REGULAR
   2024-07-15 12:46:26     name := name:string:REGULAR
   2024-07-15 12:46:26     age := age:int:REGULAR
   2024-07-15 12:46:26     create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:26     city := city:string:PARTITION_KEY
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 2024-07-15T19:46:26.497Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.iterative.IterativeOptimizer       Rule: io.trino.sql.planner.iterative.rule.RemoveRedundantIdentityProjections
   2024-07-15 12:46:26 Before:
   2024-07-15 12:46:26 Project[]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ GroupReference[groupId = 12]
   2024-07-15 12:46:26        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 After:
   2024-07-15 12:46:26 GroupReference[groupId = 12]
   2024-07-15 12:46:26     Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 2024-07-15T19:46:26.505Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 7.68ms
   2024-07-15 12:46:26 2024-07-15T19:46:26.506Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.LogicalPlanner     io.trino.sql.planner.iterative.IterativeOptimizer:
   2024-07-15 12:46:26 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ TableScan[table = hudi:hudi_db.people]
   2024-07-15 12:46:26        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26        _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:26        _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:26        _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:26        _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:26        _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:26        id := id:int:REGULAR
   2024-07-15 12:46:26        name := name:string:REGULAR
   2024-07-15 12:46:26        age := age:int:REGULAR
   2024-07-15 12:46:26        create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:26        city := city:string:PARTITION_KEY
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 2024-07-15T19:46:26.514Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 7.44ms
   2024-07-15 12:46:26 2024-07-15T19:46:26.515Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.LogicalPlanner     io.trino.sql.planner.iterative.IterativeOptimizer:
   2024-07-15 12:46:26 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ TableScan[table = hudi:hudi_db.people]
   2024-07-15 12:46:26        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26        _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:26        _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:26        _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:26        _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:26        _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:26        id := id:int:REGULAR
   2024-07-15 12:46:26        name := name:string:REGULAR
   2024-07-15 12:46:26        age := age:int:REGULAR
   2024-07-15 12:46:26        create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:26        city := city:string:PARTITION_KEY
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 2024-07-15T19:46:26.523Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 7.83ms
   2024-07-15 12:46:26 2024-07-15T19:46:26.524Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.LogicalPlanner     io.trino.sql.planner.iterative.IterativeOptimizer:
   2024-07-15 12:46:26 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ TableScan[table = hudi:hudi_db.people]
   2024-07-15 12:46:26        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26        _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:26        _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:26        _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:26        _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:26        _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:26        id := id:int:REGULAR
   2024-07-15 12:46:26        name := name:string:REGULAR
   2024-07-15 12:46:26        age := age:int:REGULAR
   2024-07-15 12:46:26        create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:26        city := city:string:PARTITION_KEY
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 2024-07-15T19:46:26.535Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 7.44ms
   2024-07-15 12:46:26 2024-07-15T19:46:26.536Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.LogicalPlanner     io.trino.sql.planner.optimizations.UnaliasSymbolReferences:
   2024-07-15 12:46:26 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ TableScan[table = hudi:hudi_db.people]
   2024-07-15 12:46:26        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26        _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:26        _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:26        city := city:string:PARTITION_KEY
   2024-07-15 12:46:26        _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:26        name := name:string:REGULAR
   2024-07-15 12:46:26        create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:26        _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:26        id := id:int:REGULAR
   2024-07-15 12:46:26        _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:26        age := age:int:REGULAR
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 2024-07-15T19:46:26.544Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 7.13ms
   2024-07-15 12:46:26 2024-07-15T19:46:26.545Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.LogicalPlanner     io.trino.sql.planner.iterative.IterativeOptimizer:
   2024-07-15 12:46:26 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ TableScan[table = hudi:hudi_db.people]
   2024-07-15 12:46:26        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26        _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:26        _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:26        city := city:string:PARTITION_KEY
   2024-07-15 12:46:26        _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:26        name := name:string:REGULAR
   2024-07-15 12:46:26        create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:26        _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:26        id := id:int:REGULAR
   2024-07-15 12:46:26        _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:26        age := age:int:REGULAR
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 2024-07-15T19:46:26.553Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 7.25ms
   2024-07-15 12:46:26 2024-07-15T19:46:26.553Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.LogicalPlanner     io.trino.sql.planner.iterative.IterativeOptimizer:
   2024-07-15 12:46:26 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ TableScan[table = hudi:hudi_db.people]
   2024-07-15 12:46:26        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26        _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:26        _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:26        city := city:string:PARTITION_KEY
   2024-07-15 12:46:26        _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:26        name := name:string:REGULAR
   2024-07-15 12:46:26        create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:26        _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:26        id := id:int:REGULAR
   2024-07-15 12:46:26        _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:26        age := age:int:REGULAR
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 2024-07-15T19:46:26.561Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 6.74ms
   2024-07-15 12:46:26 2024-07-15T19:46:26.561Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.LogicalPlanner     io.trino.sql.planner.iterative.IterativeOptimizer:
   2024-07-15 12:46:26 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ TableScan[table = hudi:hudi_db.people]
   2024-07-15 12:46:26        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26        _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:26        _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:26        city := city:string:PARTITION_KEY
   2024-07-15 12:46:26        _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:26        name := name:string:REGULAR
   2024-07-15 12:46:26        create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:26        _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:26        id := id:int:REGULAR
   2024-07-15 12:46:26        _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:26        age := age:int:REGULAR
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 2024-07-15T19:46:26.570Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 7.79ms
   2024-07-15 12:46:26 2024-07-15T19:46:26.571Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.LogicalPlanner     io.trino.sql.planner.optimizations.LimitPushDown:
   2024-07-15 12:46:26 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ TableScan[table = hudi:hudi_db.people]
   2024-07-15 12:46:26        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26        _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:26        _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:26        city := city:string:PARTITION_KEY
   2024-07-15 12:46:26        _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:26        name := name:string:REGULAR
   2024-07-15 12:46:26        create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:26        _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:26        id := id:int:REGULAR
   2024-07-15 12:46:26        _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:26        age := age:int:REGULAR
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 2024-07-15T19:46:26.579Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 7.45ms
   2024-07-15 12:46:26 2024-07-15T19:46:26.580Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.LogicalPlanner     io.trino.sql.planner.iterative.IterativeOptimizer:
   2024-07-15 12:46:26 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ TableScan[table = hudi:hudi_db.people]
   2024-07-15 12:46:26        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26        _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:26        _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:26        city := city:string:PARTITION_KEY
   2024-07-15 12:46:26        _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:26        name := name:string:REGULAR
   2024-07-15 12:46:26        create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:26        _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:26        id := id:int:REGULAR
   2024-07-15 12:46:26        _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:26        age := age:int:REGULAR
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 2024-07-15T19:46:26.587Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 6.68ms
   2024-07-15 12:46:26 2024-07-15T19:46:26.588Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.LogicalPlanner     io.trino.sql.planner.iterative.IterativeOptimizer:
   2024-07-15 12:46:26 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ TableScan[table = hudi:hudi_db.people]
   2024-07-15 12:46:26        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26        _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:26        _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:26        city := city:string:PARTITION_KEY
   2024-07-15 12:46:26        _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:26        name := name:string:REGULAR
   2024-07-15 12:46:26        create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:26        _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:26        id := id:int:REGULAR
   2024-07-15 12:46:26        _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:26        age := age:int:REGULAR
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 2024-07-15T19:46:26.595Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 6.39ms
   2024-07-15 12:46:26 2024-07-15T19:46:26.596Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.LogicalPlanner     io.trino.sql.planner.iterative.IterativeOptimizer:
   2024-07-15 12:46:26 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ TableScan[table = hudi:hudi_db.people]
   2024-07-15 12:46:26        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26        _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:26        _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:26        city := city:string:PARTITION_KEY
   2024-07-15 12:46:26        _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:26        name := name:string:REGULAR
   2024-07-15 12:46:26        create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:26        _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:26        id := id:int:REGULAR
   2024-07-15 12:46:26        _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:26        age := age:int:REGULAR
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 2024-07-15T19:46:26.603Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 6.39ms
   2024-07-15 12:46:26 2024-07-15T19:46:26.603Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.LogicalPlanner     io.trino.sql.planner.iterative.IterativeOptimizer:
   2024-07-15 12:46:26 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ TableScan[table = hudi:hudi_db.people]
   2024-07-15 12:46:26        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26        _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:26        _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:26        city := city:string:PARTITION_KEY
   2024-07-15 12:46:26        _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:26        name := name:string:REGULAR
   2024-07-15 12:46:26        create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:26        _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:26        id := id:int:REGULAR
   2024-07-15 12:46:26        _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:26        age := age:int:REGULAR
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 2024-07-15T19:46:26.611Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 6.50ms
   2024-07-15 12:46:26 2024-07-15T19:46:26.611Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.LogicalPlanner     io.trino.sql.planner.optimizations.TransformQuantifiedComparisonApplyToCorrelatedJoin:
   2024-07-15 12:46:26 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ TableScan[table = hudi:hudi_db.people]
   2024-07-15 12:46:26        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26        _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:26        _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:26        city := city:string:PARTITION_KEY
   2024-07-15 12:46:26        _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:26        name := name:string:REGULAR
   2024-07-15 12:46:26        create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:26        _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:26        id := id:int:REGULAR
   2024-07-15 12:46:26        _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:26        age := age:int:REGULAR
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 2024-07-15T19:46:26.619Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 7.23ms
   2024-07-15 12:46:26 2024-07-15T19:46:26.620Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.LogicalPlanner     io.trino.sql.planner.iterative.IterativeOptimizer:
   2024-07-15 12:46:26 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ TableScan[table = hudi:hudi_db.people]
   2024-07-15 12:46:26        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26        _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:26        _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:26        city := city:string:PARTITION_KEY
   2024-07-15 12:46:26        _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:26        name := name:string:REGULAR
   2024-07-15 12:46:26        create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:26        _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:26        id := id:int:REGULAR
   2024-07-15 12:46:26        _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:26        age := age:int:REGULAR
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 2024-07-15T19:46:26.627Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 6.76ms
   2024-07-15 12:46:26 2024-07-15T19:46:26.628Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.LogicalPlanner     io.trino.sql.planner.iterative.IterativeOptimizer:
   2024-07-15 12:46:26 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ TableScan[table = hudi:hudi_db.people]
   2024-07-15 12:46:26        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26        _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:26        _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:26        city := city:string:PARTITION_KEY
   2024-07-15 12:46:26        _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:26        name := name:string:REGULAR
   2024-07-15 12:46:26        create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:26        _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:26        id := id:int:REGULAR
   2024-07-15 12:46:26        _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:26        age := age:int:REGULAR
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 2024-07-15T19:46:26.635Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 7.00ms
   2024-07-15 12:46:26 2024-07-15T19:46:26.636Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.LogicalPlanner     io.trino.sql.planner.iterative.IterativeOptimizer:
   2024-07-15 12:46:26 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ TableScan[table = hudi:hudi_db.people]
   2024-07-15 12:46:26        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26        _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:26        _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:26        city := city:string:PARTITION_KEY
   2024-07-15 12:46:26        _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:26        name := name:string:REGULAR
   2024-07-15 12:46:26        create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:26        _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:26        id := id:int:REGULAR
   2024-07-15 12:46:26        _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:26        age := age:int:REGULAR
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 2024-07-15T19:46:26.643Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 6.45ms
   2024-07-15 12:46:26 2024-07-15T19:46:26.644Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.LogicalPlanner     io.trino.sql.planner.optimizations.CheckSubqueryNodesAreRewritten:
   2024-07-15 12:46:26 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ TableScan[table = hudi:hudi_db.people]
   2024-07-15 12:46:26        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26        _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:26        _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:26        city := city:string:PARTITION_KEY
   2024-07-15 12:46:26        _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:26        name := name:string:REGULAR
   2024-07-15 12:46:26        create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:26        _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:26        id := id:int:REGULAR
   2024-07-15 12:46:26        _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:26        age := age:int:REGULAR
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 2024-07-15T19:46:26.651Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 6.16ms
   2024-07-15 12:46:26 2024-07-15T19:46:26.651Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.LogicalPlanner     io.trino.sql.planner.iterative.IterativeOptimizer:
   2024-07-15 12:46:26 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ TableScan[table = hudi:hudi_db.people]
   2024-07-15 12:46:26        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26        _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:26        _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:26        city := city:string:PARTITION_KEY
   2024-07-15 12:46:26        _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:26        name := name:string:REGULAR
   2024-07-15 12:46:26        create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:26        _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:26        id := id:int:REGULAR
   2024-07-15 12:46:26        _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:26        age := age:int:REGULAR
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 2024-07-15T19:46:26.665Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 6.02ms
   2024-07-15 12:46:26 2024-07-15T19:46:26.666Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.LogicalPlanner     io.trino.sql.planner.optimizations.StatsRecordingPlanOptimizer:
   2024-07-15 12:46:26 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ TableScan[table = hudi:hudi_db.people]
   2024-07-15 12:46:26        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26        _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:26        _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:26        city := city:string:PARTITION_KEY
   2024-07-15 12:46:26        _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:26        name := name:string:REGULAR
   2024-07-15 12:46:26        create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:26        _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:26        id := id:int:REGULAR
   2024-07-15 12:46:26        _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:26        age := age:int:REGULAR
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 2024-07-15T19:46:26.672Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 5.86ms
   2024-07-15 12:46:26 2024-07-15T19:46:26.673Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.LogicalPlanner     io.trino.sql.planner.iterative.IterativeOptimizer:
   2024-07-15 12:46:26 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ TableScan[table = hudi:hudi_db.people]
   2024-07-15 12:46:26        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26        _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:26        _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:26        city := city:string:PARTITION_KEY
   2024-07-15 12:46:26        _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:26        name := name:string:REGULAR
   2024-07-15 12:46:26        create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:26        _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:26        id := id:int:REGULAR
   2024-07-15 12:46:26        _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:26        age := age:int:REGULAR
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 2024-07-15T19:46:26.680Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 5.81ms
   2024-07-15 12:46:26 2024-07-15T19:46:26.680Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.LogicalPlanner     io.trino.sql.planner.iterative.IterativeOptimizer:
   2024-07-15 12:46:26 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ TableScan[table = hudi:hudi_db.people]
   2024-07-15 12:46:26        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26        _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:26        _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:26        city := city:string:PARTITION_KEY
   2024-07-15 12:46:26        _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:26        name := name:string:REGULAR
   2024-07-15 12:46:26        create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:26        _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:26        id := id:int:REGULAR
   2024-07-15 12:46:26        _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:26        age := age:int:REGULAR
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 2024-07-15T19:46:26.687Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 6.14ms
   2024-07-15 12:46:26 2024-07-15T19:46:26.688Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.LogicalPlanner     io.trino.sql.planner.iterative.IterativeOptimizer:
   2024-07-15 12:46:26 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ TableScan[table = hudi:hudi_db.people]
   2024-07-15 12:46:26        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26        _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:26        _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:26        city := city:string:PARTITION_KEY
   2024-07-15 12:46:26        _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:26        name := name:string:REGULAR
   2024-07-15 12:46:26        create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:26        _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:26        id := id:int:REGULAR
   2024-07-15 12:46:26        _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:26        age := age:int:REGULAR
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 2024-07-15T19:46:26.694Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 5.61ms
   2024-07-15 12:46:26 2024-07-15T19:46:26.694Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.LogicalPlanner     io.trino.sql.planner.iterative.IterativeOptimizer:
   2024-07-15 12:46:26 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ TableScan[table = hudi:hudi_db.people]
   2024-07-15 12:46:26        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26        _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:26        _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:26        city := city:string:PARTITION_KEY
   2024-07-15 12:46:26        _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:26        name := name:string:REGULAR
   2024-07-15 12:46:26        create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:26        _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:26        id := id:int:REGULAR
   2024-07-15 12:46:26        _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:26        age := age:int:REGULAR
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 2024-07-15T19:46:26.700Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 5.69ms
   2024-07-15 12:46:26 2024-07-15T19:46:26.701Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.LogicalPlanner     io.trino.sql.planner.optimizations.UnaliasSymbolReferences:
   2024-07-15 12:46:26 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ TableScan[table = hudi:hudi_db.people]
   2024-07-15 12:46:26        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26        _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:26        _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:26        city := city:string:PARTITION_KEY
   2024-07-15 12:46:26        _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:26        name := name:string:REGULAR
   2024-07-15 12:46:26        create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:26        _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:26        id := id:int:REGULAR
   2024-07-15 12:46:26        _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:26        age := age:int:REGULAR
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 2024-07-15T19:46:26.707Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 5.94ms
   2024-07-15 12:46:26 2024-07-15T19:46:26.708Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.LogicalPlanner     io.trino.sql.planner.iterative.IterativeOptimizer:
   2024-07-15 12:46:26 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ TableScan[table = hudi:hudi_db.people]
   2024-07-15 12:46:26        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26        _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:26        _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:26        city := city:string:PARTITION_KEY
   2024-07-15 12:46:26        _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:26        name := name:string:REGULAR
   2024-07-15 12:46:26        create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:26        _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:26        id := id:int:REGULAR
   2024-07-15 12:46:26        _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:26        age := age:int:REGULAR
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 2024-07-15T19:46:26.715Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 6.01ms
   2024-07-15 12:46:26 2024-07-15T19:46:26.715Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.LogicalPlanner     io.trino.sql.planner.iterative.IterativeOptimizer:
   2024-07-15 12:46:26 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ TableScan[table = hudi:hudi_db.people]
   2024-07-15 12:46:26        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26        _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:26        _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:26        city := city:string:PARTITION_KEY
   2024-07-15 12:46:26        _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:26        name := name:string:REGULAR
   2024-07-15 12:46:26        create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:26        _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:26        id := id:int:REGULAR
   2024-07-15 12:46:26        _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:26        age := age:int:REGULAR
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 2024-07-15T19:46:26.727Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 11.22ms
   2024-07-15 12:46:26 2024-07-15T19:46:26.727Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.LogicalPlanner     io.trino.sql.planner.iterative.IterativeOptimizer:
   2024-07-15 12:46:26 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ TableScan[table = hudi:hudi_db.people]
   2024-07-15 12:46:26        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26        _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:26        _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:26        city := city:string:PARTITION_KEY
   2024-07-15 12:46:26        _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:26        name := name:string:REGULAR
   2024-07-15 12:46:26        create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:26        _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:26        id := id:int:REGULAR
   2024-07-15 12:46:26        _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:26        age := age:int:REGULAR
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 2024-07-15T19:46:26.735Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 7.33ms
   2024-07-15 12:46:26 2024-07-15T19:46:26.736Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.LogicalPlanner     io.trino.sql.planner.iterative.IterativeOptimizer:
   2024-07-15 12:46:26 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ TableScan[table = hudi:hudi_db.people]
   2024-07-15 12:46:26        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26        _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:26        _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:26        city := city:string:PARTITION_KEY
   2024-07-15 12:46:26        _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:26        name := name:string:REGULAR
   2024-07-15 12:46:26        create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:26        _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:26        id := id:int:REGULAR
   2024-07-15 12:46:26        _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:26        age := age:int:REGULAR
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 2024-07-15T19:46:26.742Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 5.78ms
   2024-07-15 12:46:26 2024-07-15T19:46:26.743Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.LogicalPlanner     io.trino.sql.planner.iterative.IterativeOptimizer:
   2024-07-15 12:46:26 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ TableScan[table = hudi:hudi_db.people]
   2024-07-15 12:46:26        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26        _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:26        _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:26        city := city:string:PARTITION_KEY
   2024-07-15 12:46:26        _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:26        name := name:string:REGULAR
   2024-07-15 12:46:26        create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:26        _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:26        id := id:int:REGULAR
   2024-07-15 12:46:26        _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:26        age := age:int:REGULAR
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 2024-07-15T19:46:26.750Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 6.33ms
   2024-07-15 12:46:26 2024-07-15T19:46:26.750Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.LogicalPlanner     io.trino.sql.planner.iterative.IterativeOptimizer:
   2024-07-15 12:46:26 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ TableScan[table = hudi:hudi_db.people]
   2024-07-15 12:46:26        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26        _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:26        _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:26        city := city:string:PARTITION_KEY
   2024-07-15 12:46:26        _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:26        name := name:string:REGULAR
   2024-07-15 12:46:26        create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:26        _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:26        id := id:int:REGULAR
   2024-07-15 12:46:26        _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:26        age := age:int:REGULAR
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 2024-07-15T19:46:26.757Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 6.08ms
   2024-07-15 12:46:26 2024-07-15T19:46:26.757Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.LogicalPlanner     io.trino.sql.planner.iterative.IterativeOptimizer:
   2024-07-15 12:46:26 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ TableScan[table = hudi:hudi_db.people]
   2024-07-15 12:46:26        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26        _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:26        _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:26        city := city:string:PARTITION_KEY
   2024-07-15 12:46:26        _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:26        name := name:string:REGULAR
   2024-07-15 12:46:26        create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:26        _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:26        id := id:int:REGULAR
   2024-07-15 12:46:26        _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:26        age := age:int:REGULAR
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 2024-07-15T19:46:26.764Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 6.19ms
   2024-07-15 12:46:26 2024-07-15T19:46:26.765Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.LogicalPlanner     io.trino.sql.planner.optimizations.StatsRecordingPlanOptimizer:
   2024-07-15 12:46:26 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ TableScan[table = hudi:hudi_db.people]
   2024-07-15 12:46:26        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26        _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:26        _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:26        city := city:string:PARTITION_KEY
   2024-07-15 12:46:26        _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:26        name := name:string:REGULAR
   2024-07-15 12:46:26        create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:26        _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:26        id := id:int:REGULAR
   2024-07-15 12:46:26        _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:26        age := age:int:REGULAR
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 2024-07-15T19:46:26.770Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 4.95ms
   2024-07-15 12:46:26 2024-07-15T19:46:26.771Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.LogicalPlanner     io.trino.sql.planner.iterative.IterativeOptimizer:
   2024-07-15 12:46:26 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ TableScan[table = hudi:hudi_db.people]
   2024-07-15 12:46:26        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26        _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:26        _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:26        city := city:string:PARTITION_KEY
   2024-07-15 12:46:26        _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:26        name := name:string:REGULAR
   2024-07-15 12:46:26        create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:26        _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:26        id := id:int:REGULAR
   2024-07-15 12:46:26        _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:26        age := age:int:REGULAR
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 2024-07-15T19:46:26.776Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 5.52ms
   2024-07-15 12:46:26 2024-07-15T19:46:26.777Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.LogicalPlanner     io.trino.sql.planner.optimizations.UnaliasSymbolReferences:
   2024-07-15 12:46:26 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ TableScan[table = hudi:hudi_db.people]
   2024-07-15 12:46:26        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26        _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:26        _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:26        city := city:string:PARTITION_KEY
   2024-07-15 12:46:26        _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:26        name := name:string:REGULAR
   2024-07-15 12:46:26        create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:26        _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:26        id := id:int:REGULAR
   2024-07-15 12:46:26        _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:26        age := age:int:REGULAR
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 2024-07-15T19:46:26.783Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 5.76ms
   2024-07-15 12:46:26 2024-07-15T19:46:26.784Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.LogicalPlanner     io.trino.sql.planner.iterative.IterativeOptimizer:
   2024-07-15 12:46:26 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ TableScan[table = hudi:hudi_db.people]
   2024-07-15 12:46:26        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26        _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:26        _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:26        city := city:string:PARTITION_KEY
   2024-07-15 12:46:26        _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:26        name := name:string:REGULAR
   2024-07-15 12:46:26        create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:26        _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:26        id := id:int:REGULAR
   2024-07-15 12:46:26        _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:26        age := age:int:REGULAR
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 2024-07-15T19:46:26.792Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 7.04ms
   2024-07-15 12:46:26 2024-07-15T19:46:26.792Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.LogicalPlanner     io.trino.sql.planner.optimizations.IndexJoinOptimizer:
   2024-07-15 12:46:26 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ TableScan[table = hudi:hudi_db.people]
   2024-07-15 12:46:26        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26        _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:26        _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:26        city := city:string:PARTITION_KEY
   2024-07-15 12:46:26        _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:26        name := name:string:REGULAR
   2024-07-15 12:46:26        create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:26        _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:26        id := id:int:REGULAR
   2024-07-15 12:46:26        _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:26        age := age:int:REGULAR
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 2024-07-15T19:46:26.798Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 5.36ms
   2024-07-15 12:46:26 2024-07-15T19:46:26.798Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.LogicalPlanner     io.trino.sql.planner.optimizations.LimitPushDown:
   2024-07-15 12:46:26 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ TableScan[table = hudi:hudi_db.people]
   2024-07-15 12:46:26        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26        _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:26        _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:26        city := city:string:PARTITION_KEY
   2024-07-15 12:46:26        _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:26        name := name:string:REGULAR
   2024-07-15 12:46:26        create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:26        _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:26        id := id:int:REGULAR
   2024-07-15 12:46:26        _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:26        age := age:int:REGULAR
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 2024-07-15T19:46:26.805Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 5.59ms
   2024-07-15 12:46:26 2024-07-15T19:46:26.805Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.LogicalPlanner     io.trino.sql.planner.iterative.IterativeOptimizer:
   2024-07-15 12:46:26 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ TableScan[table = hudi:hudi_db.people]
   2024-07-15 12:46:26        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26        _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:26        _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:26        city := city:string:PARTITION_KEY
   2024-07-15 12:46:26        _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:26        name := name:string:REGULAR
   2024-07-15 12:46:26        create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:26        _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:26        id := id:int:REGULAR
   2024-07-15 12:46:26        _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:26        age := age:int:REGULAR
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 2024-07-15T19:46:26.811Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 5.07ms
   2024-07-15 12:46:26 2024-07-15T19:46:26.811Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.LogicalPlanner     io.trino.sql.planner.iterative.IterativeOptimizer:
   2024-07-15 12:46:26 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ TableScan[table = hudi:hudi_db.people]
   2024-07-15 12:46:26        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26        _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:26        _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:26        city := city:string:PARTITION_KEY
   2024-07-15 12:46:26        _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:26        name := name:string:REGULAR
   2024-07-15 12:46:26        create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:26        _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:26        id := id:int:REGULAR
   2024-07-15 12:46:26        _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:26        age := age:int:REGULAR
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 2024-07-15T19:46:26.816Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 4.82ms
   2024-07-15 12:46:26 2024-07-15T19:46:26.817Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.LogicalPlanner     io.trino.sql.planner.iterative.IterativeOptimizer:
   2024-07-15 12:46:26 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ TableScan[table = hudi:hudi_db.people]
   2024-07-15 12:46:26        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26        _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:26        _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:26        city := city:string:PARTITION_KEY
   2024-07-15 12:46:26        _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:26        name := name:string:REGULAR
   2024-07-15 12:46:26        create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:26        _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:26        id := id:int:REGULAR
   2024-07-15 12:46:26        _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:26        age := age:int:REGULAR
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 2024-07-15T19:46:26.823Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 5.85ms
   2024-07-15 12:46:26 2024-07-15T19:46:26.824Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.LogicalPlanner     io.trino.sql.planner.iterative.IterativeOptimizer:
   2024-07-15 12:46:26 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ TableScan[table = hudi:hudi_db.people]
   2024-07-15 12:46:26        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26        _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:26        _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:26        city := city:string:PARTITION_KEY
   2024-07-15 12:46:26        _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:26        name := name:string:REGULAR
   2024-07-15 12:46:26        create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:26        _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:26        id := id:int:REGULAR
   2024-07-15 12:46:26        _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:26        age := age:int:REGULAR
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 2024-07-15T19:46:26.830Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 5.85ms
   2024-07-15 12:46:26 2024-07-15T19:46:26.831Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.LogicalPlanner     io.trino.sql.planner.iterative.IterativeOptimizer:
   2024-07-15 12:46:26 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ TableScan[table = hudi:hudi_db.people]
   2024-07-15 12:46:26        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26        _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:26        _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:26        city := city:string:PARTITION_KEY
   2024-07-15 12:46:26        _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:26        name := name:string:REGULAR
   2024-07-15 12:46:26        create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:26        _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:26        id := id:int:REGULAR
   2024-07-15 12:46:26        _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:26        age := age:int:REGULAR
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 2024-07-15T19:46:26.837Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 5.44ms
   2024-07-15 12:46:26 2024-07-15T19:46:26.837Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.LogicalPlanner     io.trino.sql.planner.optimizations.MetadataQueryOptimizer:
   2024-07-15 12:46:26 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ TableScan[table = hudi:hudi_db.people]
   2024-07-15 12:46:26        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26        _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:26        _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:26        city := city:string:PARTITION_KEY
   2024-07-15 12:46:26        _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:26        name := name:string:REGULAR
   2024-07-15 12:46:26        create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:26        _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:26        id := id:int:REGULAR
   2024-07-15 12:46:26        _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:26        age := age:int:REGULAR
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 2024-07-15T19:46:26.843Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 5.10ms
   2024-07-15 12:46:26 2024-07-15T19:46:26.843Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.LogicalPlanner     io.trino.sql.planner.iterative.IterativeOptimizer:
   2024-07-15 12:46:26 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ TableScan[table = hudi:hudi_db.people]
   2024-07-15 12:46:26        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26        _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:26        _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:26        city := city:string:PARTITION_KEY
   2024-07-15 12:46:26        _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:26        name := name:string:REGULAR
   2024-07-15 12:46:26        create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:26        _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:26        id := id:int:REGULAR
   2024-07-15 12:46:26        _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:26        age := age:int:REGULAR
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 2024-07-15T19:46:26.849Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 5.12ms
   2024-07-15 12:46:26 2024-07-15T19:46:26.850Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.LogicalPlanner     io.trino.sql.planner.optimizations.StatsRecordingPlanOptimizer:
   2024-07-15 12:46:26 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ TableScan[table = hudi:hudi_db.people]
   2024-07-15 12:46:26        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26        _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:26        _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:26        city := city:string:PARTITION_KEY
   2024-07-15 12:46:26        _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:26        name := name:string:REGULAR
   2024-07-15 12:46:26        create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:26        _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:26        id := id:int:REGULAR
   2024-07-15 12:46:26        _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:26        age := age:int:REGULAR
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 2024-07-15T19:46:26.856Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 5.57ms
   2024-07-15 12:46:26 2024-07-15T19:46:26.856Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.LogicalPlanner     io.trino.sql.planner.iterative.IterativeOptimizer:
   2024-07-15 12:46:26 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ TableScan[table = hudi:hudi_db.people]
   2024-07-15 12:46:26        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26        _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:26        _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:26        city := city:string:PARTITION_KEY
   2024-07-15 12:46:26        _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:26        name := name:string:REGULAR
   2024-07-15 12:46:26        create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:26        _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:26        id := id:int:REGULAR
   2024-07-15 12:46:26        _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:26        age := age:int:REGULAR
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 2024-07-15T19:46:26.862Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 5.43ms
   2024-07-15 12:46:26 2024-07-15T19:46:26.863Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.LogicalPlanner     io.trino.sql.planner.iterative.IterativeOptimizer:
   2024-07-15 12:46:26 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ TableScan[table = hudi:hudi_db.people]
   2024-07-15 12:46:26        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26        _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:26        _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:26        city := city:string:PARTITION_KEY
   2024-07-15 12:46:26        _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:26        name := name:string:REGULAR
   2024-07-15 12:46:26        create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:26        _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:26        id := id:int:REGULAR
   2024-07-15 12:46:26        _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:26        age := age:int:REGULAR
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 2024-07-15T19:46:26.869Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 5.76ms
   2024-07-15 12:46:26 2024-07-15T19:46:26.870Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.LogicalPlanner     io.trino.sql.planner.optimizations.StatsRecordingPlanOptimizer:
   2024-07-15 12:46:26 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ TableScan[table = hudi:hudi_db.people]
   2024-07-15 12:46:26        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26        _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:26        _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:26        city := city:string:PARTITION_KEY
   2024-07-15 12:46:26        _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:26        name := name:string:REGULAR
   2024-07-15 12:46:26        create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:26        _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:26        id := id:int:REGULAR
   2024-07-15 12:46:26        _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:26        age := age:int:REGULAR
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 2024-07-15T19:46:26.875Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 5.39ms
   2024-07-15 12:46:26 2024-07-15T19:46:26.876Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.LogicalPlanner     io.trino.sql.planner.iterative.IterativeOptimizer:
   2024-07-15 12:46:26 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ TableScan[table = hudi:hudi_db.people]
   2024-07-15 12:46:26        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26        _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:26        _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:26        city := city:string:PARTITION_KEY
   2024-07-15 12:46:26        _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:26        name := name:string:REGULAR
   2024-07-15 12:46:26        create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:26        _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:26        id := id:int:REGULAR
   2024-07-15 12:46:26        _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:26        age := age:int:REGULAR
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 2024-07-15T19:46:26.881Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 4.92ms
   2024-07-15 12:46:26 2024-07-15T19:46:26.882Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.LogicalPlanner     io.trino.sql.planner.iterative.IterativeOptimizer:
   2024-07-15 12:46:26 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ TableScan[table = hudi:hudi_db.people]
   2024-07-15 12:46:26        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26        _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:26        _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:26        city := city:string:PARTITION_KEY
   2024-07-15 12:46:26        _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:26        name := name:string:REGULAR
   2024-07-15 12:46:26        create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:26        _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:26        id := id:int:REGULAR
   2024-07-15 12:46:26        _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:26        age := age:int:REGULAR
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 2024-07-15T19:46:26.887Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 4.77ms
   2024-07-15 12:46:26 2024-07-15T19:46:26.887Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.LogicalPlanner     io.trino.sql.planner.iterative.IterativeOptimizer:
   2024-07-15 12:46:26 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ TableScan[table = hudi:hudi_db.people]
   2024-07-15 12:46:26        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26        _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:26        _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:26        city := city:string:PARTITION_KEY
   2024-07-15 12:46:26        _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:26        name := name:string:REGULAR
   2024-07-15 12:46:26        create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:26        _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:26        id := id:int:REGULAR
   2024-07-15 12:46:26        _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:26        age := age:int:REGULAR
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 2024-07-15T19:46:26.893Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 4.77ms
   2024-07-15 12:46:26 2024-07-15T19:46:26.893Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.LogicalPlanner     io.trino.sql.planner.iterative.IterativeOptimizer:
   2024-07-15 12:46:26 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ TableScan[table = hudi:hudi_db.people]
   2024-07-15 12:46:26        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26        _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:26        _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:26        city := city:string:PARTITION_KEY
   2024-07-15 12:46:26        _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:26        name := name:string:REGULAR
   2024-07-15 12:46:26        create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:26        _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:26        id := id:int:REGULAR
   2024-07-15 12:46:26        _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:26        age := age:int:REGULAR
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 2024-07-15T19:46:26.898Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 5.02ms
   2024-07-15 12:46:26 2024-07-15T19:46:26.899Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.LogicalPlanner     io.trino.sql.planner.optimizations.OptimizeMixedDistinctAggregations:
   2024-07-15 12:46:26 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ TableScan[table = hudi:hudi_db.people]
   2024-07-15 12:46:26        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26        _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:26        _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:26        city := city:string:PARTITION_KEY
   2024-07-15 12:46:26        _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:26        name := name:string:REGULAR
   2024-07-15 12:46:26        create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:26        _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:26        id := id:int:REGULAR
   2024-07-15 12:46:26        _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:26        age := age:int:REGULAR
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 2024-07-15T19:46:26.905Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 5.17ms
   2024-07-15 12:46:26 2024-07-15T19:46:26.905Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.LogicalPlanner     io.trino.sql.planner.iterative.IterativeOptimizer:
   2024-07-15 12:46:26 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ TableScan[table = hudi:hudi_db.people]
   2024-07-15 12:46:26        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26        _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:26        _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:26        city := city:string:PARTITION_KEY
   2024-07-15 12:46:26        _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:26        name := name:string:REGULAR
   2024-07-15 12:46:26        create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:26        _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:26        id := id:int:REGULAR
   2024-07-15 12:46:26        _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:26        age := age:int:REGULAR
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 2024-07-15T19:46:26.911Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 4.68ms
   2024-07-15 12:46:26 2024-07-15T19:46:26.911Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.LogicalPlanner     io.trino.sql.planner.iterative.IterativeOptimizer:
   2024-07-15 12:46:26 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ TableScan[table = hudi:hudi_db.people]
   2024-07-15 12:46:26        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26        _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:26        _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:26        city := city:string:PARTITION_KEY
   2024-07-15 12:46:26        _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:26        name := name:string:REGULAR
   2024-07-15 12:46:26        create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:26        _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:26        id := id:int:REGULAR
   2024-07-15 12:46:26        _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:26        age := age:int:REGULAR
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 2024-07-15T19:46:26.919Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 6.10ms
   2024-07-15 12:46:26 2024-07-15T19:46:26.925Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 5.49ms
   2024-07-15 12:46:26 2024-07-15T19:46:26.925Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.iterative.IterativeOptimizer       Rule: io.trino.sql.planner.iterative.rule.DetermineTableScanNodePartitioning
   2024-07-15 12:46:26 Before:
   2024-07-15 12:46:26 TableScan[table = hudi:hudi_db.people]
   2024-07-15 12:46:26     Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26     _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:26     _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:26     city := city:string:PARTITION_KEY
   2024-07-15 12:46:26     _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:26     name := name:string:REGULAR
   2024-07-15 12:46:26     create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:26     _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:26     id := id:int:REGULAR
   2024-07-15 12:46:26     _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:26     age := age:int:REGULAR
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 After:
   2024-07-15 12:46:26 TableScan[table = hudi:hudi_db.people]
   2024-07-15 12:46:26     Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26     _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:26     _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:26     city := city:string:PARTITION_KEY
   2024-07-15 12:46:26     _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:26     name := name:string:REGULAR
   2024-07-15 12:46:26     create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:26     _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:26     id := id:int:REGULAR
   2024-07-15 12:46:26     _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:26     age := age:int:REGULAR
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 2024-07-15T19:46:26.931Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 4.82ms
   2024-07-15 12:46:26 2024-07-15T19:46:26.931Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.LogicalPlanner     io.trino.sql.planner.iterative.IterativeOptimizer:
   2024-07-15 12:46:26 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ TableScan[table = hudi:hudi_db.people]
   2024-07-15 12:46:26        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26        _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:26        _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:26        city := city:string:PARTITION_KEY
   2024-07-15 12:46:26        _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:26        name := name:string:REGULAR
   2024-07-15 12:46:26        create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:26        _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:26        id := id:int:REGULAR
   2024-07-15 12:46:26        _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:26        age := age:int:REGULAR
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 2024-07-15T19:46:26.936Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 4.82ms
   2024-07-15 12:46:26 2024-07-15T19:46:26.937Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.LogicalPlanner     io.trino.sql.planner.iterative.IterativeOptimizer:
   2024-07-15 12:46:26 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ TableScan[table = hudi:hudi_db.people]
   2024-07-15 12:46:26        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26        _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:26        _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:26        city := city:string:PARTITION_KEY
   2024-07-15 12:46:26        _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:26        name := name:string:REGULAR
   2024-07-15 12:46:26        create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:26        _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:26        id := id:int:REGULAR
   2024-07-15 12:46:26        _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:26        age := age:int:REGULAR
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 2024-07-15T19:46:26.942Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 4.91ms
   2024-07-15 12:46:26 2024-07-15T19:46:26.943Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.LogicalPlanner     io.trino.sql.planner.iterative.IterativeOptimizer:
   2024-07-15 12:46:26 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ TableScan[table = hudi:hudi_db.people]
   2024-07-15 12:46:26        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26        _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:26        _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:26        city := city:string:PARTITION_KEY
   2024-07-15 12:46:26        _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:26        name := name:string:REGULAR
   2024-07-15 12:46:26        create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:26        _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:26        id := id:int:REGULAR
   2024-07-15 12:46:26        _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:26        age := age:int:REGULAR
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 2024-07-15T19:46:26.948Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 4.96ms
   2024-07-15 12:46:26 2024-07-15T19:46:26.948Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.LogicalPlanner     io.trino.sql.planner.iterative.IterativeOptimizer:
   2024-07-15 12:46:26 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ TableScan[table = hudi:hudi_db.people]
   2024-07-15 12:46:26        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26        _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:26        _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:26        city := city:string:PARTITION_KEY
   2024-07-15 12:46:26        _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:26        name := name:string:REGULAR
   2024-07-15 12:46:26        create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:26        _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:26        id := id:int:REGULAR
   2024-07-15 12:46:26        _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:26        age := age:int:REGULAR
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 2024-07-15T19:46:26.954Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 5.15ms
   2024-07-15 12:46:26 2024-07-15T19:46:26.955Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.LogicalPlanner     io.trino.sql.planner.iterative.IterativeOptimizer:
   2024-07-15 12:46:26 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ TableScan[table = hudi:hudi_db.people]
   2024-07-15 12:46:26        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26        _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:26        _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:26        city := city:string:PARTITION_KEY
   2024-07-15 12:46:26        _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:26        name := name:string:REGULAR
   2024-07-15 12:46:26        create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:26        _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:26        id := id:int:REGULAR
   2024-07-15 12:46:26        _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:26        age := age:int:REGULAR
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 2024-07-15T19:46:26.960Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 5.17ms
   2024-07-15 12:46:26 2024-07-15T19:46:26.961Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.LogicalPlanner     io.trino.sql.planner.optimizations.UnaliasSymbolReferences:
   2024-07-15 12:46:26 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ TableScan[table = hudi:hudi_db.people]
   2024-07-15 12:46:26        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26        _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:26        _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:26        city := city:string:PARTITION_KEY
   2024-07-15 12:46:26        _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:26        name := name:string:REGULAR
   2024-07-15 12:46:26        create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:26        _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:26        id := id:int:REGULAR
   2024-07-15 12:46:26        _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:26        age := age:int:REGULAR
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 2024-07-15T19:46:26.975Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 5.22ms
   2024-07-15 12:46:26 2024-07-15T19:46:26.976Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.LogicalPlanner     io.trino.sql.planner.optimizations.StatsRecordingPlanOptimizer:
   2024-07-15 12:46:26 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ TableScan[table = hudi:hudi_db.people]
   2024-07-15 12:46:26        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26        _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:26        _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:26        city := city:string:PARTITION_KEY
   2024-07-15 12:46:26        _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:26        name := name:string:REGULAR
   2024-07-15 12:46:26        create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:26        _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:26        id := id:int:REGULAR
   2024-07-15 12:46:26        _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:26        age := age:int:REGULAR
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 2024-07-15T19:46:26.982Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 4.90ms
   2024-07-15 12:46:26 2024-07-15T19:46:26.982Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.LogicalPlanner     io.trino.sql.planner.optimizations.StatsRecordingPlanOptimizer:
   2024-07-15 12:46:26 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ TableScan[table = hudi:hudi_db.people]
   2024-07-15 12:46:26        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26        _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:26        _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:26        city := city:string:PARTITION_KEY
   2024-07-15 12:46:26        _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:26        name := name:string:REGULAR
   2024-07-15 12:46:26        create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:26        _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:26        id := id:int:REGULAR
   2024-07-15 12:46:26        _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:26        age := age:int:REGULAR
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 2024-07-15T19:46:26.988Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 5.20ms
   2024-07-15 12:46:26 2024-07-15T19:46:26.989Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.LogicalPlanner     io.trino.sql.planner.iterative.IterativeOptimizer:
   2024-07-15 12:46:26 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ TableScan[table = hudi:hudi_db.people]
   2024-07-15 12:46:26        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26        _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:26        _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:26        city := city:string:PARTITION_KEY
   2024-07-15 12:46:26        _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:26        name := name:string:REGULAR
   2024-07-15 12:46:26        create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:26        _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:26        id := id:int:REGULAR
   2024-07-15 12:46:26        _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:26        age := age:int:REGULAR
   2024-07-15 12:46:26 
   2024-07-15 12:46:26 2024-07-15T19:46:26.994Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 5.39ms
   2024-07-15 12:46:26 2024-07-15T19:46:26.995Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.LogicalPlanner     io.trino.sql.planner.optimizations.StatsRecordingPlanOptimizer:
   2024-07-15 12:46:26 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:26 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26 └─ TableScan[table = hudi:hudi_db.people]
   2024-07-15 12:46:26        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:26        _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:26        _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:26        city := city:string:PARTITION_KEY
   2024-07-15 12:46:26        _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:26        name := name:string:REGULAR
   2024-07-15 12:46:26        create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:26        _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:26        id := id:int:REGULAR
   2024-07-15 12:46:26        _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:26        age := age:int:REGULAR
   2024-07-15 12:46:26 
   2024-07-15 12:46:27 2024-07-15T19:46:27.000Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 4.93ms
   2024-07-15 12:46:27 2024-07-15T19:46:27.001Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.LogicalPlanner     io.trino.sql.planner.iterative.IterativeOptimizer:
   2024-07-15 12:46:27 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:27 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:27 └─ TableScan[table = hudi:hudi_db.people]
   2024-07-15 12:46:27        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:27        _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:27        _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:27        city := city:string:PARTITION_KEY
   2024-07-15 12:46:27        _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:27        name := name:string:REGULAR
   2024-07-15 12:46:27        create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:27        _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:27        id := id:int:REGULAR
   2024-07-15 12:46:27        _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:27        age := age:int:REGULAR
   2024-07-15 12:46:27 
   2024-07-15 12:46:27 2024-07-15T19:46:27.006Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 4.71ms
   2024-07-15 12:46:27 2024-07-15T19:46:27.006Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.LogicalPlanner     io.trino.sql.planner.iterative.IterativeOptimizer:
   2024-07-15 12:46:27 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:27 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:27 └─ TableScan[table = hudi:hudi_db.people]
   2024-07-15 12:46:27        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:27        _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:27        _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:27        city := city:string:PARTITION_KEY
   2024-07-15 12:46:27        _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:27        name := name:string:REGULAR
   2024-07-15 12:46:27        create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:27        _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:27        id := id:int:REGULAR
   2024-07-15 12:46:27        _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:27        age := age:int:REGULAR
   2024-07-15 12:46:27 
   2024-07-15 12:46:27 2024-07-15T19:46:27.016Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 9.51ms
   2024-07-15 12:46:27 2024-07-15T19:46:27.017Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.LogicalPlanner     io.trino.sql.planner.iterative.IterativeOptimizer:
   2024-07-15 12:46:27 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:27 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:27 └─ TableScan[table = hudi:hudi_db.people]
   2024-07-15 12:46:27        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:27        _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:27        _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:27        city := city:string:PARTITION_KEY
   2024-07-15 12:46:27        _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:27        name := name:string:REGULAR
   2024-07-15 12:46:27        create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:27        _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:27        id := id:int:REGULAR
   2024-07-15 12:46:27        _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:27        age := age:int:REGULAR
   2024-07-15 12:46:27 
   2024-07-15 12:46:27 2024-07-15T19:46:27.022Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 4.67ms
   2024-07-15 12:46:27 2024-07-15T19:46:27.022Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.LogicalPlanner     io.trino.sql.planner.optimizations.StatsRecordingPlanOptimizer:
   2024-07-15 12:46:27 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:27 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:27 └─ TableScan[table = hudi:hudi_db.people]
   2024-07-15 12:46:27        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:27        _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:27        _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:27        city := city:string:PARTITION_KEY
   2024-07-15 12:46:27        _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:27        name := name:string:REGULAR
   2024-07-15 12:46:27        create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:27        _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:27        id := id:int:REGULAR
   2024-07-15 12:46:27        _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:27        age := age:int:REGULAR
   2024-07-15 12:46:27 
   2024-07-15 12:46:27 2024-07-15T19:46:27.029Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 4.83ms
   2024-07-15 12:46:27 2024-07-15T19:46:27.029Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.LogicalPlanner     io.trino.sql.planner.iterative.rule.RemoveUnsupportedDynamicFilters:
   2024-07-15 12:46:27 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:27 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:27 └─ TableScan[table = hudi:hudi_db.people]
   2024-07-15 12:46:27        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:27        _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:27        _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:27        city := city:string:PARTITION_KEY
   2024-07-15 12:46:27        _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:27        name := name:string:REGULAR
   2024-07-15 12:46:27        create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:27        _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:27        id := id:int:REGULAR
   2024-07-15 12:46:27        _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:27        age := age:int:REGULAR
   2024-07-15 12:46:27 
   2024-07-15 12:46:27 2024-07-15T19:46:27.034Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 4.64ms
   2024-07-15 12:46:27 2024-07-15T19:46:27.035Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.LogicalPlanner     io.trino.sql.planner.iterative.IterativeOptimizer:
   2024-07-15 12:46:27 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:27 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:27 └─ TableScan[table = hudi:hudi_db.people]
   2024-07-15 12:46:27        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:27        _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:27        _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:27        city := city:string:PARTITION_KEY
   2024-07-15 12:46:27        _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:27        name := name:string:REGULAR
   2024-07-15 12:46:27        create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:27        _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:27        id := id:int:REGULAR
   2024-07-15 12:46:27        _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:27        age := age:int:REGULAR
   2024-07-15 12:46:27 
   2024-07-15 12:46:27 2024-07-15T19:46:27.040Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 4.60ms
   2024-07-15 12:46:27 2024-07-15T19:46:27.040Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.LogicalPlanner     io.trino.sql.planner.iterative.IterativeOptimizer:
   2024-07-15 12:46:27 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:27 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:27 └─ TableScan[table = hudi:hudi_db.people]
   2024-07-15 12:46:27        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:27        _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:27        _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:27        city := city:string:PARTITION_KEY
   2024-07-15 12:46:27        _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:27        name := name:string:REGULAR
   2024-07-15 12:46:27        create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:27        _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:27        id := id:int:REGULAR
   2024-07-15 12:46:27        _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:27        age := age:int:REGULAR
   2024-07-15 12:46:27 
   2024-07-15 12:46:27 2024-07-15T19:46:27.046Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 5.03ms
   2024-07-15 12:46:27 2024-07-15T19:46:27.046Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.LogicalPlanner     io.trino.sql.planner.optimizations.UnaliasSymbolReferences:
   2024-07-15 12:46:27 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:27 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:27 └─ TableScan[table = hudi:hudi_db.people]
   2024-07-15 12:46:27        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:27        _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:27        _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:27        city := city:string:PARTITION_KEY
   2024-07-15 12:46:27        _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:27        name := name:string:REGULAR
   2024-07-15 12:46:27        create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:27        _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:27        id := id:int:REGULAR
   2024-07-15 12:46:27        _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:27        age := age:int:REGULAR
   2024-07-15 12:46:27 
   2024-07-15 12:46:27 2024-07-15T19:46:27.052Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 5.28ms
   2024-07-15 12:46:27 2024-07-15T19:46:27.052Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.LogicalPlanner     io.trino.sql.planner.iterative.IterativeOptimizer:
   2024-07-15 12:46:27 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:27 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:27 └─ TableScan[table = hudi:hudi_db.people]
   2024-07-15 12:46:27        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:27        _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:27        _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:27        city := city:string:PARTITION_KEY
   2024-07-15 12:46:27        _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:27        name := name:string:REGULAR
   2024-07-15 12:46:27        create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:27        _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:27        id := id:int:REGULAR
   2024-07-15 12:46:27        _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:27        age := age:int:REGULAR
   2024-07-15 12:46:27 
   2024-07-15 12:46:27 2024-07-15T19:46:27.058Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 5.40ms
   2024-07-15 12:46:27 2024-07-15T19:46:27.058Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.LogicalPlanner     io.trino.sql.planner.iterative.IterativeOptimizer:
   2024-07-15 12:46:27 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:27 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:27 └─ TableScan[table = hudi:hudi_db.people]
   2024-07-15 12:46:27        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:27        _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:27        _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:27        city := city:string:PARTITION_KEY
   2024-07-15 12:46:27        _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:27        name := name:string:REGULAR
   2024-07-15 12:46:27        create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:27        _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:27        id := id:int:REGULAR
   2024-07-15 12:46:27        _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:27        age := age:int:REGULAR
   2024-07-15 12:46:27 
   2024-07-15 12:46:27 2024-07-15T19:46:27.068Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 4.80ms
   2024-07-15 12:46:27 2024-07-15T19:46:27.068Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.LogicalPlanner     io.trino.sql.planner.optimizations.AddLocalExchanges:
   2024-07-15 12:46:27 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:27 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:27 └─ TableScan[table = hudi:hudi_db.people]
   2024-07-15 12:46:27        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:27        _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:27        _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:27        city := city:string:PARTITION_KEY
   2024-07-15 12:46:27        _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:27        name := name:string:REGULAR
   2024-07-15 12:46:27        create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:27        _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:27        id := id:int:REGULAR
   2024-07-15 12:46:27        _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:27        age := age:int:REGULAR
   2024-07-15 12:46:27 
   2024-07-15 12:46:27 2024-07-15T19:46:27.074Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 4.96ms
   2024-07-15 12:46:27 2024-07-15T19:46:27.074Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.LogicalPlanner     io.trino.sql.planner.iterative.IterativeOptimizer:
   2024-07-15 12:46:27 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:27 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:27 └─ TableScan[table = hudi:hudi_db.people]
   2024-07-15 12:46:27        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:27        _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:27        _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:27        city := city:string:PARTITION_KEY
   2024-07-15 12:46:27        _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:27        name := name:string:REGULAR
   2024-07-15 12:46:27        create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:27        _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:27        id := id:int:REGULAR
   2024-07-15 12:46:27        _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:27        age := age:int:REGULAR
   2024-07-15 12:46:27 
   2024-07-15 12:46:27 2024-07-15T19:46:27.079Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 4.78ms
   2024-07-15 12:46:27 2024-07-15T19:46:27.080Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.LogicalPlanner     io.trino.sql.planner.iterative.IterativeOptimizer:
   2024-07-15 12:46:27 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:27 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:27 └─ TableScan[table = hudi:hudi_db.people]
   2024-07-15 12:46:27        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:27        _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:27        _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:27        city := city:string:PARTITION_KEY
   2024-07-15 12:46:27        _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:27        name := name:string:REGULAR
   2024-07-15 12:46:27        create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:27        _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:27        id := id:int:REGULAR
   2024-07-15 12:46:27        _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:27        age := age:int:REGULAR
   2024-07-15 12:46:27 
   2024-07-15 12:46:27 2024-07-15T19:46:27.086Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 5.85ms
   2024-07-15 12:46:27 2024-07-15T19:46:27.087Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.LogicalPlanner     io.trino.sql.planner.iterative.IterativeOptimizer:
   2024-07-15 12:46:27 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:27 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:27 └─ TableScan[table = hudi:hudi_db.people]
   2024-07-15 12:46:27        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:27        _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:27        _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:27        city := city:string:PARTITION_KEY
   2024-07-15 12:46:27        _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:27        name := name:string:REGULAR
   2024-07-15 12:46:27        create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:27        _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:27        id := id:int:REGULAR
   2024-07-15 12:46:27        _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:27        age := age:int:REGULAR
   2024-07-15 12:46:27 
   2024-07-15 12:46:27 2024-07-15T19:46:27.093Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 5.74ms
   2024-07-15 12:46:27 2024-07-15T19:46:27.094Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.LogicalPlanner     io.trino.sql.planner.iterative.IterativeOptimizer:
   2024-07-15 12:46:27 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:27 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:27 └─ TableScan[table = hudi:hudi_db.people]
   2024-07-15 12:46:27        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:27        _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:27        _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:27        city := city:string:PARTITION_KEY
   2024-07-15 12:46:27        _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:27        name := name:string:REGULAR
   2024-07-15 12:46:27        create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:27        _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:27        id := id:int:REGULAR
   2024-07-15 12:46:27        _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:27        age := age:int:REGULAR
   2024-07-15 12:46:27 
   2024-07-15 12:46:27 2024-07-15T19:46:27.102Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 4.68ms
   2024-07-15 12:46:27 2024-07-15T19:46:27.103Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.LogicalPlanner     io.trino.sql.planner.optimizations.HashGenerationOptimizer:
   2024-07-15 12:46:27 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:27 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:27 └─ TableScan[table = hudi:hudi_db.people]
   2024-07-15 12:46:27        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:27        _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:27        _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:27        city := city:string:PARTITION_KEY
   2024-07-15 12:46:27        _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:27        name := name:string:REGULAR
   2024-07-15 12:46:27        create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:27        _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:27        id := id:int:REGULAR
   2024-07-15 12:46:27        _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:27        age := age:int:REGULAR
   2024-07-15 12:46:27 
   2024-07-15 12:46:27 2024-07-15T19:46:27.108Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 4.73ms
   2024-07-15 12:46:27 2024-07-15T19:46:27.108Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.LogicalPlanner     io.trino.sql.planner.iterative.IterativeOptimizer:
   2024-07-15 12:46:27 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:27 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:27 └─ TableScan[table = hudi:hudi_db.people]
   2024-07-15 12:46:27        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:27        _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:27        _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:27        city := city:string:PARTITION_KEY
   2024-07-15 12:46:27        _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:27        name := name:string:REGULAR
   2024-07-15 12:46:27        create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:27        _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:27        id := id:int:REGULAR
   2024-07-15 12:46:27        _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:27        age := age:int:REGULAR
   2024-07-15 12:46:27 
   2024-07-15 12:46:27 2024-07-15T19:46:27.113Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 4.64ms
   2024-07-15 12:46:27 2024-07-15T19:46:27.114Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.LogicalPlanner     io.trino.sql.planner.iterative.rule.RemoveUnsupportedDynamicFilters:
   2024-07-15 12:46:27 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:27 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:27 └─ TableScan[table = hudi:hudi_db.people]
   2024-07-15 12:46:27        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:27        _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:27        _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:27        city := city:string:PARTITION_KEY
   2024-07-15 12:46:27        _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:27        name := name:string:REGULAR
   2024-07-15 12:46:27        create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:27        _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:27        id := id:int:REGULAR
   2024-07-15 12:46:27        _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:27        age := age:int:REGULAR
   2024-07-15 12:46:27 
   2024-07-15 12:46:27 2024-07-15T19:46:27.119Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 4.64ms
   2024-07-15 12:46:27 2024-07-15T19:46:27.120Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.sql.planner.LogicalPlanner     io.trino.sql.planner.optimizations.BeginTableWrite:
   2024-07-15 12:46:27 Output[columnNames = [_hoodie_commit_time, _hoodie_commit_seqno, _hoodie_record_key, _hoodie_partition_path, _hoodie_file_name, id, name, age, create_ts, city]]
   2024-07-15 12:46:27 │   Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:27 └─ TableScan[table = hudi:hudi_db.people]
   2024-07-15 12:46:27        Layout: [_hoodie_commit_time:varchar, _hoodie_commit_seqno:varchar, _hoodie_record_key:varchar, _hoodie_partition_path:varchar, _hoodie_file_name:varchar, id:integer, name:varchar, age:integer, create_ts:varchar, city:varchar]
   2024-07-15 12:46:27        _hoodie_commit_time := _hoodie_commit_time:string:REGULAR
   2024-07-15 12:46:27        _hoodie_partition_path := _hoodie_partition_path:string:REGULAR
   2024-07-15 12:46:27        city := city:string:PARTITION_KEY
   2024-07-15 12:46:27        _hoodie_record_key := _hoodie_record_key:string:REGULAR
   2024-07-15 12:46:27        name := name:string:REGULAR
   2024-07-15 12:46:27        create_ts := create_ts:string:REGULAR
   2024-07-15 12:46:27        _hoodie_commit_seqno := _hoodie_commit_seqno:string:REGULAR
   2024-07-15 12:46:27        id := id:int:REGULAR
   2024-07-15 12:46:27        _hoodie_file_name := _hoodie_file_name:string:REGULAR
   2024-07-15 12:46:27        age := age:int:REGULAR
   2024-07-15 12:46:27 
   2024-07-15 12:46:27 2024-07-15T19:46:27.134Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 5.45ms
   2024-07-15 12:46:27 2024-07-15T19:46:27.147Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 5.47ms
   2024-07-15 12:46:27 2024-07-15T19:46:27.156Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 4.73ms
   2024-07-15 12:46:27 2024-07-15T19:46:27.159Z    DEBUG   dispatcher-query-4      io.trino.execution.StageStateMachine    Stage 20240715_194625_00000_23mm5.0 is PLANNED
   2024-07-15 12:46:27 2024-07-15T19:46:27.161Z    DEBUG   dispatcher-query-4      io.trino.execution.QueryStateMachine    Query 20240715_194625_00000_23mm5 is STARTING
   2024-07-15 12:46:27 2024-07-15T19:46:27.164Z    DEBUG   stage-scheduler io.trino.execution.scheduler.PipelinedStageExecution    Pipelined stage execution 20240715_194625_00000_23mm5.0 is PLANNED
   2024-07-15 12:46:27 2024-07-15T19:46:27.173Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 6.29ms
   2024-07-15 12:46:27 2024-07-15T19:46:27.179Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getTableReq(req=GetTableRequest(dbName:hudi_db, tblName:people, capabilities:ClientCapabilities(values:[INSERT_ONLY_TABLES]))) succeeded in 4.63ms
   2024-07-15 12:46:27 2024-07-15T19:46:27.190Z    INFO    Query-20240715_194625_00000_23mm5-187   org.apache.hudi.common.table.HoodieTableMetaClient      Loading HoodieTableMetaClient from s3a://warehouse/people
   2024-07-15 12:46:27 2024-07-15T19:46:27.207Z    INFO    Query-20240715_194625_00000_23mm5-187   org.apache.hudi.common.table.HoodieTableConfig  Loading table properties from s3a://warehouse/people/.hoodie/hoodie.properties
   2024-07-15 12:46:27 2024-07-15T19:46:27.212Z    INFO    Query-20240715_194625_00000_23mm5-187   org.apache.hudi.common.table.HoodieTableMetaClient      Finished Loading Table of type COPY_ON_WRITE(version=1, baseFileFormat=PARQUET) from s3a://warehouse/people
   2024-07-15 12:46:27 2024-07-15T19:46:27.225Z    INFO    Query-20240715_194625_00000_23mm5-187   org.apache.hudi.common.table.timeline.HoodieActiveTimeline      Loaded instants upto : Option{val=[20240715194105692__replacecommit__COMPLETED]}
   2024-07-15 12:46:27 2024-07-15T19:46:27.226Z    INFO    Query-20240715_194625_00000_23mm5-187   org.apache.hudi.common.table.view.FileSystemViewManager Creating InMemory based view for basePath s3a://warehouse/people
   2024-07-15 12:46:27 2024-07-15T19:46:27.241Z    INFO    Query-20240715_194625_00000_23mm5-187   org.apache.hudi.common.table.view.AbstractTableFileSystemView   Took 14 ms to read  1 instants, 0 replaced file groups
   2024-07-15 12:46:27 2024-07-15T19:46:27.243Z    INFO    Query-20240715_194625_00000_23mm5-187   org.apache.hudi.common.util.ClusteringUtils     Found 0 files in pending clustering operations
   2024-07-15 12:46:27 2024-07-15T19:46:27.261Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.execution.scheduler.policy.PhasedExecutionSchedule     selectedForExecution: [PipelinedStageStateMachine{stageId=20240715_194625_00000_23mm5.0, state=PLANNED}]
   2024-07-15 12:46:27 2024-07-15T19:46:27.262Z    DEBUG   Query-20240715_194625_00000_23mm5-187   io.trino.execution.scheduler.policy.PhasedExecutionSchedule     fragmentDependency: isDirected: true, allowsSelfLoops: false, nodes: [0], edges: [], fragmentTopology: isDirected: true, allowsSelfLoops: false, nodes: [0], edges: [], sortedFragments: [0], stagesByFragmentId: {0=PipelinedStageStateMachine{stageId=20240715_194625_00000_23mm5.0, state=PLANNED}}
   2024-07-15 12:46:27 2024-07-15T19:46:27.264Z    DEBUG   Query-20240715_194625_00000_23mm5-198   io.trino.execution.scheduler.policy.PhasedExecutionSchedule     scheduledStages: []
   2024-07-15 12:46:27 2024-07-15T19:46:27.265Z    DEBUG   Query-20240715_194625_00000_23mm5-198   io.trino.execution.scheduler.policy.PhasedExecutionSchedule     blockedFragments: []
   2024-07-15 12:46:27 2024-07-15T19:46:27.265Z    DEBUG   Query-20240715_194625_00000_23mm5-198   io.trino.execution.scheduler.policy.PhasedExecutionSchedule     selectedForExecution: []
   2024-07-15 12:46:27 2024-07-15T19:46:27.265Z    DEBUG   hudi-split-manager-0    io.trino.plugin.hive.metastore.thrift.ThriftHiveMetastoreClient Invocation of getPartitionNames(db_name='hudi_db', tbl_name='people', max_parts=-1) succeeded in 15.61ms
   2024-07-15 12:46:27 2024-07-15T19:46:27.265Z    DEBUG   stage-scheduler io.trino.execution.scheduler.PipelinedStageExecution    Pipelined stage execution 20240715_194625_00000_23mm5.0 is SCHEDULING
   2024-07-15 12:46:27 2024-07-15T19:46:27.269Z    DEBUG   Query-20240715_194625_00000_23mm5-198   io.trino.execution.scheduler.SourcePartitionedScheduler stage id: 20240715_194625_00000_23mm5.0, node: 0; blocked on next split batch
   2024-07-15 12:46:27 2024-07-15T19:46:27.270Z    DEBUG   Query-20240715_194625_00000_23mm5-198   io.trino.execution.scheduler.SourcePartitionedScheduler stage id: 20240715_194625_00000_23mm5.0, node: 0; assigned 0 splits (blocked reason WAITING_FOR_SOURCE)
   2024-07-15 12:46:27 2024-07-15T19:46:27.270Z    DEBUG   Query-20240715_194625_00000_23mm5-198   io.trino.execution.scheduler.policy.PhasedExecutionSchedule     scheduledStages: []
   2024-07-15 12:46:27 2024-07-15T19:46:27.270Z    DEBUG   Query-20240715_194625_00000_23mm5-198   io.trino.execution.scheduler.policy.PhasedExecutionSchedule     blockedFragments: []
   2024-07-15 12:46:27 2024-07-15T19:46:27.270Z    DEBUG   Query-20240715_194625_00000_23mm5-198   io.trino.execution.scheduler.policy.PhasedExecutionSchedule     selectedForExecution: []
   2024-07-15 12:46:27 2024-07-15T19:46:27.270Z    DEBUG   Query-20240715_194625_00000_23mm5-198   io.trino.execution.scheduler.SourcePartitionedScheduler stage id: 20240715_194625_00000_23mm5.0, node: 0; transitioning to SPLITS_SCHEDULED
   2024-07-15 12:46:27 2024-07-15T19:46:27.273Z    DEBUG   dispatcher-query-4      io.trino.execution.StageStateMachine    Stage 20240715_194625_00000_23mm5.0 is SCHEDULING
   2024-07-15 12:46:27 2024-07-15T19:46:27.280Z    DEBUG   dispatcher-query-4      io.trino.execution.StageStateMachine    Stage 20240715_194625_00000_23mm5.0 is RUNNING
   2024-07-15 12:46:27 2024-07-15T19:46:27.282Z    DEBUG   Query-20240715_194625_00000_23mm5-198   io.trino.execution.scheduler.SourcePartitionedScheduler stage id: 20240715_194625_00000_23mm5.0, node: 0; transitioning to FINISHED
   2024-07-15 12:46:27 2024-07-15T19:46:27.283Z    DEBUG   Query-20240715_194625_00000_23mm5-198   io.trino.execution.scheduler.policy.PhasedExecutionSchedule     scheduledStages: [PipelinedStageStateMachine{stageId=20240715_194625_00000_23mm5.0, state=SCHEDULED}]
   2024-07-15 12:46:27 2024-07-15T19:46:27.283Z    DEBUG   stage-scheduler io.trino.execution.scheduler.PipelinedStageExecution    Pipelined stage execution 20240715_194625_00000_23mm5.0 is SCHEDULED
   2024-07-15 12:46:27 2024-07-15T19:46:27.283Z    DEBUG   dispatcher-query-1      io.trino.execution.QueryStateMachine    Query 20240715_194625_00000_23mm5 is RUNNING
   2024-07-15 12:46:27 2024-07-15T19:46:27.320Z    DEBUG   Query-20240715_194625_00000_23mm5-198   io.trino.execution.scheduler.policy.PhasedExecutionSchedule     blockedFragments: []
   2024-07-15 12:46:27 2024-07-15T19:46:27.320Z    DEBUG   Query-20240715_194625_00000_23mm5-198   io.trino.execution.scheduler.policy.PhasedExecutionSchedule     selectedForExecution: []
   2024-07-15 12:46:27 2024-07-15T19:46:27.325Z    DEBUG   task-notification-0     io.trino.execution.TaskStateMachine     Task 20240715_194625_00000_23mm5.0.0.0 is RUNNING
   2024-07-15 12:46:27 2024-07-15T19:46:27.422Z    DEBUG   Task-20240715_194625_00000_23mm5.0.0.0-140      io.trino.execution.executor.TaskExecutor        Task scheduled 20240715_194625_00000_23mm5.0.0.0
   2024-07-15 12:46:27 2024-07-15T19:46:27.433Z    DEBUG   stage-scheduler io.trino.execution.scheduler.PipelinedStageExecution    Pipelined stage execution 20240715_194625_00000_23mm5.0 is RUNNING
   2024-07-15 12:46:27 2024-07-15T19:46:27.437Z    DEBUG   20240715_194625_00000_23mm5.0.0.0-0-92  io.trino.execution.executor.TaskExecutor        Split 20240715_194625_00000_23mm5.0.0.0-0 io.trino.split.EmptySplit@55918216 (start = 1.03319404799098E8, wall = 11 ms, cpu = 8 ms, wait = 0 ms, calls = 1) is finished
   2024-07-15 12:46:27 2024-07-15T19:46:27.439Z    DEBUG   task-notification-4     io.trino.execution.TaskStateMachine     Task 20240715_194625_00000_23mm5.0.0.0 is FLUSHING
   2024-07-15 12:46:27 2024-07-15T19:46:27.443Z    DEBUG   http-worker-184 io.trino.execution.SqlTask      Aborting task 20240715_194625_00000_23mm5.0.0.0 output 0
   2024-07-15 12:46:27 2024-07-15T19:46:27.443Z    DEBUG   task-notification-1     io.trino.execution.TaskStateMachine     Task 20240715_194625_00000_23mm5.0.0.0 is FINISHED
   2024-07-15 12:46:27 2024-07-15T19:46:27.444Z    DEBUG   stage-scheduler io.trino.execution.scheduler.PipelinedStageExecution    Pipelined stage execution 20240715_194625_00000_23mm5.0 is FLUSHING
   2024-07-15 12:46:27 2024-07-15T19:46:27.445Z    DEBUG   Task-20240715_194625_00000_23mm5.0.0.0-208      io.trino.execution.executor.TaskExecutor        Task finished or failed 20240715_194625_00000_23mm5.0.0.0
   2024-07-15 12:46:27 2024-07-15T19:46:27.448Z    DEBUG   dispatcher-query-0      io.trino.execution.StageStateMachine    Stage 20240715_194625_00000_23mm5.0 is PENDING
   2024-07-15 12:46:27 2024-07-15T19:46:27.448Z    DEBUG   stage-scheduler io.trino.execution.scheduler.PipelinedStageExecution    Pipelined stage execution 20240715_194625_00000_23mm5.0 is FINISHED
   2024-07-15 12:46:27 2024-07-15T19:46:27.448Z    DEBUG   dispatcher-query-0      io.trino.execution.StageStateMachine    Stage 20240715_194625_00000_23mm5.0 is FINISHED
   2024-07-15 12:46:27 2024-07-15T19:46:27.449Z    DEBUG   dispatcher-query-0      io.trino.execution.QueryStateMachine    Query 20240715_194625_00000_23mm5 is FINISHING
   2024-07-15 12:46:27 2024-07-15T19:46:27.455Z    DEBUG   dispatcher-query-0      io.trino.execution.QueryStateMachine    Query 20240715_194625_00000_23mm5 is FINISHED
   2024-07-15 12:46:27 2024-07-15T19:46:27.466Z    INFO    dispatcher-query-4      io.trino.event.QueryMonitor     TIMELINE: Query 20240715_194625_00000_23mm5 :: FINISHED :: elapsed 1710ms :: planning 803ms :: waiting 607ms :: scheduling 887ms :: running 8ms :: finishing 12ms :: begin 2024-07-15T19:46:25.745Z :: end 2024-07-15T19:46:27.455Z
   ```


-- 
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: commits-unsubscribe@xtable.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org