jjtjiang commented on issue #5777:
URL: https://github.com/apache/hudi/issues/5777#issuecomment-1152188149
> what
sql : elect
_hoodie_commit_time,_hoodie_commit_seqno,_hoodie_record_key,_hoodie_partition_path,_hoodie_file_name
from hudi_trips_snapshot where order_no=128920931 and order_type=1
|_hoodie_commit_time| _hoodie_commit_seqno|
_hoodie_record_key|_hoodie_partition_path|
_hoodie_file_name|
+-------------------+---------------------------+-------------------------------+----------------------+---------------------------------------------------------------------------------+
|
20220602081230746|20220602081230746_81_327042|order_no:128920931,order_type:1|
2022-02|
1a02bc31-cb63-4d7d-af81-b34eae295eef-0|
|
20220602081230746|20220602081230746_81_327042|order_no:128920931,order_type:1|
2022-02|
1a02bc31-cb63-4d7d-af81-b34eae295eef-0|
|
20220602081230746|20220602081230746_81_327042|order_no:128920931,order_type:1|
2022-02|
1a02bc31-cb63-4d7d-af81-b34eae295eef-0|
|
20220602081230746|20220602081230746_81_327042|order_no:128920931,order_type:1|
2022-02|
1a02bc31-cb63-4d7d-af81-b34eae295eef-0|
|
20220602081230746|20220602081230746_81_327042|order_no:128920931,order_type:1|
2022-02|
1a02bc31-cb63-4d7d-af81-b34eae295eef-0|
|
20220602081230746|20220602081230746_81_327042|order_no:128920931,order_type:1|
2022-02|
1a02bc31-cb63-4d7d-af81-b34eae295eef-0|
|
20220602081230746|20220602081230746_81_327042|order_no:128920931,order_type:1|
2022-02|
1a02bc31-cb63-4d7d-af81-b34eae295eef-0|
|
20220602081230746|20220602081230746_81_327042|order_no:128920931,order_type:1|
2022-02|
1a02bc31-cb63-4d7d-af81-b34eae295eef-0|
|
20220602081230746|20220602081230746_81_327042|order_no:128920931,order_type:1|
2022-02|
1a02bc31-cb63-4d7d-af81-b34eae295eef-0|
|
20220602081230746|20220602081230746_81_327042|order_no:128920931,order_type:1|
2022-02|
1a02bc31-cb63-4d7d-af81-b34eae295eef-0|
|
20220602081230746|20220602081230746_73_326908|order_no:128920931,order_type:1|
2022-02|
81653f9b-e473-49cb-b741-3f5e5b6149c9-0|
|
20220602081230746|20220602081230746_79_727509|order_no:128920931,order_type:1|
2022-02|9a4700d8-1f27-47dc-98f9-f26bc8259ece-0_79-33673-2654041_20220602081230746.parquet|
|
20220602081230746|20220602081230746_61_326739|order_no:128920931,order_type:1|
2022-02|
98e64140-374e-4d6b-939a-c0479174402d-0|
|
20220602081230746|20220602081230746_74_326931|order_no:128920931,order_type:1|
2022-02|
c724dbb4-823e-4744-963a-e77d5993f0e3-0|
|
20220602081230746|20220602081230746_87_327208|order_no:128920931,order_type:1|
2022-02|
e6486128-d1bd-4502-93bf-a2a62487b57a-0|
|
20220602081230746|20220602081230746_69_326841|order_no:128920931,order_type:1|
2022-02|
6557dd29-8e3f-476e-ad2c-048cebb2de67-0|
|
20220602081230746|20220602081230746_80_327039|order_no:128920931,order_type:1|
2022-02|
3dcbebeb-0f0f-4909-a6be-99f818158dfd-0|
|
20220602081230746|20220602081230746_75_326962|order_no:128920931,order_type:1|
2022-02|
bf3af60a-6405-4792-a8ff-d1c824011fa4-0|
|
20220602081230746|20220602081230746_77_327009|order_no:128920931,order_type:1|
2022-02|
e8345f22-da0e-4b5e-b99e-a32bdd939089-0|
|
20220602081230746|20220602081230746_84_327110|order_no:128920931,order_type:1|
2022-02|
c4723a41-d3fd-405d-9f09-ac97d77f5f9c-0|
|
20220602081230746|20220602081230746_86_327167|order_no:128920931,order_type:1|
2022-02|
8fa2c068-5e63-492c-936e-44784384514d-0|
+-------------------+---------------------------+-------------------------------+----------------------+---------------------------------------------------------------------------------+
I'll try to reproduce it later.
ddl: CREATE TABLE `temp_db`.`hudi_solution_order_header_20220520` (\n
`_hoodie_commit_time` STRING,\n `_hoodie_commit_seqno` STRING,\n
`_hoodie_record_key` STRING,\n `_hoodie_partition_path` STRING,\n
`_hoodie_file_name` STRING,\n `_hoodie_is_deleted` BOOLEAN,\n
`trigger_cdc_action` STRING,\n `order_type` INT,\n `order_no` INT,\n
`u_version` STRING,\n `from_acct_no` INT,\n `from_loc_no` INT,\n
`from_contact_no` INT,\n `from_dept_no` INT,\n `from_inv_type` INT,\n
`to_acct_no` INT,\n `to_loc_no` INT,\n `to_contact_no` INT,\n `to_dept_no`
INT,\n `to_inv_type` INT,\n `ship_to_name` STRING,\n `ship_to_addr`
STRING,\n `ship_to_po_box` STRING,\n `ship_to_city` STRING,\n
`ship_to_state` STRING,\n `ship_to_country` STRING,\n `ship_to_zip` STRING,\n
`account_rep` INT,\n `mt_expense_code` STRING,\n `int_ref_no` INT,\n
`int_ref_type` INT,\n `ext_ref` STRING,\n `issue_date` TIMESTAMP,\n
`credit_rel_date` TIMESTAMP,\n `pick_date` TIMESTAMP,\n `manifest_date`
TIMESTAMP,\n `ship_date` TIMESTAMP,\n `invoice_date` TIMESTAMP,\n
`posting_date` TIMESTAMP,\n `expected_date` TIMESTAMP,\n `receiving_date`
TIMESTAMP,\n `closed_date` TIMESTAMP,\n `printed_date` TIMESTAMP,\n
`delete_date` TIMESTAMP,\n `terms_no` STRING,\n `carrier_no` INT,\n
`ship_method` STRING,\n `freight` STRING,\n `resale` STRING,\n `sales_terr`
INT,\n `credit_rel_code` STRING,\n `it_cost_code` INT,\n `sales_tax`
DECIMAL(20,8),\n `entry_datetime` TIMESTAMP,\n `entry_id` INT,\n
`total_order` DECIMAL(20,8),\n `total_cost` DECIMAL(20,8),\n `sales_total`
DECIMAL(20,8),\n `head_exp_total` DECIMAL(20,8),\n `sales_rel_date`
TIMESTAMP,\n `delete_id` INT,\n `detail_exp_total` DECIMAL(20,8),\n
`rma_disp_type` STRING,\n `repick_id` INT,\n `repick_counter` INT,\n
`invoice_id` INT,\n `invoice_counter` INT,\n `total_weight` DECIMAL(20,8),\n
`hold_date` TIMESTAMP,\n `hold_id` INT,\n `drop_ship` STRING,\n
`detail_price_total` DECIMAL(20,8),\n `ship_to_loc` I
NT,\n `ship_to_loc_change` INT,\n `q_userid` INT,\n `label_printed`
STRING,\n `label_date` TIMESTAMP,\n `dist_exp_date` TIMESTAMP,\n
`prod_exp_date` TIMESTAMP,\n `bol_date` TIMESTAMP,\n `bol_printed` STRING,\n
`qc_date` TIMESTAMP,\n `schedule_date` TIMESTAMP,\n `approval` STRING,\n
`fx_total_order` DECIMAL(20,8),\n `fx_total_cost` DECIMAL(20,8),\n
`fx_sales_total` DECIMAL(20,8),\n `fx_head_exp_total` DECIMAL(20,8),\n
`fx_detail_exp_total` DECIMAL(20,8),\n `fx_detail_price_total`
DECIMAL(20,8),\n `h_version` INT,\n `profile_special_handle` STRING,\n
`fx_currency` STRING,\n `company_no` INT,\n `trigger_entry_datetime`
TIMESTAMP,\n `cdc_system_time_long` BIGINT,\n `kafka_time_long` BIGINT,\n
`process_time_long` BIGINT,\n `date_flag` STRING)\nUSING hudi\nOPTIONS (\n
`hoodie.query.as.ro.table` \true\)\nPARTITIONED BY (date_flag)\nLOCATION
\\warehouse\tablespace\managed\hive\temp_db.db\hudi_solution_order_header_20220520\\nTBLPROPERTIES
(\n \bucketing_version\
= \2\,\n \last_modified_time\ = \1653531205\,\n \last_modified_by\ =
\itjulianj\,\n \last_commit_time_sync\ = \20220605080937159\)\n
thanks
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
