Skip to content

Conversation

@kaka11chen
Copy link
Contributor

Proposed changes

[Fix] (multi-catalog) Fix not throw error when call close() in hive/iceberg writer.

When the file writer closes(), it will sync buffer to commit. Therefore, sometimes data is written only when close() is called, which can expose some errors. For example, hdfs_file_writer. Therefore, this error needs to be captured in the entire close process.

@doris-robot
Copy link

Thank you for your contribution to Apache Doris.
Don't know what should be done next? See How to process your PR

Since 2024-03-18, the Document has been moved to doris-website.
See Doris Document.

@kaka11chen
Copy link
Contributor Author

run buildall

@github-actions
Copy link
Contributor

github-actions bot commented Aug 6, 2024

clang-tidy review says "All clean, LGTM! 👍"

@doris-robot
Copy link

TPC-H: Total hot run time: 41597 ms
machine: 'aliyun_ecs.c7a.8xlarge_32C64G'
scripts: https://github.com/apache/doris/tree/master/tools/tpch-tools
Tpch sf100 test result on commit 0abae9314b60fcf369a3e8e03bda094a4bde77fb, data reload: false

------ Round 1 ----------------------------------
q1	17619	4069	4101	4069
q2	2023	201	195	195
q3	10464	1276	1286	1276
q4	11183	864	927	864
q5	8070	2930	3004	2930
q6	223	144	144	144
q7	1077	644	635	635
q8	10623	1892	1975	1892
q9	8496	6576	6647	6576
q10	8671	3837	3841	3837
q11	435	255	256	255
q12	406	227	225	225
q13	17761	2938	2917	2917
q14	267	245	251	245
q15	534	479	489	479
q16	523	394	391	391
q17	957	921	925	921
q18	8006	7275	7230	7230
q19	1387	1228	1214	1214
q20	568	317	341	317
q21	5384	4788	4691	4691
q22	368	297	294	294
Total cold run time: 115045 ms
Total hot run time: 41597 ms

----- Round 2, with runtime_filter_mode=off -----
q1	4012	4008	3999	3999
q2	323	225	216	216
q3	3025	3006	3004	3004
q4	1870	1849	1830	1830
q5	5236	5223	5217	5217
q6	217	129	132	129
q7	2072	1703	1713	1703
q8	3186	3249	3256	3249
q9	8309	8288	8260	8260
q10	3723	3847	3828	3828
q11	549	466	452	452
q12	735	535	548	535
q13	13649	2968	2943	2943
q14	284	253	249	249
q15	525	476	487	476
q16	436	395	420	395
q17	1723	1714	1700	1700
q18	7823	7279	7215	7215
q19	1670	1681	1678	1678
q20	1962	1747	1755	1747
q21	5416	5135	5331	5135
q22	536	470	452	452
Total cold run time: 67281 ms
Total hot run time: 54412 ms

@doris-robot
Copy link

TPC-DS: Total hot run time: 169562 ms
machine: 'aliyun_ecs.c7a.8xlarge_32C64G'
scripts: https://github.com/apache/doris/tree/master/tools/tpcds-tools
TPC-DS sf100 test result on commit 0abae9314b60fcf369a3e8e03bda094a4bde77fb, data reload: false

query1	912	380	369	369
query2	6489	1724	1767	1724
query3	6661	211	223	211
query4	20179	17546	17496	17496
query5	4330	521	534	521
query6	274	175	168	168
query7	4608	308	304	304
query8	263	202	202	202
query9	8545	2384	2376	2376
query10	432	290	277	277
query11	10558	9981	9900	9900
query12	141	89	89	89
query13	1623	374	383	374
query14	9888	7236	7025	7025
query15	214	176	170	170
query16	7115	485	432	432
query17	946	581	566	566
query18	1918	292	291	291
query19	206	149	149	149
query20	94	93	86	86
query21	209	104	101	101
query22	4028	3924	3930	3924
query23	33857	32996	33040	32996
query24	10373	3136	3075	3075
query25	710	410	404	404
query26	1772	158	162	158
query27	2880	277	286	277
query28	6873	1987	1975	1975
query29	1346	441	433	433
query30	285	157	153	153
query31	959	766	780	766
query32	108	57	57	57
query33	718	336	331	331
query34	917	497	495	495
query35	853	742	734	734
query36	1040	868	873	868
query37	299	92	82	82
query38	2908	2792	2797	2792
query39	876	843	824	824
query40	287	117	115	115
query41	52	49	47	47
query42	123	101	107	101
query43	462	416	438	416
query44	1206	728	732	728
query45	207	180	183	180
query46	1090	837	808	808
query47	1825	1711	1736	1711
query48	367	303	295	295
query49	1203	461	450	450
query50	899	447	451	447
query51	6909	6790	6720	6720
query52	102	95	94	94
query53	265	188	187	187
query54	638	464	459	459
query55	79	81	78	78
query56	300	288	282	282
query57	1177	1034	1065	1034
query58	274	267	288	267
query59	2600	2499	2379	2379
query60	306	299	290	290
query61	122	115	222	115
query62	900	671	671	671
query63	219	192	186	186
query64	5905	1922	1872	1872
query65	3195	3096	3133	3096
query66	1441	333	361	333
query67	15315	14892	14701	14701
query68	6746	570	594	570
query69	716	382	324	324
query70	1160	1086	1058	1058
query71	567	281	281	281
query72	8164	2696	2517	2517
query73	957	328	329	328
query74	6058	5634	5646	5634
query75	4602	2738	2723	2723
query76	4740	1261	1280	1261
query77	775	313	367	313
query78	9512	9000	8983	8983
query79	2719	535	544	535
query80	922	520	508	508
query81	564	228	228	228
query82	739	134	130	130
query83	331	166	178	166
query84	270	81	81	81
query85	1514	320	306	306
query86	444	308	287	287
query87	3329	3066	3047	3047
query88	3660	2445	2410	2410
query89	410	290	300	290
query90	2048	191	197	191
query91	133	106	105	105
query92	71	51	55	51
query93	3713	606	609	606
query94	948	300	294	294
query95	374	271	271	271
query96	615	280	288	280
query97	3245	3062	3080	3062
query98	224	204	211	204
query99	1634	1312	1281	1281
Total cold run time: 275779 ms
Total hot run time: 169562 ms

