| stream-10000001651-1 |
FINISHED |
470da58e-3bf0-43e9-92f9-208c55e721e2 |
6ced03eb-c046-4d38-8b3d-6156b8f3929b |
2026/06/09 15:47:03 |
8 minutes 36 seconds |
6.73 |
2.38 |
10 |
- |
| stream-10000001635-1 |
FINISHED |
aa853f2f-f4b9-48cb-a48e-bb90c0127670 |
bd6be9bf-b906-4b53-b63f-d8e4b28ab437 |
2026/06/09 09:41:01 |
24 minutes 3 seconds |
22.42 |
6.74 |
35 |
- |
| stream-10000001634-1 |
FINISHED |
e697e62f-c961-4f16-9d2e-fbc2fdd1fb6e |
c725e476-5321-4975-92a9-8157512a6033 |
2026/06/09 09:41:01 |
19 minutes 18 seconds |
36.94 |
8.68 |
16 |
- |
| stream-10000000861-1 |
FINISHED |
ffe0818d-55fb-4537-8d6f-c7ead28bacf3 |
c36a5190-01f7-4593-98c1-ef4f7a25cf7b |
2026/06/09 09:39:51 |
25 minutes 13 seconds |
7.80 |
2.29 |
39 |
- |
| stream-10000000860-1 |
FINISHED |
952dbbf0-88f1-4f34-bb1d-310822c76a22 |
e89e6ba0-df32-43e2-ba19-a47fca5bc15c |
2026/06/09 09:33:29 |
1 hour 39 minutes 15 seconds |
24.86 |
7.87 |
171 |
- |
| stream-10000000859-1 |
FINISHED |
f6eebefe-8ef4-44fd-8478-6b21b4f93245 |
60498d86-c0c2-47f8-981c-a3fc9b781efb |
2026/06/09 09:31:15 |
1 hour 17 minutes 54 seconds |
22.14 |
6.85 |
98 |
- |
| stream-10000000858-1 |
FINISHED |
9ec16343-d80f-4a18-af65-ac30bae5fe00 |
8bbc13f5-e368-4482-9853-85dee529fda4 |
2026/06/09 08:53:29 |
14 minutes 40 seconds |
1.91 |
0.75 |
25 |
- |
| stream-10000001630-1 |
FINISHED |
50672663-3e6c-4cf2-a266-23e2a5dabebe |
d05031ff-d8cd-421f-b697-68f43728ece2 |
2026/06/09 08:10:29 |
20 minutes 30 seconds |
23.20 |
9.57 |
42 |
- |
| stream-10000000856-1 |
FINISHED |
6616dd22-900b-4cf8-a1b2-e756a29f8fb2 |
3f2d79f4-5724-4a01-8f85-6295e752b758 |
2026/06/09 07:07:05 |
26 minutes 14 seconds |
58.03 |
20.25 |
49 |
- |
| stream-10000000855-1 |
FINISHED |
5802b18c-a77b-462e-8cfd-821cbd82fb1e |
43b06251-45aa-4ea2-8374-da864fdc333b |
2026/06/09 06:29:25 |
34 minutes 54 seconds |
53.27 |
14.90 |
49 |
- |
| stream-10000000854-1 |
FINISHED |
68c8c636-5929-4368-8f87-d6a13193f563 |
9b44b844-3c22-4f38-a986-0c8cbea09e4b |
2026/06/09 06:25:29 |
41 minutes 5 seconds |
6.67 |
1.82 |
60 |
- |
| stream-10000000853-1 |
FINISHED |
50449fa1-d2eb-45ad-96c2-5000394fd435 |
0f8d1ca5-3911-4a72-809b-ecfdeac47ab5 |
2026/06/09 06:19:37 |
44 minutes 52 seconds |
6.55 |
1.50 |
66 |
- |
| stream-10000001626-1 |
FINISHED |
f3c92080-2bc4-41df-a8aa-ff976c0ba360 |
0c841b63-3d10-49b2-b736-5be4602e7988 |
2026/06/09 05:37:05 |
25 minutes 59 seconds |
24.61 |
8.90 |
50 |
- |
| stream-10000000852-1 |
FINISHED |
33997b83-2aa2-4335-a71e-0b8759a52f64 |
2c4b89fd-a5a6-4f3d-8c97-0f790a51257a |
2026/06/09 04:46:15 |
35 minutes 29 seconds |
52.29 |
15.60 |
62 |
- |
| stream-10000001624-1 |
FINISHED |
a00d9a3b-965e-4b62-b324-c23ee6ff6042 |
2a626ad7-a25a-49d3-8063-4d1fc205d758 |
2026/06/09 04:32:57 |
5 minutes 22 seconds |
3.34 |
1.15 |
6 |
- |
| stream-10000001623-1 |
FINISHED |
f335c346-8caa-4d2c-8637-a626c7e35cab |
38516d32-68f2-46d0-93df-64634b06f41b |
2026/06/09 03:46:22 |
3 minutes 17 seconds |
26.53 |
8.26 |
2 |
- |
| stream-10000000851-1 |
FINISHED |
7b8fe1e1-1f9b-4793-99aa-e23a9050ba1f |
468ec10c-4d42-4538-bc2b-d8a6c5e1c0fc |
2026/06/09 03:35:15 |
26 minutes 39 seconds |
9.28 |
3.47 |
49 |
- |
| stream-10000000850-1 |
FINISHED |
637a2296-96a0-4613-a734-70d8749f425e |
5e41837e-c00e-4292-b7ab-0985be34be79 |
2026/06/09 03:07:03 |
18 minutes 46 seconds |
29.76 |
11.70 |
33 |
- |
| stream-10000001622-1 |
FINISHED |
78ed4307-249d-4caf-b8d7-87d354a38b16 |
ce0dbb5c-1984-4e0c-8a36-0a523e9fa92d |
2026/06/09 01:56:08 |
5 minutes 46 seconds |
3.94 |
1.46 |
6 |
- |
| stream-10000001621-1 |
FINISHED |
26059a99-ac16-4abf-ba20-7974f13648e1 |
c8c96a70-7fff-4a03-b719-3fed94279629 |
2026/06/09 00:05:51 |
6 minutes 3 seconds |
8.91 |
3.28 |
6 |
- |
| stream-10000000849-1 |
FINISHED |
a4a606b7-6277-4891-b1c4-cb423f6bd752 |
1ed2649b-efcb-4866-a955-9388229c72f0 |
2026/06/08 23:37:10 |
25 minutes 19 seconds |
55.22 |
19.28 |
49 |
- |
| stream-10000001618-1 |
FINISHED |
7cd075fd-a521-4940-b0c7-f8ee17be057a |
1383ede7-2d3f-4323-b1da-cebef35ea67f |
2026/06/08 19:49:00 |
2 minutes 54 seconds |
26.53 |
9.65 |
2 |
- |
| stream-10000001617-1 |
FINISHED |
3756e426-568c-4d55-a4af-46750d98125a |
b0b31e91-6b55-4317-8539-13b21e1f89cc |
2026/06/08 19:33:16 |
11 minutes 28 seconds |
36.74 |
12.51 |
12 |
- |
| stream-10000001616-1 |
FINISHED |
29267944-2e68-4d98-97ae-7404755a4ff4 |
24502c57-df58-413c-80d1-65da70db6d45 |
2026/06/08 19:17:47 |
11 minutes 27 seconds |
36.74 |
12.55 |
12 |
- |
| stream-10000001614-1 |
FINISHED |
7353c588-a76f-4e6f-bbf7-f09aec70199f |
665334a3-2649-4b0d-a594-064293aef275 |
2026/06/08 16:03:59 |
10 minutes 30 seconds |
1.75 |
0.62 |
12 |
- |
| stream-10000001613-1 |
FINISHED |
09238855-12fd-4b26-8568-e2ca28d5ded7 |
70e9a09e-9846-4328-9372-62d85d67b52e |
2026/06/08 15:57:50 |
9 minutes 24 seconds |
6.73 |
2.25 |
10 |
- |
| stream-10000001612-1 |
FINISHED |
ca9b8f4d-059e-4859-b77b-5ba1f300275b |
8568def7-d657-41fc-a18c-bc761de90e49 |
2026/06/08 15:16:45 |
6 minutes 14 seconds |
6.34 |
2.19 |
6 |
- |
| stream-10000000847-1 |
FINISHED |
9ad74e6c-1fba-4717-a094-b66f3733ddff |
010dd135-913c-4bf2-bc6a-39a2f4b86247 |
2026/06/08 14:49:56 |
6 minutes 43 seconds |
1.00 |
0.40 |
5 |
- |
| stream-10000000846-1 |
FINISHED |
4c997237-f645-43b6-813c-453acd3799d3 |
d93ea2bf-7866-4cb6-a130-0f8487aaa7dd |
2026/06/08 14:25:10 |
19 minutes 19 seconds |
4.81 |
1.45 |
26 |
- |
| stream-10000000845-1 |
FINISHED |
0a7026f3-d88c-4215-b923-154c19fc80b5 |
25f1d461-bc1c-459c-aaa1-93c95df2c294 |
2026/06/08 13:58:03 |
14 minutes 26 seconds |
1.80 |
0.71 |
25 |
- |
| stream-10000000843-1 |
FINISHED |
d13e2593-355c-4273-a4a5-881a749c728f |
556dc8c3-ee3f-4e95-8eef-2838e524cc7c |
2026/06/08 13:46:47 |
15 minutes 37 seconds |
57.58 |
21.18 |
25 |
- |
| stream-10000001608-1 |
FINISHED |
425fa685-19d7-439c-bbb2-22e0facfd007 |
d717ff3f-da59-4d2b-b344-cc6cdb266c95 |
2026/06/08 11:33:28 |
10 minutes 11 seconds |
3.18 |
1.01 |
10 |
- |
| stream-10000000842-1 |
FINISHED |
97847ba1-ab72-4e8d-a925-030f6b1f2b04 |
04c11137-d0b6-497e-90dc-70bba0db3b3f |
2026/06/08 11:11:26 |
6 minutes 8 seconds |
0.43 |
0.11 |
3 |
- |
| stream-10000001607-1 |
FINISHED |
42cf88a0-5c34-40af-b363-6428f80d408d |
e7ceb6fb-2a9e-4506-ad2d-dae56aa781c8 |
2026/06/08 11:07:26 |
17 minutes 43 seconds |
1.22 |
0.31 |
14 |
- |
| stream-10000001605-1 |
FINISHED |
6a35a768-abac-4b17-b109-1d8789138d97 |
91609239-7ca9-4c46-8d9f-655d81bec910 |
2026/06/08 11:00:10 |
24 minutes 4 seconds |
36.58 |
8.28 |
14 |
- |
| stream-10000000840-1 |
FINISHED |
baa37ca2-644d-4730-bfea-f89bf01abead |
b85d59ea-4a37-43a2-a6b9-d314f8c70dc4 |
2026/06/08 09:55:52 |
2 hours 16 minutes 52 seconds |
24.78 |
4.75 |
171 |
- |
| stream-10000000839-1 |
FINISHED |
29546718-0d8b-467a-9077-f32da0804834 |
34e3a2cc-2c18-4d2d-944b-6b3aaab7c1a4 |
2026/06/08 09:53:39 |
1 hour 10 minutes 20 seconds |
22.76 |
5.15 |
94 |
- |
| stream-10000001602-1 |
FINISHED |
0b319bc0-1099-45a9-8968-bbe5650eee57 |
fd713bd4-cb40-4d3a-b820-a6c8215b78a7 |
2026/06/08 09:50:47 |
26 minutes 44 seconds |
43.83 |
9.71 |
16 |
- |
| stream-10000001603-1 |
FINISHED |
32b1d9a9-af02-4712-b455-6ae4d488fbe8 |
4181fa21-6df9-4661-990d-8f7a3512c599 |
2026/06/08 09:50:38 |
26 minutes 21 seconds |
29.91 |
8.68 |
30 |
- |
| stream-10000000841-1 |
FINISHED |
770511e8-3404-4e4c-a88a-1a9df09957b5 |
8b47d01d-f111-4547-8f0f-b30176e64acf |
2026/06/08 09:42:40 |
26 minutes 14 seconds |
7.33 |
2.47 |
38 |
- |
| stream-10000000838-1 |
FINISHED |
6647f44e-9db5-49e2-adab-6c23ed5f039c |
6d985f93-813f-4898-98b0-5a378d3fd54a |
2026/06/08 08:51:52 |
11 minutes 7 seconds |
1.94 |
0.92 |
23 |
- |
| stream-10000001598-1 |
FINISHED |
0642d360-25f0-4bf2-ad17-ddd3d4d69b96 |
7490d00b-bee0-4146-a5a1-2c66cf03d3ae |
2026/06/08 08:12:37 |
22 minutes 22 seconds |
21.81 |
8.02 |
44 |
- |
| stream-10000000836-1 |
FINISHED |
eedfec57-a08a-4bb7-8ac7-2339fba8d278 |
78993a0e-802d-4665-b86f-65b723ca3143 |
2026/06/08 07:07:28 |
25 minutes 21 seconds |
56.11 |
20.66 |
49 |
- |
| stream-10000000835-1 |
FINISHED |
1e4c68fe-43fa-4161-88df-05b275514b2b |
05596a15-0fea-4338-b324-458c45815f85 |
2026/06/08 06:28:23 |
30 minutes 16 seconds |
51.94 |
15.87 |
49 |
- |
| stream-10000000834-1 |
FINISHED |
82c7b8ac-be50-4da6-8a7e-73308ab9262d |
36dbf969-19c3-4585-9d1d-6208ca1ef209 |
2026/06/08 06:25:38 |
34 minutes 46 seconds |
7.82 |
2.25 |
60 |
- |
| stream-10000000833-1 |
FINISHED |
564db8b4-b265-4f86-944e-20b5742ecd18 |
b12722cb-6ee8-420c-82b4-9d6c0d81d15e |
2026/06/08 06:19:50 |
37 minutes 59 seconds |
5.76 |
1.55 |
66 |
- |
| stream-10000001594-1 |
FINISHED |
08209f05-e241-48c0-b5ef-11512ef2d49a |
fd5ac18b-786b-49cc-a834-c60dd29424ae |
2026/06/08 05:37:52 |
25 minutes 52 seconds |
19.57 |
6.67 |
54 |
- |
| stream-10000000832-1 |
FINISHED |
849b124a-153e-46f7-afa9-1d1162a9ad93 |
4b4497ad-de0e-4397-83e1-93e24c4d90fe |
2026/06/08 05:02:34 |
30 minutes 10 seconds |
50.73 |
18.32 |
62 |
- |
| stream-10000001592-1 |
FINISHED |
209ab914-c57d-46ab-b1f6-baf9cc03849a |
c412964b-7cf2-4cf1-89df-4ff68bf68b80 |
2026/06/08 04:33:03 |
5 minutes 1 second |
3.34 |
1.32 |
6 |
- |
| stream-10000001591-1 |
FINISHED |
3a9b460c-dd7f-4543-8864-e33a38738ef6 |
c1a2a38a-e82f-4231-971b-1c10767acace |
2026/06/08 03:46:07 |
3 minutes 17 seconds |
26.53 |
8.33 |
2 |
- |
| stream-10000000831-1 |
FINISHED |
e1ebcdb5-35e7-4081-af8c-b52e3fedac39 |
f1d9230f-92af-459c-a85b-88b704ec71d0 |
2026/06/08 03:34:57 |
20 minutes 57 seconds |
9.13 |
4.01 |
49 |
- |
| stream-10000000830-1 |
FINISHED |
34ccc9f6-84f9-4cae-85d4-d7379debf239 |
bde551c0-b36d-448d-ba78-8480e2653022 |
2026/06/08 03:05:29 |
15 minutes 10 seconds |
28.67 |
12.15 |
31 |
- |
| stream-10000001590-1 |
FINISHED |
73718964-b16f-405c-b10a-bca8069b07d5 |
f8f783b1-dc35-4845-b2a5-47e66a417c1c |
2026/06/08 01:56:16 |
5 minutes 33 seconds |
3.94 |
1.52 |
6 |
- |
| stream-10000001589-1 |
FINISHED |
b43e08b8-802e-4576-ad6e-a8b2143395b0 |
e60e5746-a2fe-48cd-a5d3-89e2868f7acd |
2026/06/08 00:05:42 |
5 minutes 32 seconds |
8.98 |
3.33 |
6 |
- |
| stream-10000000829-1 |
FINISHED |
f37b0938-d86b-423c-b9e4-a2724695aa41 |
849a1d34-b0b7-4325-9b75-87d7e9558c72 |
2026/06/07 23:36:20 |
21 minutes 34 seconds |
53.42 |
21.76 |
49 |
- |
| stream-10000001586-1 |
FINISHED |
13b34c31-7b44-4c2d-afd5-5b3f9319760b |
767e32bf-ac17-4398-92c2-1c864d508aaf |
2026/06/07 19:48:52 |
2 minutes 42 seconds |
26.53 |
10.11 |
2 |
- |
| stream-10000001585-1 |
FINISHED |
f37072ac-d597-4e3f-a376-85c0482b86ad |
66c3e362-0bde-4d79-8f88-c5eb6624fd1e |
2026/06/07 19:33:19 |
10 minutes 10 seconds |
36.74 |
11.93 |
12 |
- |
| stream-10000001584-1 |
FINISHED |
83d6deba-5194-45c6-a25a-5dc4c4640ae3 |
ef676a62-aa93-4b95-91d5-517d3ca5c27d |
2026/06/07 19:17:56 |
10 minutes 33 seconds |
36.74 |
12.67 |
12 |
- |
| stream-10000001582-1 |
FINISHED |
e33ea07e-3311-4e5d-b933-597d0266767b |
5538290f-0635-4e06-a2af-7d6a09122b71 |
2026/06/07 16:03:06 |
9 minutes 53 seconds |
1.75 |
0.72 |
12 |
- |
| stream-10000001581-1 |
FINISHED |
0dfbc8db-2494-414b-980c-ab4d8fab9c9b |
d5a90827-4a71-4f14-b22b-3de636b17200 |
2026/06/07 15:57:31 |
9 minutes 13 seconds |
8.00 |
2.74 |
10 |
- |
| stream-10000001580-1 |
FINISHED |
f65d5d19-98fc-4879-8b28-59670bab6f04 |
579584db-303c-4b63-9c73-61ac1852be69 |
2026/06/07 15:16:01 |
6 minutes 3 seconds |
6.34 |
2.48 |
6 |
- |
| stream-10000000827-1 |
FINISHED |
4561a6f1-7dcf-4b63-8944-e26765e42ab2 |
eea56e93-315d-4657-9000-360a254c9492 |
2026/06/07 14:48:06 |
5 minutes 48 seconds |
1.00 |
0.38 |
5 |
- |
| stream-10000000826-1 |
FINISHED |
948aa91b-456a-4078-a8e2-951375916c3a |
2a026118-c64a-4194-a761-15cb1a542a3c |
2026/06/07 14:23:14 |
16 minutes 30 seconds |
4.81 |
1.97 |
26 |
- |
| stream-10000000825-1 |
FINISHED |
b513070a-f02e-452d-9480-398a08da7a77 |
047d6fcd-a2cc-4ead-b1d2-d88100c999f7 |
2026/06/07 13:56:18 |
12 minutes 51 seconds |
1.78 |
0.90 |
25 |
- |
| stream-10000000823-1 |
FINISHED |
ac2bb392-8351-47c9-99db-876434b8531b |
db09449c-04b3-4e0e-9cc1-e8583a54a977 |
2026/06/07 13:45:34 |
14 minutes 40 seconds |
59.10 |
25.18 |
25 |
- |
| stream-10000001576-1 |
FINISHED |
0f87bb7a-acec-470a-9a07-77f0b22a57fa |
03c1dcaa-6cd0-48b2-a4a6-96200570ee2a |
2026/06/07 11:31:59 |
9 minutes 15 seconds |
3.18 |
1.27 |
10 |
- |
| stream-10000000822-1 |
FINISHED |
a0d1b178-ac7e-4b3d-a981-39410128b574 |
99b7462e-340b-4786-a2d7-4c3efa478e3c |
2026/06/07 11:10:02 |
4 minutes 47 seconds |
0.30 |
0.12 |
3 |
- |
| stream-10000001575-1 |
FINISHED |
4e68fdc2-4123-4ec5-b7d0-fb94f0f6f06a |
61434d4d-b1f3-466c-8a39-e48d30954c0a |
2026/06/07 11:07:23 |
13 minutes 36 seconds |
1.21 |
0.45 |
14 |
- |
| stream-10000001573-1 |
FINISHED |
14b94446-a1fa-4d68-8a31-f417d7f5ed48 |
d996da3a-3ab2-41d2-8e3e-0f8dcdd1a90c |
2026/06/07 10:59:03 |
18 minutes 21 seconds |
36.16 |
10.18 |
14 |
- |
| stream-10000000820-1 |
FINISHED |
57997c6c-46dc-444d-8a2f-28483c95c3c7 |
e5d9e13f-9247-42ab-b1f0-804d310d1aae |
2026/06/07 10:32:54 |
58 minutes 3 seconds |
42.26 |
31.67 |
17 |
- |
| stream-10000000820-1 |
FAILED |
0da15a5d-9953-4ec5-8dbe-02788a2aa86e |
81e0d49a-6855-4f0e-acc0-ab3396c9f3e2 |
2026/06/07 09:46:49 |
45 minutes 25 seconds |
48.13 |
17.26 |
82 |
java.util.concurrent.ExecutionException: org.apache.spark.SparkException: Job aborted due to stage failure: Task serialization failed: java.lang.OutOfMemoryError: Java heap space
+details
java.util.concurrent.ExecutionException: org.apache.spark.SparkException: Job aborted due to stage failure: Task serialization failed: java.lang.OutOfMemoryError: Java heap space
java.lang.OutOfMemoryError: Java heap space
at java.base/java.nio.HeapByteBuffer.<init>(Unknown Source)
at java.base/java.nio.ByteBuffer.allocate(Unknown Source)
at org.apache.spark.broadcast.TorrentBroadcast$.$anonfun$blockifyObject$1(TorrentBroadcast.scala:364)
at org.apache.spark.broadcast.TorrentBroadcast$.$anonfun$blockifyObject$1$adapted(TorrentBroadcast.scala:364)
at org.apache.spark.broadcast.TorrentBroadcast$$$Lambda/0x000000080167df78.apply(Unknown Source)
at org.apache.spark.util.io.ChunkedByteBufferOutputStream.allocateNewChunkIfNeeded(ChunkedByteBufferOutputStream.scala:87)
at org.apache.spark.util.io.ChunkedByteBufferOutputStream.write(ChunkedByteBufferOutputStream.scala:75)
at net.jpountz.lz4.LZ4BlockOutputStream.flushBufferedData(LZ4BlockOutputStream.java:225)
at net.jpountz.lz4.LZ4BlockOutputStream.write(LZ4BlockOutputStream.java:178)
at com.esotericsoftware.kryo.io.Output.flush(Output.java:185)
at com.esotericsoftware.kryo.io.Output.close(Output.java:196)
at org.apache.spark.serializer.KryoSerializationStream.close(KryoSerializer.scala:297)
at org.apache.spark.broadcast.TorrentBroadcast$.$anonfun$blockifyObject$5(TorrentBroadcast.scala:371)
at org.apache.spark.broadcast.TorrentBroadcast$$$Lambda/0x00000008016fdfd8.apply$mcV$sp(Unknown Source)
at org.apache.spark.util.SparkErrorUtils.tryWithSafeFinally(SparkErrorUtils.scala:89)
at org.apache.spark.util.SparkErrorUtils.tryWithSafeFinally$(SparkErrorUtils.scala:77)
at org.apache.spark.util.Utils$.tryWithSafeFinally(Utils.scala:99)
at org.apache.spark.broadcast.TorrentBroadcast$.blockifyObject(TorrentBroadcast.scala:371)
at org.apache.spark.broadcast.TorrentBroadcast.writeBlocks(TorrentBroadcast.scala:162)
at org.apache.spark.broadcast.TorrentBroadcast.<init>(TorrentBroadcast.scala:100)
at org.apache.spark.broadcast.TorrentBroadcastFactory.newBroadcast(TorrentBroadcastFactory.scala:38)
at org.apache.spark.broadcast.BroadcastManager.newBroadcast(BroadcastManager.scala:78)
at org.apache.spark.SparkContext.broadcastInternal(SparkContext.scala:1728)
at org.apache.spark.SparkContext.broadcast(SparkContext.scala:1710)
at org.apache.spark.scheduler.DAGScheduler.submitMissingTasks(DAGScheduler.scala:1676)
at org.apache.spark.scheduler.DAGScheduler.submitStage(DAGScheduler.scala:1470)
at org.apache.spark.scheduler.DAGScheduler.handleJobSubmitted(DAGScheduler.scala:1400)
at org.apache.spark.scheduler.DAGSchedulerEventProcessLoop.doOnReceive(DAGScheduler.scala:3150)
at org.apache.spark.scheduler.DAGSchedulerEventProcessLoop.onReceive(DAGScheduler.scala:3141)
at org.apache.spark.scheduler.DAGSchedulerEventProcessLoop.onReceive(DAGScheduler.scala:3130)
at org.apache.spark.util.EventLoop$$anon$1.run(EventLoop.scala:50)
at java.base/java.util.concurrent.CompletableFuture.reportGet(Unknown Source)
at java.base/java.util.concurrent.CompletableFuture.get(Unknown Source)
at org.apache.spark.sql.execution.exchange.BroadcastExchangeExec.doExecuteBroadcast(BroadcastExchangeExec.scala:254)
at org.apache.spark.sql.execution.InputAdapter.doExecuteBroadcast(WholeStageCodegenExec.scala:523)
at org.apache.spark.sql.execution.SparkPlan.$anonfun$executeBroadcastBcast$1(SparkPlan.scala:205)
at scala.util.Try$.apply(Try.scala:217)
at org.apache.spark.util.Utils$.doTryWithCallerStacktrace(Utils.scala:1378)
at org.apache.spark.util.LazyTry.tryT$lzycompute(LazyTry.scala:46)
at org.apache.spark.util.LazyTry.tryT(LazyTry.scala:46)
at org.apache.spark.util.LazyTry.get(LazyTry.scala:58)
at org.apache.spark.sql.execution.SparkPlan.$anonfun$executeBroadcast$1(SparkPlan.scala:218)
at org.apache.spark.sql.execution.SparkPlan.$anonfun$executeQuery$1(SparkPlan.scala:260)
at org.apache.spark.rdd.RDDOperationScope$.withScope(RDDOperationScope.scala:151)
at org.apache.spark.sql.execution.SparkPlan.executeQuery(SparkPlan.scala:257)
at org.apache.spark.sql.execution.SparkPlan.executeBroadcast(SparkPlan.scala:214)
at org.apache.spark.sql.execution.joins.BroadcastHashJoinExec.prepareBroadcast(BroadcastHashJoinExec.scala:186)
at org.apache.spark.sql.execution.joins.BroadcastHashJoinExec.prepareRelation(BroadcastHashJoinExec.scala:200)
at org.apache.spark.sql.execution.joins.HashJoin.codegenInner(HashJoin.scala:396)
at org.apache.spark.sql.execution.joins.HashJoin.codegenInner$(HashJoin.scala:395)
at org.apache.spark.sql.execution.joins.BroadcastHashJoinExec.codegenInner(BroadcastHashJoinExec.scala:40)
at org.apache.spark.sql.execution.joins.HashJoin.doConsume(HashJoin.scala:362)
at org.apache.spark.sql.execution.joins.HashJoin.doConsume$(HashJoin.scala:360)
at org.apache.spark.sql.execution.joins.BroadcastHashJoinExec.doConsume(BroadcastHashJoinExec.scala:40)
at org.apache.spark.sql.execution.CodegenSupport.consume(WholeStageCodegenExec.scala:200)
at org.apache.spark.sql.execution.CodegenSupport.consume$(WholeStageCodegenExec.scala:153)
at org.apache.spark.sql.execution.InputAdapter.consume(WholeStageCodegenExec.scala:504)
at org.apache.spark.sql.execution.InputRDDCodegen.doProduce(WholeStageCodegenExec.scala:491)
at org.apache.spark.sql.execution.InputRDDCodegen.doProduce$(WholeStageCodegenExec.scala:464)
at org.apache.spark.sql.execution.InputAdapter.doProduce(WholeStageCodegenExec.scala:504)
at org.apache.spark.sql.execution.CodegenSupport.$anonfun$produce$1(WholeStageCodegenExec.scala:99)
at org.apache.spark.sql.execution.SparkPlan.$anonfun$executeQuery$1(SparkPlan.scala:260)
at org.apache.spark.rdd.RDDOperationScope$.withScope(RDDOperationScope.scala:151)
at org.apache.spark.sql.execution.SparkPlan.executeQuery(SparkPlan.scala:257)
at org.apache.spark.sql.execution.CodegenSupport.produce(WholeStageCodegenExec.scala:94)
at org.apache.spark.sql.execution.CodegenSupport.produce$(WholeStageCodegenExec.scala:94)
at org.apache.spark.sql.execution.InputAdapter.produce(WholeStageCodegenExec.scala:504)
at org.apache.spark.sql.execution.joins.HashJoin.doProduce(HashJoin.scala:357)
at org.apache.spark.sql.execution.joins.HashJoin.doProduce$(HashJoin.scala:356)
at org.apache.spark.sql.execution.joins.BroadcastHashJoinExec.doProduce(BroadcastHashJoinExec.scala:40)
at org.apache.spark.sql.execution.CodegenSupport.$anonfun$produce$1(WholeStageCodegenExec.scala:99)
at org.apache.spark.sql.execution.SparkPlan.$anonfun$executeQuery$1(SparkPlan.scala:260)
at org.apache.spark.rdd.RDDOperationScope$.withScope(RDDOperationScope.scala:151)
at org.apache.spark.sql.execution.SparkPlan.executeQuery(SparkPlan.scala:257)
at org.apache.spark.sql.execution.CodegenSupport.produce(WholeStageCodegenExec.scala:94)
at org.apache.spark.sql.execution.CodegenSupport.produce$(WholeStageCodegenExec.scala:94)
at org.apache.spark.sql.execution.joins.BroadcastHashJoinExec.produce(BroadcastHashJoinExec.scala:40)
at org.apache.spark.sql.execution.ProjectExec.doProduce(basicPhysicalOperators.scala:55)
at org.apache.spark.sql.execution.CodegenSupport.$anonfun$produce$1(WholeStageCodegenExec.scala:99)
at org.apache.spark.sql.execution.SparkPlan.$anonfun$executeQuery$1(SparkPlan.scala:260)
at org.apache.spark.rdd.RDDOperationScope$.withScope(RDDOperationScope.scala:151)
at org.apache.spark.sql.execution.SparkPlan.executeQuery(SparkPlan.scala:257)
at org.apache.spark.sql.execution.CodegenSupport.produce(WholeStageCodegenExec.scala:94)
at org.apache.spark.sql.execution.CodegenSupport.produce$(WholeStageCodegenExec.scala:94)
at org.apache.spark.sql.execution.ProjectExec.produce(basicPhysicalOperators.scala:42)
at org.apache.spark.sql.execution.ProjectExec.doProduce(basicPhysicalOperators.scala:55)
at org.apache.spark.sql.execution.CodegenSupport.$anonfun$produce$1(WholeStageCodegenExec.scala:99)
at org.apache.spark.sql.execution.SparkPlan.$anonfun$executeQuery$1(SparkPlan.scala:260)
at org.apache.spark.rdd.RDDOperationScope$.withScope(RDDOperationScope.scala:151)
at org.apache.spark.sql.execution.SparkPlan.executeQuery(SparkPlan.scala:257)
at org.apache.spark.sql.execution.CodegenSupport.produce(WholeStageCodegenExec.scala:94)
at org.apache.spark.sql.execution.CodegenSupport.produce$(WholeStageCodegenExec.scala:94)
at org.apache.spark.sql.execution.ProjectExec.produce(basicPhysicalOperators.scala:42)
at org.apache.spark.sql.execution.WholeStageCodegenExec.doCodeGen(WholeStageCodegenExec.scala:666)
at org.apache.spark.sql.execution.WholeStageCodegenExec.doExecute(WholeStageCodegenExec.scala:729)
at org.apache.spark.sql.execution.SparkPlan.$anonfun$executeRDD$1(SparkPlan.scala:188)
at scala.util.Try$.apply(Try.scala:217)
at org.apache.spark.util.Utils$.doTryWithCallerStacktrace(Utils.scala:1378)
at org.apache.spark.util.LazyTry.tryT$lzycompute(LazyTry.scala:46)
at org.apache.spark.util.LazyTry.tryT(LazyTry.scala:46)
at org.apache.spark.util.LazyTry.get(LazyTry.scala:58)
at org.apache.spark.sql.execution.SparkPlan.$anonfun$execute$1(SparkPlan.scala:201)
at org.apache.spark.sql.execution.SparkPlan.$anonfun$executeQuery$1(SparkPlan.scala:260)
at org.apache.spark.rdd.RDDOperationScope$.withScope(RDDOperationScope.scala:151)
at org.apache.spark.sql.execution.SparkPlan.executeQuery(SparkPlan.scala:257)
at org.apache.spark.sql.execution.SparkPlan.execute(SparkPlan.scala:197)
at org.apache.spark.sql.execution.DeserializeToObjectExec.doExecute(objects.scala:93)
at org.apache.spark.sql.execution.SparkPlan.$anonfun$executeRDD$1(SparkPlan.scala:188)
at scala.util.Try$.apply(Try.scala:217)
at org.apache.spark.util.Utils$.doTryWithCallerStacktrace(Utils.scala:1378)
at org.apache.spark.util.LazyTry.tryT$lzycompute(LazyTry.scala:46)
at org.apache.spark.util.LazyTry.tryT(LazyTry.scala:46)
at org.apache.spark.util.LazyTry.get(LazyTry.scala:58)
at org.apache.spark.sql.execution.SparkPlan.$anonfun$execute$1(SparkPlan.scala:201)
at org.apache.spark.sql.execution.SparkPlan.$anonfun$executeQuery$1(SparkPlan.scala:260)
at org.apache.spark.rdd.RDDOperationScope$.withScope(RDDOperationScope.scala:151)
at org.apache.spark.sql.execution.SparkPlan.executeQuery(SparkPlan.scala:257)
at org.apache.spark.sql.execution.SparkPlan.execute(SparkPlan.scala:197)
at org.apache.spark.sql.execution.MapPartitionsExec.doExecute(objects.scala:195)
at org.apache.spark.sql.execution.SparkPlan.$anonfun$executeRDD$1(SparkPlan.scala:188)
at scala.util.Try$.apply(Try.scala:217)
at org.apache.spark.util.Utils$.doTryWithCallerStacktrace(Utils.scala:1378)
at org.apache.spark.util.LazyTry.tryT$lzycompute(LazyTry.scala:46)
at org.apache.spark.util.LazyTry.tryT(LazyTry.scala:46)
at org.apache.spark.util.LazyTry.get(LazyTry.scala:58)
at org.apache.spark.sql.execution.SparkPlan.$anonfun$execute$1(SparkPlan.scala:201)
at org.apache.spark.sql.execution.SparkPlan.$anonfun$executeQuery$1(SparkPlan.scala:260)
at org.apache.spark.rdd.RDDOperationScope$.withScope(RDDOperationScope.scala:151)
at org.apache.spark.sql.execution.SparkPlan.executeQuery(SparkPlan.scala:257)
at org.apache.spark.sql.execution.SparkPlan.execute(SparkPlan.scala:197)
at org.apache.spark.sql.execution.InputAdapter.inputRDD(WholeStageCodegenExec.scala:533)
at org.apache.spark.sql.execution.InputRDDCodegen.inputRDDs(WholeStageCodegenExec.scala:461)
at org.apache.spark.sql.execution.InputRDDCodegen.inputRDDs$(WholeStageCodegenExec.scala:460)
at org.apache.spark.sql.execution.InputAdapter.inputRDDs(WholeStageCodegenExec.scala:504)
at org.apache.spark.sql.execution.SerializeFromObjectExec.inputRDDs(objects.scala:117)
at org.apache.spark.sql.execution.joins.BroadcastNestedLoopJoinExec.inputRDDs(BroadcastNestedLoopJoinExec.scala:436)
at org.apache.spark.sql.execution.WholeStageCodegenExec.doExecute(WholeStageCodegenExec.scala:761)
at org.apache.spark.sql.execution.SparkPlan.$anonfun$executeRDD$1(SparkPlan.scala:188)
at scala.util.Try$.apply(Try.scala:217)
at org.apache.spark.util.Utils$.doTryWithCallerStacktrace(Utils.scala:1378)
at org.apache.spark.util.LazyTry.tryT$lzycompute(LazyTry.scala:46)
at org.apache.spark.util.LazyTry.tryT(LazyTry.scala:46)
at org.apache.spark.util.LazyTry.get(LazyTry.scala:58)
at org.apache.spark.sql.execution.SparkPlan.$anonfun$execute$1(SparkPlan.scala:201)
at org.apache.spark.sql.execution.SparkPlan.$anonfun$executeQuery$1(SparkPlan.scala:260)
at org.apache.spark.rdd.RDDOperationScope$.withScope(RDDOperationScope.scala:151)
at org.apache.spark.sql.execution.SparkPlan.executeQuery(SparkPlan.scala:257)
at org.apache.spark.sql.execution.SparkPlan.execute(SparkPlan.scala:197)
at org.apache.spark.sql.execution.DeserializeToObjectExec.doExecute(objects.scala:93)
at org.apache.spark.sql.execution.SparkPlan.$anonfun$executeRDD$1(SparkPlan.scala:188)
at scala.util.Try$.apply(Try.scala:217)
at org.apache.spark.util.Utils$.doTryWithCallerStacktrace(Utils.scala:1378)
at org.apache.spark.util.LazyTry.tryT$lzycompute(LazyTry.scala:46)
at org.apache.spark.util.LazyTry.tryT(LazyTry.scala:46)
at org.apache.spark.util.LazyTry.get(LazyTry.scala:58)
at org.apache.spark.sql.execution.SparkPlan.$anonfun$execute$1(SparkPlan.scala:201)
at org.apache.spark.sql.execution.SparkPlan.$anonfun$executeQuery$1(SparkPlan.scala:260)
at org.apache.spark.util.Utils$.getTryWithCallerStacktrace(Utils.scala:1439)
at org.apache.spark.util.LazyTry.get(LazyTry.scala:58)
at org.apache.spark.sql.execution.QueryExecution.toRdd(QueryExecution.scala:266)
at org.apache.spark.sql.classic.Dataset.materializedRdd$lzycompute(Dataset.scala:1578)
at org.apache.spark.sql.classic.Dataset.materializedRdd(Dataset.scala:1576)
at org.apache.spark.sql.classic.Dataset.$anonfun$rdd$1(Dataset.scala:1586)
at org.apache.spark.sql.classic.Dataset.$anonfun$withNewRDDExecutionId$1(Dataset.scala:2221)
at org.apache.spark.sql.execution.SQLExecution$.$anonfun$withNewExecutionId0$8(SQLExecution.scala:163)
at org.apache.spark.sql.execution.SQLExecution$.withSessionTagsApplied(SQLExecution.scala:272)
at org.apache.spark.sql.execution.SQLExecution$.$anonfun$withNewExecutionId0$7(SQLExecution.scala:125)
at org.apache.spark.JobArtifactSet$.withActiveJobArtifactState(JobArtifactSet.scala:94)
at org.apache.spark.sql.artifact.ArtifactManager.$anonfun$withResources$1(ArtifactManager.scala:112)
at org.apache.spark.sql.artifact.ArtifactManager.withClassLoaderIfNeeded(ArtifactManager.scala:106)
at org.apache.spark.sql.artifact.ArtifactManager.withResources(ArtifactManager.scala:111)
at org.apache.spark.sql.execution.SQLExecution$.$anonfun$withNewExecutionId0$6(SQLExecution.scala:125)
at org.apache.spark.sql.execution.SQLExecution$.withSQLConfPropagated(SQLExecution.scala:295)
at org.apache.spark.sql.execution.SQLExecution$.$anonfun$withNewExecutionId0$1(SQLExecution.scala:124)
at org.apache.spark.sql.SparkSession.withActive(SparkSession.scala:804)
at org.apache.spark.sql.execution.SQLExecution$.withNewExecutionId0(SQLExecution.scala:78)
at org.apache.spark.sql.execution.SQLExecution$.withNewExecutionId(SQLExecution.scala:237)
at org.apache.spark.sql.classic.Dataset.withNewRDDExecutionId(Dataset.scala:2219)
at org.apache.spark.sql.classic.Dataset.rdd$lzycompute(Dataset.scala:1586)
at org.apache.spark.sql.classic.Dataset.rdd(Dataset.scala:1584)
at org.apache.spark.sql.classic.Dataset.toJavaRDD(Dataset.scala:1591)
at com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.calculation.KpiCurveRefinementImpl.callStockExtrapolationByPartition(KpiCurveRefinementImpl.java:245)
at com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.calculation.KpiCurveRefinementImpl.refineKpiCurves(KpiCurveRefinementImpl.java:66)
at com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.business.OrderQuantityKpiImpl.calculateKpis(OrderQuantityKpiImpl.java:93)
at com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.business.OrderQuantityKpiImpl.calculateKpiCurveUpdate(OrderQuantityKpiImpl.java:69)
at com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.lambda$triggerOrderProposalUpdateStream$7872d289$1(FileStorageAdapterImpl.java:171)
at org.apache.spark.sql.streaming.DataStreamWriter.$anonfun$foreachBatch$1(DataStreamWriter.scala:170)
at org.apache.spark.sql.streaming.DataStreamWriter.$anonfun$foreachBatch$1$adapted(DataStreamWriter.scala:170)
at org.apache.spark.sql.execution.streaming.sources.ForeachBatchSink.callBatchWriter(ForeachBatchSink.scala:56)
at org.apache.spark.sql.execution.streaming.sources.ForeachBatchSink.addBatch(ForeachBatchSink.scala:49)
at org.apache.spark.sql.execution.streaming.MicroBatchExecution.$anonfun$runBatch$17(MicroBatchExecution.scala:879)
at org.apache.spark.sql.execution.SQLExecution$.$anonfun$withNewExecutionId0$8(SQLExecution.scala:163)
at org.apache.spark.sql.execution.SQLExecution$.withSessionTagsApplied(SQLExecution.scala:272)
at org.apache.spark.sql.execution.SQLExecution$.$anonfun$withNewExecutionId0$7(SQLExecution.scala:125)
at org.apache.spark.JobArtifactSet$.withActiveJobArtifactState(JobArtifactSet.scala:94)
at org.apache.spark.sql.artifact.ArtifactManager.$anonfun$withResources$1(ArtifactManager.scala:112)
at org.apache.spark.sql.artifact.ArtifactManager.withClassLoaderIfNeeded(ArtifactManager.scala:106)
at org.apache.spark.sql.artifact.ArtifactManager.withResources(ArtifactManager.scala:111)
at org.apache.spark.sql.execution.SQLExecution$.$anonfun$withNewExecutionId0$6(SQLExecution.scala:125)
at org.apache.spark.sql.execution.SQLExecution$.withSQLConfPropagated(SQLExecution.scala:295)
at org.apache.spark.sql.execution.SQLExecution$.$anonfun$withNewExecutionId0$1(SQLExecution.scala:124)
at org.apache.spark.sql.SparkSession.withActive(SparkSession.scala:804)
at org.apache.spark.sql.execution.SQLExecution$.withNewExecutionId0(SQLExecution.scala:78)
at org.apache.spark.sql.execution.SQLExecution$.withNewExecutionId(SQLExecution.scala:237)
at org.apache.spark.sql.execution.streaming.MicroBatchExecution.$anonfun$runBatch$16(MicroBatchExecution.scala:876)
at org.apache.spark.sql.execution.streaming.ProgressContext.reportTimeTaken(ProgressReporter.scala:186)
at org.apache.spark.sql.execution.streaming.MicroBatchExecution.runBatch(MicroBatchExecution.scala:876)
at org.apache.spark.sql.execution.streaming.MicroBatchExecution.$anonfun$executeOneBatch$2(MicroBatchExecution.scala:394)
at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.scala:18)
at org.apache.spark.sql.execution.streaming.ProgressContext.reportTimeTaken(ProgressReporter.scala:186)
at org.apache.spark.sql.execution.streaming.MicroBatchExecution.executeOneBatch(MicroBatchExecution.scala:364)
at org.apache.spark.sql.execution.streaming.MicroBatchExecution.$anonfun$runActivatedStream$1(MicroBatchExecution.scala:344)
at org.apache.spark.sql.execution.streaming.MicroBatchExecution.$anonfun$runActivatedStream$1$adapted(MicroBatchExecution.scala:344)
at org.apache.spark.sql.execution.streaming.TriggerExecutor.runOneBatch(TriggerExecutor.scala:39)
at org.apache.spark.sql.execution.streaming.TriggerExecutor.runOneBatch$(TriggerExecutor.scala:37)
at org.apache.spark.sql.execution.streaming.ProcessingTimeExecutor.runOneBatch(TriggerExecutor.scala:70)
at org.apache.spark.sql.execution.streaming.ProcessingTimeExecutor.execute(TriggerExecutor.scala:82)
at org.apache.spark.sql.execution.streaming.MicroBatchExecution.runActivatedStream(MicroBatchExecution.scala:344)
at org.apache.spark.sql.execution.streaming.StreamExecution.$anonfun$runStream$1(StreamExecution.scala:337)
at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.scala:18)
at org.apache.spark.sql.SparkSession.withActive(SparkSession.scala:804)
at org.apache.spark.sql.execution.streaming.StreamExecution.org$apache$spark$sql$execution$streaming$StreamExecution$$runStream(StreamExecution.scala:311)
at org.apache.spark.sql.execution.streaming.StreamExecution$$anon$1.run(StreamExecution.scala:226)
Suppressed: org.apache.spark.util.Utils$OriginalTryStackTraceException: Full stacktrace of original doTryWithCallerStacktrace caller
at java.base/java.util.concurrent.CompletableFuture.reportGet(Unknown Source)
at java.base/java.util.concurrent.CompletableFuture.get(Unknown Source)
at org.apache.spark.sql.execution.exchange.BroadcastExchangeExec.doExecuteBroadcast(BroadcastExchangeExec.scala:254)
at org.apache.spark.sql.execution.InputAdapter.doExecuteBroadcast(WholeStageCodegenExec.scala:523)
at org.apache.spark.sql.execution.SparkPlan.$anonfun$executeBroadcastBcast$1(SparkPlan.scala:205)
at scala.util.Try$.apply(Try.scala:217)
at org.apache.spark.util.Utils$.doTryWithCallerStacktrace(Utils.scala:1378)
at org.apache.spark.util.LazyTry.tryT$lzycompute(LazyTry.scala:46)
at org.apache.spark.util.LazyTry.tryT(LazyTry.scala:46)
at org.apache.spark.util.LazyTry.get(LazyTry.scala:58)
at org.apache.spark.sql.execution.SparkPlan.$anonfun$executeBroadcast$1(SparkPlan.scala:218)
at org.apache.spark.sql.execution.SparkPlan.$anonfun$executeQuery$1(SparkPlan.scala:260)
at org.apache.spark.rdd.RDDOperationScope$.withScope(RDDOperationScope.scala:151)
at org.apache.spark.sql.execution.SparkPlan.executeQuery(SparkPlan.scala:257)
at org.apache.spark.sql.execution.SparkPlan.executeBroadcast(SparkPlan.scala:214)
at org.apache.spark.sql.execution.joins.BroadcastHashJoinExec.prepareBroadcast(BroadcastHashJoinExec.scala:186)
at org.apache.spark.sql.execution.joins.BroadcastHashJoinExec.prepareRelation(BroadcastHashJoinExec.scala:200)
at org.apache.spark.sql.execution.joins.HashJoin.codegenInner(HashJoin.scala:396)
at org.apache.spark.sql.execution.joins.HashJoin.codegenInner$(HashJoin.scala:395)
at org.apache.spark.sql.execution.joins.BroadcastHashJoinExec.codegenInner(BroadcastHashJoinExec.scala:40)
at org.apache.spark.sql.execution.joins.HashJoin.doConsume(HashJoin.scala:362)
at org.apache.spark.sql.execution.joins.HashJoin.doConsume$(HashJoin.scala:360)
at org.apache.spark.sql.execution.joins.BroadcastHashJoinExec.doConsume(BroadcastHashJoinExec.scala:40)
at org.apache.spark.sql.execution.CodegenSupport.consume(WholeStageCodegenExec.scala:200)
at org.apache.spark.sql.execution.CodegenSupport.consume$(WholeStageCodegenExec.scala:153)
at org.apache.spark.sql.execution.InputAdapter.consume(WholeStageCodegenExec.scala:504)
at org.apache.spark.sql.execution.InputRDDCodegen.doProduce(WholeStageCodegenExec.scala:491)
at org.apache.spark.sql.execution.InputRDDCodegen.doProduce$(WholeStageCodegenExec.scala:464)
at org.apache.spark.sql.execution.InputAdapter.doProduce(WholeStageCodegenExec.scala:504)
at org.apache.spark.sql.execution.CodegenSupport.$anonfun$produce$1(WholeStageCodegenExec.scala:99)
at org.apache.spark.sql.execution.SparkPlan.$anonfun$executeQuery$1(SparkPlan.scala:260)
at org.apache.spark.rdd.RDDOperationScope$.withScope(RDDOperationScope.scala:151)
at org.apache.spark.sql.execution.SparkPlan.executeQuery(SparkPlan.scala:257)
at org.apache.spark.sql.execution.CodegenSupport.produce(WholeStageCodegenExec.scala:94)
at org.apache.spark.sql.execution.CodegenSupport.produce$(WholeStageCodegenExec.scala:94)
at org.apache.spark.sql.execution.InputAdapter.produce(WholeStageCodegenExec.scala:504)
at org.apache.spark.sql.execution.joins.HashJoin.doProduce(HashJoin.scala:357)
at org.apache.spark.sql.execution.joins.HashJoin.doProduce$(HashJoin.scala:356)
at org.apache.spark.sql.execution.joins.BroadcastHashJoinExec.doProduce(BroadcastHashJoinExec.scala:40)
at org.apache.spark.sql.execution.CodegenSupport.$anonfun$produce$1(WholeStageCodegenExec.scala:99)
at org.apache.spark.sql.execution.SparkPlan.$anonfun$executeQuery$1(SparkPlan.scala:260)
at org.apache.spark.rdd.RDDOperationScope$.withScope(RDDOperationScope.scala:151)
at org.apache.spark.sql.execution.SparkPlan.executeQuery(SparkPlan.scala:257)
at org.apache.spark.sql.execution.CodegenSupport.produce(WholeStageCodegenExec.scala:94)
at org.apache.spark.sql.execution.CodegenSupport.produce$(WholeStageCodegenExec.scala:94)
at org.apache.spark.sql.execution.joins.BroadcastHashJoinExec.produce(BroadcastHashJoinExec.scala:40)
at org.apache.spark.sql.execution.ProjectExec.doProduce(basicPhysicalOperators.scala:55)
at org.apache.spark.sql.execution.CodegenSupport.$anonfun$produce$1(WholeStageCodegenExec.scala:99)
at org.apache.spark.sql.execution.SparkPlan.$anonfun$executeQuery$1(SparkPlan.scala:260)
at org.apache.spark.rdd.RDDOperationScope$.withScope(RDDOperationScope.scala:151)
at org.apache.spark.sql.execution.SparkPlan.executeQuery(SparkPlan.scala:257)
at org.apache.spark.sql.execution.CodegenSupport.produce(WholeStageCodegenExec.scala:94)
at org.apache.spark.sql.execution.CodegenSupport.produce$(WholeStageCodegenExec.scala:94)
at org.apache.spark.sql.execution.ProjectExec.produce(basicPhysicalOperators.scala:42)
at org.apache.spark.sql.execution.ProjectExec.doProduce(basicPhysicalOperators.scala:55)
at org.apache.spark.sql.execution.CodegenSupport.$anonfun$produce$1(WholeStageCodegenExec.scala:99)
at org.apache.spark.sql.execution.SparkPlan.$anonfun$executeQuery$1(SparkPlan.scala:260)
at org.apache.spark.rdd.RDDOperationScope$.withScope(RDDOperationScope.scala:151)
at org.apache.spark.sql.execution.SparkPlan.executeQuery(SparkPlan.scala:257)
at org.apache.spark.sql.execution.CodegenSupport.produce(WholeStageCodegenExec.scala:94)
at org.apache.spark.sql.execution.CodegenSupport.produce$(WholeStageCodegenExec.scala:94)
at org.apache.spark.sql.execution.ProjectExec.produce(basicPhysicalOperators.scala:42)
at org.apache.spark.sql.execution.WholeStageCodegenExec.doCodeGen(WholeStageCodegenExec.scala:666)
at org.apache.spark.sql.execution.WholeStageCodegenExec.doExecute(WholeStageCodegenExec.scala:729)
at org.apache.spark.sql.execution.SparkPlan.$anonfun$executeRDD$1(SparkPlan.scala:188)
at scala.util.Try$.apply(Try.scala:217)
at org.apache.spark.util.Utils$.doTryWithCallerStacktrace(Utils.scala:1378)
at org.apache.spark.util.LazyTry.tryT$lzycompute(LazyTry.scala:46)
at org.apache.spark.util.LazyTry.tryT(LazyTry.scala:46)
at org.apache.spark.util.LazyTry.get(LazyTry.scala:58)
at org.apache.spark.sql.execution.SparkPlan.$anonfun$execute$1(SparkPlan.scala:201)
at org.apache.spark.sql.execution.SparkPlan.$anonfun$executeQuery$1(SparkPlan.scala:260)
at org.apache.spark.rdd.RDDOperationScope$.withScope(RDDOperationScope.scala:151)
at org.apache.spark.sql.execution.SparkPlan.executeQuery(SparkPlan.scala:257)
at org.apache.spark.sql.execution.SparkPlan.execute(SparkPlan.scala:197)
at org.apache.spark.sql.execution.DeserializeToObjectExec.doExecute(objects.scala:93)
at org.apache.spark.sql.execution.SparkPlan.$anonfun$executeRDD$1(SparkPlan.scala:188)
at scala.util.Try$.apply(Try.scala:217)
at org.apache.spark.util.Utils$.doTryWithCallerStacktrace(Utils.scala:1378)
at org.apache.spark.util.LazyTry.tryT$lzycompute(LazyTry.scala:46)
at org.apache.spark.util.LazyTry.tryT(LazyTry.scala:46)
at org.apache.spark.util.LazyTry.get(LazyTry.scala:58)
at org.apache.spark.sql.execution.SparkPlan.$anonfun$execute$1(SparkPlan.scala:201)
at org.apache.spark.sql.execution.SparkPlan.$anonfun$executeQuery$1(SparkPlan.scala:260)
at org.apache.spark.rdd.RDDOperationScope$.withScope(RDDOperationScope.scala:151)
at org.apache.spark.sql.execution.SparkPlan.executeQuery(SparkPlan.scala:257)
at org.apache.spark.sql.execution.SparkPlan.execute(SparkPlan.scala:197)
at org.apache.spark.sql.execution.MapPartitionsExec.doExecute(objects.scala:195)
at org.apache.spark.sql.execution.SparkPlan.$anonfun$executeRDD$1(SparkPlan.scala:188)
at scala.util.Try$.apply(Try.scala:217)
at org.apache.spark.util.Utils$.doTryWithCallerStacktrace(Utils.scala:1378)
at org.apache.spark.util.LazyTry.tryT$lzycompute(LazyTry.scala:46)
at org.apache.spark.util.LazyTry.tryT(LazyTry.scala:46)
at org.apache.spark.util.LazyTry.get(LazyTry.scala:58)
at org.apache.spark.sql.execution.SparkPlan.$anonfun$execute$1(SparkPlan.scala:201)
at org.apache.spark.sql.execution.SparkPlan.$anonfun$executeQuery$1(SparkPlan.scala:260)
at org.apache.spark.rdd.RDDOperationScope$.withScope(RDDOperationScope.scala:151)
at org.apache.spark.sql.execution.SparkPlan.executeQuery(SparkPlan.scala:257)
at org.apache.spark.sql.execution.SparkPlan.execute(SparkPlan.scala:197)
at org.apache.spark.sql.execution.InputAdapter.inputRDD(WholeStageCodegenExec.scala:533)
at org.apache.spark.sql.execution.InputRDDCodegen.inputRDDs(WholeStageCodegenExec.scala:461)
at org.apache.spark.sql.execution.InputRDDCodegen.inputRDDs$(WholeStageCodegenExec.scala:460)
at org.apache.spark.sql.execution.InputAdapter.inputRDDs(WholeStageCodegenExec.scala:504)
at org.apache.spark.sql.execution.SerializeFromObjectExec.inputRDDs(objects.scala:117)
at org.apache.spark.sql.execution.joins.BroadcastNestedLoopJoinExec.inputRDDs(BroadcastNestedLoopJoinExec.scala:436)
at org.apache.spark.sql.execution.WholeStageCodegenExec.doExecute(WholeStageCodegenExec.scala:761)
at org.apache.spark.sql.execution.SparkPlan.$anonfun$executeRDD$1(SparkPlan.scala:188)
at scala.util.Try$.apply(Try.scala:217)
at org.apache.spark.util.Utils$.doTryWithCallerStacktrace(Utils.scala:1378)
at org.apache.spark.util.LazyTry.tryT$lzycompute(LazyTry.scala:46)
at org.apache.spark.util.LazyTry.tryT(LazyTry.scala:46)
at org.apache.spark.util.LazyTry.get(LazyTry.scala:58)
at org.apache.spark.sql.execution.SparkPlan.$anonfun$execute$1(SparkPlan.scala:201)
at org.apache.spark.sql.execution.SparkPlan.$anonfun$executeQuery$1(SparkPlan.scala:260)
at org.apache.spark.rdd.RDDOperationScope$.withScope(RDDOperationScope.scala:151)
at org.apache.spark.sql.execution.SparkPlan.executeQuery(SparkPlan.scala:257)
at org.apache.spark.sql.execution.SparkPlan.execute(SparkPlan.scala:197)
at org.apache.spark.sql.execution.DeserializeToObjectExec.doExecute(objects.scala:93)
at org.apache.spark.sql.execution.SparkPlan.$anonfun$executeRDD$1(SparkPlan.scala:188)
at scala.util.Try$.apply(Try.scala:217)
at org.apache.spark.util.Utils$.doTryWithCallerStacktrace(Utils.scala:1378)
at org.apache.spark.util.LazyTry.tryT$lzycompute(LazyTry.scala:46)
at org.apache.spark.util.LazyTry.tryT(LazyTry.scala:46)
at org.apache.spark.util.LazyTry.get(LazyTry.scala:58)
at org.apache.spark.sql.execution.SparkPlan.$anonfun$execute$1(SparkPlan.scala:201)
at org.apache.spark.sql.execution.SparkPlan.$anonfun$executeQuery$1(SparkPlan.scala:260)
at org.apache.spark.rdd.RDDOperationScope$.withScope(RDDOperationScope.scala:151)
at org.apache.spark.sql.execution.SparkPlan.executeQuery(SparkPlan.scala:257)
at org.apache.spark.sql.execution.SparkPlan.execute(SparkPlan.scala:197)
at org.apache.spark.sql.execution.QueryExecution.$anonfun$lazyToRdd$1(QueryExecution.scala:253)
at scala.util.Try$.apply(Try.scala:217)
at org.apache.spark.util.Utils$.doTryWithCallerStacktrace(Utils.scala:1378)
at org.apache.spark.util.LazyTry.tryT$lzycompute(LazyTry.scala:46)
at org.apache.spark.util.LazyTry.tryT(LazyTry.scala:46)
... 65 more
Caused by: org.apache.spark.SparkException: Job aborted due to stage failure: Task serialization failed: java.lang.OutOfMemoryError: Java heap space
java.lang.OutOfMemoryError: Java heap space
at java.base/java.nio.HeapByteBuffer.<init>(Unknown Source)
at java.base/java.nio.ByteBuffer.allocate(Unknown Source)
at org.apache.spark.broadcast.TorrentBroadcast$.$anonfun$blockifyObject$1(TorrentBroadcast.scala:364)
at org.apache.spark.broadcast.TorrentBroadcast$.$anonfun$blockifyObject$1$adapted(TorrentBroadcast.scala:364)
at org.apache.spark.broadcast.TorrentBroadcast$$$Lambda/0x000000080167df78.apply(Unknown Source)
at org.apache.spark.util.io.ChunkedByteBufferOutputStream.allocateNewChunkIfNeeded(ChunkedByteBufferOutputStream.scala:87)
at org.apache.spark.util.io.ChunkedByteBufferOutputStream.write(ChunkedByteBufferOutputStream.scala:75)
at net.jpountz.lz4.LZ4BlockOutputStream.flushBufferedData(LZ4BlockOutputStream.java:225)
at net.jpountz.lz4.LZ4BlockOutputStream.write(LZ4BlockOutputStream.java:178)
at com.esotericsoftware.kryo.io.Output.flush(Output.java:185)
at com.esotericsoftware.kryo.io.Output.close(Output.java:196)
at org.apache.spark.serializer.KryoSerializationStream.close(KryoSerializer.scala:297)
at org.apache.spark.broadcast.TorrentBroadcast$.$anonfun$blockifyObject$5(TorrentBroadcast.scala:371)
at org.apache.spark.broadcast.TorrentBroadcast$$$Lambda/0x00000008016fdfd8.apply$mcV$sp(Unknown Source)
at org.apache.spark.util.SparkErrorUtils.tryWithSafeFinally(SparkErrorUtils.scala:89)
at org.apache.spark.util.SparkErrorUtils.tryWithSafeFinally$(SparkErrorUtils.scala:77)
at org.apache.spark.util.Utils$.tryWithSafeFinally(Utils.scala:99)
at org.apache.spark.broadcast.TorrentBroadcast$.blockifyObject(TorrentBroadcast.scala:371)
at org.apache.spark.broadcast.TorrentBroadcast.writeBlocks(TorrentBroadcast.scala:162)
at org.apache.spark.broadcast.TorrentBroadcast.<init>(TorrentBroadcast.scala:100)
at org.apache.spark.broadcast.TorrentBroadcastFactory.newBroadcast(TorrentBroadcastFactory.scala:38)
at org.apache.spark.broadcast.BroadcastManager.newBroadcast(BroadcastManager.scala:78)
at org.apache.spark.SparkContext.broadcastInternal(SparkContext.scala:1728)
at org.apache.spark.SparkContext.broadcast(SparkContext.scala:1710)
at org.apache.spark.scheduler.DAGScheduler.submitMissingTasks(DAGScheduler.scala:1676)
at org.apache.spark.scheduler.DAGScheduler.submitStage(DAGScheduler.scala:1470)
at org.apache.spark.scheduler.DAGScheduler.handleJobSubmitted(DAGScheduler.scala:1400)
at org.apache.spark.scheduler.DAGSchedulerEventProcessLoop.doOnReceive(DAGScheduler.scala:3150)
at org.apache.spark.scheduler.DAGSchedulerEventProcessLoop.onReceive(DAGScheduler.scala:3141)
at org.apache.spark.scheduler.DAGSchedulerEventProcessLoop.onReceive(DAGScheduler.scala:3130)
at org.apache.spark.util.EventLoop$$anon$1.run(EventLoop.scala:50)
at org.apache.spark.scheduler.DAGScheduler.$anonfun$abortStage$3(DAGScheduler.scala:2935)
at scala.Option.getOrElse(Option.scala:201)
at org.apache.spark.scheduler.DAGScheduler.$anonfun$abortStage$2(DAGScheduler.scala:2935)
at org.apache.spark.scheduler.DAGScheduler.$anonfun$abortStage$2$adapted(DAGScheduler.scala:2927)
at scala.collection.immutable.List.foreach(List.scala:334)
at org.apache.spark.scheduler.DAGScheduler.abortStage(DAGScheduler.scala:2927)
at org.apache.spark.scheduler.DAGScheduler.submitMissingTasks(DAGScheduler.scala:1686)
at org.apache.spark.scheduler.DAGScheduler.submitStage(DAGScheduler.scala:1470)
at org.apache.spark.scheduler.DAGScheduler.handleJobSubmitted(DAGScheduler.scala:1400)
at org.apache.spark.scheduler.DAGSchedulerEventProcessLoop.doOnReceive(DAGScheduler.scala:3150)
at org.apache.spark.scheduler.DAGSchedulerEventProcessLoop.onReceive(DAGScheduler.scala:3141)
at org.apache.spark.scheduler.DAGSchedulerEventProcessLoop.onReceive(DAGScheduler.scala:3130)
at org.apache.spark.util.EventLoop$$anon$1.run(EventLoop.scala:50)
at org.apache.spark.scheduler.DAGScheduler.runJob(DAGScheduler.scala:1009)
at org.apache.spark.SparkContext.runJob(SparkContext.scala:2484)
at org.apache.spark.SparkContext.runJob(SparkContext.scala:2505)
at org.apache.spark.SparkContext.runJob(SparkContext.scala:2524)
at org.apache.spark.SparkContext.runJob(SparkContext.scala:2549)
at org.apache.spark.rdd.RDD.$anonfun$collect$1(RDD.scala:1057)
at org.apache.spark.rdd.RDDOperationScope$.withScope(RDDOperationScope.scala:151)
at org.apache.spark.rdd.RDDOperationScope$.withScope(RDDOperationScope.scala:112)
at org.apache.spark.rdd.RDD.withScope(RDD.scala:417)
at org.apache.spark.rdd.RDD.collect(RDD.scala:1056)
at org.apache.spark.sql.execution.SparkPlan.executeCollectIterator(SparkPlan.scala:469)
at org.apache.spark.sql.execution.exchange.BroadcastExchangeExec.$anonfun$relationFuture$1(BroadcastExchangeExec.scala:182)
at org.apache.spark.sql.execution.SQLExecution$.$anonfun$withThreadLocalCaptured$4(SQLExecution.scala:322)
at org.apache.spark.sql.execution.SQLExecution$.withSessionTagsApplied(SQLExecution.scala:272)
at org.apache.spark.sql.execution.SQLExecution$.$anonfun$withThreadLocalCaptured$3(SQLExecution.scala:320)
at org.apache.spark.JobArtifactSet$.withActiveJobArtifactState(JobArtifactSet.scala:94)
at org.apache.spark.sql.execution.SQLExecution$.$anonfun$withThreadLocalCaptured$2(SQLExecution.scala:316)
at java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run(Unknown Source)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
at java.base/java.lang.Thread.run(Unknown Source)
Caused by: java.lang.OutOfMemoryError: Java heap space
at java.base/java.nio.HeapByteBuffer.<init>(Unknown Source)
at java.base/java.nio.ByteBuffer.allocate(Unknown Source)
at org.apache.spark.broadcast.TorrentBroadcast$.$anonfun$blockifyObject$1(TorrentBroadcast.scala:364)
at org.apache.spark.broadcast.TorrentBroadcast$.$anonfun$blockifyObject$1$adapted(TorrentBroadcast.scala:364)
at org.apache.spark.broadcast.TorrentBroadcast$$$Lambda/0x000000080167df78.apply(Unknown Source)
at org.apache.spark.util.io.ChunkedByteBufferOutputStream.allocateNewChunkIfNeeded(ChunkedByteBufferOutputStream.scala:87)
at org.apache.spark.util.io.ChunkedByteBufferOutputStream.write(ChunkedByteBufferOutputStream.scala:75)
at net.jpountz.lz4.LZ4BlockOutputStream.flushBufferedData(LZ4BlockOutputStream.java:225)
at net.jpountz.lz4.LZ4BlockOutputStream.write(LZ4BlockOutputStream.java:178)
at com.esotericsoftware.kryo.io.Output.flush(Output.java:185)
at com.esotericsoftware.kryo.io.Output.close(Output.java:196)
at org.apache.spark.serializer.KryoSerializationStream.close(KryoSerializer.scala:297)
at org.apache.spark.broadcast.TorrentBroadcast$.$anonfun$blockifyObject$5(TorrentBroadcast.scala:371)
at org.apache.spark.broadcast.TorrentBroadcast$$$Lambda/0x00000008016fdfd8.apply$mcV$sp(Unknown Source)
at org.apache.spark.util.SparkErrorUtils.tryWithSafeFinally(SparkErrorUtils.scala:89)
at org.apache.spark.util.SparkErrorUtils.tryWithSafeFinally$(SparkErrorUtils.scala:77)
at org.apache.spark.util.Utils$.tryWithSafeFinally(Utils.scala:99)
at org.apache.spark.broadcast.TorrentBroadcast$.blockifyObject(TorrentBroadcast.scala:371)
at org.apache.spark.broadcast.TorrentBroadcast.writeBlocks(TorrentBroadcast.scala:162)
at org.apache.spark.broadcast.TorrentBroadcast.<init>(TorrentBroadcast.scala:100)
at org.apache.spark.broadcast.TorrentBroadcastFactory.newBroadcast(TorrentBroadcastFactory.scala:38)
at org.apache.spark.broadcast.BroadcastManager.newBroadcast(BroadcastManager.scala:78)
at org.apache.spark.SparkContext.broadcastInternal(SparkContext.scala:1728)
at org.apache.spark.SparkContext.broadcast(SparkContext.scala:1710)
at org.apache.spark.scheduler.DAGScheduler.submitMissingTasks(DAGScheduler.scala:1676)
at org.apache.spark.scheduler.DAGScheduler.submitStage(DAGScheduler.scala:1470)
at org.apache.spark.scheduler.DAGScheduler.handleJobSubmitted(DAGScheduler.scala:1400)
at org.apache.spark.scheduler.DAGSchedulerEventProcessLoop.doOnReceive(DAGScheduler.scala:3150)
at org.apache.spark.scheduler.DAGSchedulerEventProcessLoop.onReceive(DAGScheduler.scala:3141)
at org.apache.spark.scheduler.DAGSchedulerEventProcessLoop.onReceive(DAGScheduler.scala:3130)
at org.apache.spark.util.EventLoop$$anon$1.run(EventLoop.scala:50)
|
| stream-10000001570-1 |
FINISHED |
7faaf841-9a41-4905-8578-de2bf3162bc8 |
96023ad8-fa55-47fc-9eab-4986f4ad91a1 |
2026/06/07 09:45:53 |
18 minutes 46 seconds |
36.64 |
9.39 |
16 |
- |
| stream-10000001571-1 |
FINISHED |
64ae3bad-a94c-4c6f-8894-da53fa25c025 |
1b8e14b9-89eb-4313-ad0e-a44a75133e1a |
2026/06/07 09:39:10 |
20 minutes 54 seconds |
25.80 |
9.12 |
29 |
- |
| stream-10000000821-1 |
FINISHED |
8746484e-6fcf-42e9-9e10-91c5623dcdc6 |
103189d3-4d74-4dfc-8678-7f9554def936 |
2026/06/07 09:38:40 |
25 minutes 29 seconds |
7.09 |
2.46 |
39 |
- |
| stream-10000000818-1 |
FINISHED |
62980539-f58e-4027-ac5e-4590fef858f0 |
bcbbcfd8-af5a-43e8-99bb-d23cdc392410 |
2026/06/07 08:51:42 |
11 minutes 12 seconds |
2.10 |
1.09 |
22 |
- |
| stream-10000001566-1 |
FINISHED |
35e53987-5684-4a7e-b6a5-f15226494641 |
b6eee974-690f-40b5-825c-9b90d2ae75e2 |
2026/06/07 08:09:50 |
19 minutes 19 seconds |
24.53 |
10.57 |
38 |
- |
| stream-10000000816-1 |
FINISHED |
736afd9f-9778-4bc7-a6c3-3308f34c0334 |
afa1af77-72dd-4b53-a988-04920f306c6d |
2026/06/07 07:31:53 |
26 minutes 6 seconds |
56.87 |
22.39 |
49 |
- |
| stream-10000000815-1 |
FINISHED |
732c37d1-45dd-45fe-9f98-01daf617d84f |
f41044a8-cc1f-43d8-9c6e-5d6f89effb50 |
2026/06/07 06:27:26 |
31 minutes 58 seconds |
54.16 |
17.67 |
49 |
- |
| stream-10000000814-1 |
FINISHED |
7c793b90-ccba-4077-803e-a6bbde9c8070 |
49dc4796-d504-4da5-ac2b-665a71e654db |
2026/06/07 06:24:05 |
38 minutes 19 seconds |
7.29 |
2.60 |
60 |
- |
| stream-10000000813-1 |
FINISHED |
f5ae034c-259d-4f46-9bd4-2b2902484022 |
b5b1b80e-b46c-4ea5-8e58-3782e63a251a |
2026/06/07 06:18:40 |
40 minutes 54 seconds |
5.31 |
1.84 |
66 |
- |
| stream-10000001562-1 |
FINISHED |
f4c127f9-f530-47ef-bffc-f3562dd18124 |
f699c036-2150-484f-a70d-5cebd62970d2 |
2026/06/07 05:36:45 |
25 minutes 34 seconds |
25.31 |
9.83 |
47 |
- |
| stream-10000000812-1 |
FINISHED |
0bc3b1a3-1f4e-4a43-baf0-595daf48208f |
f1570d9f-9957-44b9-8af6-ddce178d45ca |
2026/06/07 04:46:30 |
32 minutes 24 seconds |
49.01 |
17.99 |
62 |
- |
| stream-10000001560-1 |
FINISHED |
4832a847-058d-4980-b0f8-52d80401344a |
1071c0c2-45de-4b7e-99e2-bd81694bffec |
2026/06/07 04:32:18 |
5 minutes 31 seconds |
3.34 |
1.29 |
6 |
- |
| stream-10000001559-1 |
FINISHED |
e4c483ae-f3f9-478f-8131-e5c2e63e708a |
b5e285ad-806b-4e4c-bc5e-b56573f8db9b |
2026/06/07 03:46:20 |
3 minutes 9 seconds |
26.53 |
10.28 |
2 |
- |
| stream-10000000811-1 |
FINISHED |
aee9011f-7621-4975-9006-d57fb313948a |
d152d1f1-6d40-4442-8cee-f862db662b66 |
2026/06/07 03:35:52 |
23 minutes 22 seconds |
9.26 |
4.13 |
49 |
- |
| stream-10000000810-1 |
FINISHED |
16532b24-eaa1-4769-a2bc-a72c91e98d05 |
f771d2e7-1800-4af5-bf48-e212f562ea45 |
2026/06/07 03:05:36 |
18 minutes 53 seconds |
26.21 |
10.85 |
35 |
- |
| stream-10000001558-1 |
FINISHED |
a021ad82-aa81-4af1-81ce-508d52d9c320 |
13953cfe-e630-47da-9b0e-ee13304813d7 |
2026/06/07 01:55:33 |
5 minutes 56 seconds |
3.94 |
1.48 |
6 |
- |
| stream-10000001557-1 |
FINISHED |
dbfde133-f14c-4a0e-92c6-433deed8ab71 |
85b31237-e026-4a08-8c61-2da46eff2cdc |
2026/06/07 00:06:14 |
6 minutes 25 seconds |
8.91 |
3.24 |
6 |
- |
| stream-10000000809-1 |
FINISHED |
a0c1077c-1ca0-4725-b18f-a55d8070851d |
df946732-db5b-45ba-ab46-e17467dd8fb0 |
2026/06/07 00:00:13 |
26 minutes 56 seconds |
34.40 |
59.83 |
6 |
- |
| stream-10000000809-1 |
FINISHED |
3ea2a7d8-c048-47d1-bf10-a9e743f37822 |
cfb84591-efdc-412d-a661-9b7722eaf054 |
2026/06/06 23:35:39 |
24 minutes 20 seconds |
56.20 |
23.30 |
47 |
- |
| stream-10000001554-1 |
FINISHED |
458ef3f1-8227-4110-8548-be27b298580c |
8ab09ba2-b1d6-4182-8313-179e3fb429a9 |
2026/06/06 19:49:10 |
2 minutes 49 seconds |
26.53 |
10.09 |
2 |
- |
| stream-10000001553-1 |
FINISHED |
e04a569a-7794-4871-b138-548368dbd74e |
40574e7e-3c5f-4675-8f37-fc6927351498 |
2026/06/06 19:33:33 |
11 minutes 11 seconds |
36.74 |
12.46 |
12 |
- |
| stream-10000001552-1 |
FINISHED |
b9880c04-cd3b-48ee-9eb1-dfac42a56831 |
f0a0e815-579b-4016-ab4f-94ca2629fe58 |
2026/06/06 19:17:23 |
11 minutes 41 seconds |
36.74 |
11.94 |
12 |
- |
| stream-10000001550-1 |
FINISHED |
48c5fdef-0a18-4a1b-a19d-b837f0b80a5a |
0396f9da-52b5-4d99-a593-a82e5ff6dd20 |
2026/06/06 16:03:35 |
8 minutes 54 seconds |
1.75 |
0.74 |
12 |
- |
| stream-10000001549-1 |
FINISHED |
941288c5-0d2c-448f-ae33-4e876a411a53 |
bfaa47a8-4c2b-4e85-9554-dcff039fce04 |
2026/06/06 15:56:58 |
8 minutes 56 seconds |
16.04 |
5.01 |
10 |
- |
| stream-10000001548-1 |
FINISHED |
617f9ac0-7955-4a8f-b34d-a60f0cdd4b73 |
47be8adc-631b-458b-864c-c38622924637 |
2026/06/06 15:16:35 |
5 minutes 44 seconds |
6.34 |
2.51 |
6 |
- |
| stream-10000000807-1 |
FINISHED |
7918abb9-9bf1-4d3f-915f-96ab34c75fe0 |
1851c247-fa5e-4f69-9565-11894621ea00 |
2026/06/06 14:48:20 |
5 minutes 19 seconds |
1.00 |
0.46 |
5 |
- |
| stream-10000000806-1 |
FINISHED |
528be510-f20d-4f60-b935-3e23e3d3662c |
8bab2d53-2900-4b3f-9a47-8ccbbd7da1ce |
2026/06/06 14:23:27 |
16 minutes 42 seconds |
4.81 |
2.03 |
26 |
- |
| stream-10000000805-1 |
FINISHED |
36113d14-208c-4dfc-bbed-254bb90deaa4 |
8147017d-4042-42a2-9028-5dcdae679bc5 |
2026/06/06 13:56:08 |
12 minutes 56 seconds |
1.67 |
0.88 |
27 |
- |
| stream-10000000803-1 |
FINISHED |
ae519c66-5a14-4c5b-84ec-710c4fa2d3a2 |
5e57e191-5e11-4e69-b2d7-4603631ea26b |
2026/06/06 13:45:08 |
13 minutes 46 seconds |
63.82 |
28.53 |
25 |
- |