@doris-robot
Copy link

ClickBench: Total hot run time: 30.17 s
machine: 'aliyun_ecs.c7a.8xlarge_32C64G'
scripts: https://github.com/apache/doris/tree/master/tools/clickbench-tools
ClickBench test result on commit 0abae9314b60fcf369a3e8e03bda094a4bde77fb, data reload: false

query1	0.05	0.05	0.04
query2	0.07	0.04	0.04
query3	0.23	0.04	0.04
query4	1.69	0.06	0.06
query5	0.49	0.49	0.48
query6	1.13	0.71	0.71
query7	0.02	0.01	0.01
query8	0.05	0.04	0.04
query9	0.56	0.50	0.49
query10	0.57	0.56	0.56
query11	0.15	0.11	0.12
query12	0.14	0.12	0.13
query13	0.60	0.61	0.59
query14	0.77	0.79	0.80
query15	0.90	0.84	0.87
query16	0.35	0.36	0.35
query17	1.01	0.99	0.99
query18	0.26	0.21	0.21
query19	1.84	1.75	1.79
query20	0.01	0.01	0.02
query21	15.43	0.76	0.65
query22	3.95	7.54	1.70
query23	17.86	1.23	1.14
query24	2.13	0.23	0.23
query25	0.18	0.08	0.08
query26	0.32	0.22	0.21
query27	0.46	0.24	0.23
query28	13.15	1.00	0.97
query29	12.50	3.32	3.29
query30	0.26	0.05	0.05
query31	2.88	0.40	0.41
query32	3.25	0.48	0.48
query33	2.91	2.92	2.95
query34	15.44	4.25	4.24
query35	4.26	4.27	4.28
query36	0.68	0.49	0.48
query37	0.19	0.17	0.16
query38	0.17	0.15	0.15
query39	0.05	0.04	0.04
query40	0.16	0.13	0.12
query41	0.10	0.05	0.05
query42	0.05	0.05	0.05
query43	0.05	0.04	0.03
Total cold run time: 107.32 s
Total hot run time: 30.17 s

Copy link
Contributor

@morningman morningman left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

LGTM

@github-actions
Copy link
Contributor

github-actions bot commented Aug 7, 2024

PR approved by at least one committer and no changes requested.

@github-actions github-actions bot added approved Indicates a PR has been approved by one committer. reviewed labels Aug 7, 2024
@github-actions
Copy link
Contributor

github-actions bot commented Aug 7, 2024

PR approved by anyone and no changes requested.

Copy link
Contributor

@wuwenchi wuwenchi left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

LGTM

Copy link
Contributor

@morningman morningman left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

LGTM

@morningman morningman merged commit 269fc7b into apache:master Aug 11, 2024
dataroaring pushed a commit that referenced this pull request Aug 12, 2024
…eberg writer. (#38987)

## Proposed changes

[Fix] (multi-catalog) Fix not throw error when call close() in
hive/iceberg writer.

When the file writer closes(), it will sync buffer to commit. Therefore,
sometimes data is written only when close() is called, which can expose
some errors. For example, hdfs_file_writer. Therefore, this error needs
to be captured in the entire close process.
wyxxxcat pushed a commit to wyxxxcat/doris that referenced this pull request Aug 14, 2024
…eberg writer. (apache#38987)

## Proposed changes

[Fix] (multi-catalog) Fix not throw error when call close() in
hive/iceberg writer.

When the file writer closes(), it will sync buffer to commit. Therefore,
sometimes data is written only when close() is called, which can expose
some errors. For example, hdfs_file_writer. Therefore, this error needs
to be captured in the entire close process.
dataroaring pushed a commit that referenced this pull request Aug 16, 2024
…eberg writer. (#38987)

## Proposed changes

[Fix] (multi-catalog) Fix not throw error when call close() in
hive/iceberg writer.

When the file writer closes(), it will sync buffer to commit. Therefore,
sometimes data is written only when close() is called, which can expose
some errors. For example, hdfs_file_writer. Therefore, this error needs
to be captured in the entire close process.
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

approved Indicates a PR has been approved by one committer. dev/2.1.6-merged dev/3.0.2-merged doing reviewed

Projects

None yet

Development

Successfully merging this pull request may close these issues.

5 participants