crp-order-quantity-kpi-service - Stages for All Jobs

Completed Stages: 36
Skipped Stages: 32

Fair Scheduler Pools (1001)

Pool Name	Minimum Share	Pool Weight	SchedulingMode
tenants-pool-1	1	1	FAIR
tenants-pool-606	1	1	FAIR
tenants-pool-449	1	1	FAIR
tenants-pool-212	1	1	FAIR
tenants-pool-881	1	1	FAIR
tenants-pool-111	1	1	FAIR
tenants-pool-171	1	1	FAIR
tenants-pool-793	1	1	FAIR
tenants-pool-374	1	1	FAIR
tenants-pool-274	1	1	FAIR
tenants-pool-65	1	1	FAIR
tenants-pool-267	1	1	FAIR
tenants-pool-475	1	1	FAIR
tenants-pool-804	1	1	FAIR
tenants-pool-25	1	1	FAIR
tenants-pool-27	1	1	FAIR
tenants-pool-59	1	1	FAIR
tenants-pool-155	1	1	FAIR
tenants-pool-461	1	1	FAIR
tenants-pool-165	1	1	FAIR
tenants-pool-726	1	1	FAIR
tenants-pool-535	1	1	FAIR
tenants-pool-969	1	1	FAIR
tenants-pool-817	1	1	FAIR
tenants-pool-130	1	1	FAIR
tenants-pool-861	1	1	FAIR
tenants-pool-235	1	1	FAIR
tenants-pool-942	1	1	FAIR
tenants-pool-654	1	1	FAIR
tenants-pool-984	1	1	FAIR
tenants-pool-546	1	1	FAIR
tenants-pool-898	1	1	FAIR
tenants-pool-640	1	1	FAIR
tenants-pool-95	1	1	FAIR
tenants-pool-268	1	1	FAIR
tenants-pool-447	1	1	FAIR
tenants-pool-316	1	1	FAIR
tenants-pool-766	1	1	FAIR
tenants-pool-342	1	1	FAIR
tenants-pool-136	1	1	FAIR
tenants-pool-983	1	1	FAIR
tenants-pool-294	1	1	FAIR
tenants-pool-960	1	1	FAIR
tenants-pool-700	1	1	FAIR
tenants-pool-899	1	1	FAIR
tenants-pool-7	1	1	FAIR
tenants-pool-210	1	1	FAIR
tenants-pool-262	1	1	FAIR
tenants-pool-632	1	1	FAIR
tenants-pool-295	1	1	FAIR
tenants-pool-973	1	1	FAIR
tenants-pool-123	1	1	FAIR
tenants-pool-332	1	1	FAIR
tenants-pool-545	1	1	FAIR
tenants-pool-372	1	1	FAIR
tenants-pool-301	1	1	FAIR
tenants-pool-663	1	1	FAIR
tenants-pool-808	1	1	FAIR
tenants-pool-71	1	1	FAIR
tenants-pool-883	1	1	FAIR
tenants-pool-483	1	1	FAIR
tenants-pool-516	1	1	FAIR
tenants-pool-90	1	1	FAIR
tenants-pool-399	1	1	FAIR
tenants-pool-175	1	1	FAIR
tenants-pool-887	1	1	FAIR
tenants-pool-21	1	1	FAIR
tenants-pool-946	1	1	FAIR
tenants-pool-811	1	1	FAIR
tenants-pool-251	1	1	FAIR
tenants-pool-466	1	1	FAIR
tenants-pool-715	1	1	FAIR
tenants-pool-150	1	1	FAIR
tenants-pool-650	1	1	FAIR
tenants-pool-875	1	1	FAIR
tenants-pool-690	1	1	FAIR
tenants-pool-354	1	1	FAIR
tenants-pool-383	1	1	FAIR
tenants-pool-617	1	1	FAIR
tenants-pool-618	1	1	FAIR
tenants-pool-335	1	1	FAIR
tenants-pool-772	1	1	FAIR
tenants-pool-713	1	1	FAIR
tenants-pool-365	1	1	FAIR
tenants-pool-566	1	1	FAIR
tenants-pool-334	1	1	FAIR
tenants-pool-806	1	1	FAIR
tenants-pool-263	1	1	FAIR
tenants-pool-697	1	1	FAIR
tenants-pool-328	1	1	FAIR
tenants-pool-98	1	1	FAIR
tenants-pool-162	1	1	FAIR
tenants-pool-126	1	1	FAIR
tenants-pool-553	1	1	FAIR
tenants-pool-825	1	1	FAIR
tenants-pool-761	1	1	FAIR
tenants-pool-324	1	1	FAIR
tenants-pool-482	1	1	FAIR
tenants-pool-406	1	1	FAIR
tenants-pool-135	1	1	FAIR
tenants-pool-538	1	1	FAIR
tenants-pool-442	1	1	FAIR
tenants-pool-434	1	1	FAIR
tenants-pool-257	1	1	FAIR
tenants-pool-487	1	1	FAIR
tenants-pool-672	1	1	FAIR
tenants-pool-500	1	1	FAIR
tenants-pool-305	1	1	FAIR
tenants-pool-903	1	1	FAIR
tenants-pool-616	1	1	FAIR
tenants-pool-412	1	1	FAIR
tenants-pool-170	1	1	FAIR
tenants-pool-803	1	1	FAIR
tenants-pool-815	1	1	FAIR
tenants-pool-493	1	1	FAIR
tenants-pool-832	1	1	FAIR
tenants-pool-57	1	1	FAIR
tenants-pool-182	1	1	FAIR
tenants-pool-555	1	1	FAIR
tenants-pool-82	1	1	FAIR
tenants-pool-794	1	1	FAIR
tenants-pool-512	1	1	FAIR
tenants-pool-508	1	1	FAIR
tenants-pool-597	1	1	FAIR
tenants-pool-965	1	1	FAIR
tenants-pool-927	1	1	FAIR
tenants-pool-985	1	1	FAIR
tenants-pool-133	1	1	FAIR
tenants-pool-748	1	1	FAIR
tenants-pool-349	1	1	FAIR
tenants-pool-564	1	1	FAIR
tenants-pool-906	1	1	FAIR
tenants-pool-319	1	1	FAIR
tenants-pool-595	1	1	FAIR
tenants-pool-311	1	1	FAIR
tenants-pool-68	1	1	FAIR
tenants-pool-919	1	1	FAIR
tenants-pool-582	1	1	FAIR
tenants-pool-112	1	1	FAIR
tenants-pool-996	1	1	FAIR
tenants-pool-312	1	1	FAIR
tenants-pool-327	1	1	FAIR
tenants-pool-751	1	1	FAIR
tenants-pool-886	1	1	FAIR
tenants-pool-450	1	1	FAIR
tenants-pool-363	1	1	FAIR
tenants-pool-36	1	1	FAIR
tenants-pool-215	1	1	FAIR
tenants-pool-230	1	1	FAIR
tenants-pool-561	1	1	FAIR
tenants-pool-359	1	1	FAIR
tenants-pool-139	1	1	FAIR
tenants-pool-114	1	1	FAIR
tenants-pool-541	1	1	FAIR
tenants-pool-838	1	1	FAIR
tenants-pool-51	1	1	FAIR
tenants-pool-146	1	1	FAIR
tenants-pool-613	1	1	FAIR
tenants-pool-770	1	1	FAIR
tenants-pool-453	1	1	FAIR
tenants-pool-417	1	1	FAIR
tenants-pool-124	1	1	FAIR
tenants-pool-669	1	1	FAIR
tenants-pool-897	1	1	FAIR
tenants-pool-357	1	1	FAIR
tenants-pool-704	1	1	FAIR
tenants-pool-840	1	1	FAIR
tenants-pool-755	1	1	FAIR
tenants-pool-634	1	1	FAIR
tenants-pool-486	1	1	FAIR
tenants-pool-467	1	1	FAIR
tenants-pool-419	1	1	FAIR
tenants-pool-11	1	1	FAIR
tenants-pool-34	1	1	FAIR
tenants-pool-833	1	1	FAIR
tenants-pool-847	1	1	FAIR
tenants-pool-891	1	1	FAIR
tenants-pool-225	1	1	FAIR
tenants-pool-921	1	1	FAIR
tenants-pool-499	1	1	FAIR
tenants-pool-708	1	1	FAIR
tenants-pool-908	1	1	FAIR
tenants-pool-93	1	1	FAIR
tenants-pool-425	1	1	FAIR
tenants-pool-742	1	1	FAIR
tenants-pool-9	1	1	FAIR
tenants-pool-845	1	1	FAIR
tenants-pool-224	1	1	FAIR
tenants-pool-77	1	1	FAIR
tenants-pool-750	1	1	FAIR
tenants-pool-84	1	1	FAIR
tenants-pool-331	1	1	FAIR
tenants-pool-104	1	1	FAIR
tenants-pool-977	1	1	FAIR
tenants-pool-423	1	1	FAIR
tenants-pool-320	1	1	FAIR
tenants-pool-870	1	1	FAIR
tenants-pool-211	1	1	FAIR
tenants-pool-866	1	1	FAIR
tenants-pool-943	1	1	FAIR
tenants-pool-570	1	1	FAIR
tenants-pool-153	1	1	FAIR
tenants-pool-533	1	1	FAIR
tenants-pool-156	1	1	FAIR
tenants-pool-543	1	1	FAIR
tenants-pool-356	1	1	FAIR
tenants-pool-686	1	1	FAIR
tenants-pool-733	1	1	FAIR
tenants-pool-958	1	1	FAIR
tenants-pool-471	1	1	FAIR
tenants-pool-749	1	1	FAIR
tenants-pool-747	1	1	FAIR
tenants-pool-652	1	1	FAIR
tenants-pool-172	1	1	FAIR
tenants-pool-206	1	1	FAIR
tenants-pool-785	1	1	FAIR
tenants-pool-547	1	1	FAIR
tenants-pool-859	1	1	FAIR
tenants-pool-601	1	1	FAIR
tenants-pool-364	1	1	FAIR
tenants-pool-729	1	1	FAIR
tenants-pool-444	1	1	FAIR
tenants-pool-885	1	1	FAIR
tenants-pool-280	1	1	FAIR
tenants-pool-720	1	1	FAIR
tenants-pool-834	1	1	FAIR
tenants-pool-443	1	1	FAIR
tenants-pool-402	1	1	FAIR
tenants-pool-646	1	1	FAIR
tenants-pool-395	1	1	FAIR
tenants-pool-527	1	1	FAIR
tenants-pool-665	1	1	FAIR
tenants-pool-246	1	1	FAIR
tenants-pool-659	1	1	FAIR
tenants-pool-913	1	1	FAIR
tenants-pool-53	1	1	FAIR
tenants-pool-87	1	1	FAIR
tenants-pool-689	1	1	FAIR
tenants-pool-773	1	1	FAIR
tenants-pool-384	1	1	FAIR
tenants-pool-642	1	1	FAIR
tenants-pool-439	1	1	FAIR
tenants-pool-974	1	1	FAIR
tenants-pool-829	1	1	FAIR
tenants-pool-217	1	1	FAIR
tenants-pool-99	1	1	FAIR
tenants-pool-15	1	1	FAIR
tenants-pool-567	1	1	FAIR
tenants-pool-23	1	1	FAIR
tenants-pool-187	1	1	FAIR
tenants-pool-878	1	1	FAIR
tenants-pool-559	1	1	FAIR
tenants-pool-193	1	1	FAIR
tenants-pool-740	1	1	FAIR
tenants-pool-129	1	1	FAIR
tenants-pool-188	1	1	FAIR
tenants-pool-348	1	1	FAIR
tenants-pool-721	1	1	FAIR
tenants-pool-345	1	1	FAIR
tenants-pool-822	1	1	FAIR
tenants-pool-300	1	1	FAIR
tenants-pool-837	1	1	FAIR
tenants-pool-534	1	1	FAIR
tenants-pool-168	1	1	FAIR
tenants-pool-581	1	1	FAIR
tenants-pool-496	1	1	FAIR
tenants-pool-853	1	1	FAIR
tenants-pool-879	1	1	FAIR
tenants-pool-577	1	1	FAIR
tenants-pool-189	1	1	FAIR
tenants-pool-831	1	1	FAIR
tenants-pool-437	1	1	FAIR
tenants-pool-427	1	1	FAIR
tenants-pool-196	1	1	FAIR
tenants-pool-186	1	1	FAIR
tenants-pool-776	1	1	FAIR
tenants-pool-46	1	1	FAIR
tenants-pool-462	1	1	FAIR
tenants-pool-370	1	1	FAIR
tenants-pool-586	1	1	FAIR
tenants-pool-738	1	1	FAIR
tenants-pool-722	1	1	FAIR
tenants-pool-775	1	1	FAIR
tenants-pool-756	1	1	FAIR
tenants-pool-693	1	1	FAIR
tenants-pool-578	1	1	FAIR
tenants-pool-849	1	1	FAIR
tenants-pool-67	1	1	FAIR
tenants-pool-455	1	1	FAIR
tenants-pool-101	1	1	FAIR
tenants-pool-951	1	1	FAIR
tenants-pool-231	1	1	FAIR
tenants-pool-641	1	1	FAIR
tenants-pool-563	1	1	FAIR
tenants-pool-688	1	1	FAIR
tenants-pool-656	1	1	FAIR
tenants-pool-433	1	1	FAIR
tenants-pool-375	1	1	FAIR
tenants-pool-115	1	1	FAIR
tenants-pool-152	1	1	FAIR
tenants-pool-299	1	1	FAIR
tenants-pool-490	1	1	FAIR
tenants-pool-336	1	1	FAIR
tenants-pool-819	1	1	FAIR
tenants-pool-746	1	1	FAIR
tenants-pool-769	1	1	FAIR
tenants-pool-89	1	1	FAIR
tenants-pool-530	1	1	FAIR
tenants-pool-318	1	1	FAIR
tenants-pool-226	1	1	FAIR
tenants-pool-108	1	1	FAIR
tenants-pool-79	1	1	FAIR
tenants-pool-494	1	1	FAIR
tenants-pool-415	1	1	FAIR
tenants-pool-975	1	1	FAIR
tenants-pool-633	1	1	FAIR
tenants-pool-214	1	1	FAIR
tenants-pool-223	1	1	FAIR
tenants-pool-254	1	1	FAIR
tenants-pool-695	1	1	FAIR
tenants-pool-529	1	1	FAIR
tenants-pool-351	1	1	FAIR
tenants-pool-964	1	1	FAIR
tenants-pool-651	1	1	FAIR
tenants-pool-147	1	1	FAIR
tenants-pool-850	1	1	FAIR
tenants-pool-107	1	1	FAIR
tenants-pool-605	1	1	FAIR
tenants-pool-408	1	1	FAIR
tenants-pool-645	1	1	FAIR
tenants-pool-667	1	1	FAIR
tenants-pool-380	1	1	FAIR
tenants-pool-655	1	1	FAIR
tenants-pool-208	1	1	FAIR
tenants-pool-347	1	1	FAIR
tenants-pool-317	1	1	FAIR
tenants-pool-60	1	1	FAIR
tenants-pool-988	1	1	FAIR
tenants-pool-35	1	1	FAIR
tenants-pool-603	1	1	FAIR
tenants-pool-373	1	1	FAIR
tenants-pool-245	1	1	FAIR
tenants-pool-896	1	1	FAIR
tenants-pool-624	1	1	FAIR
tenants-pool-308	1	1	FAIR
tenants-pool-275	1	1	FAIR
tenants-pool-397	1	1	FAIR
tenants-pool-705	1	1	FAIR
tenants-pool-249	1	1	FAIR
tenants-pool-391	1	1	FAIR
tenants-pool-199	1	1	FAIR
tenants-pool-75	1	1	FAIR
tenants-pool-513	1	1	FAIR
tenants-pool-526	1	1	FAIR
tenants-pool-691	1	1	FAIR
tenants-pool-4	1	1	FAIR
tenants-pool-867	1	1	FAIR
tenants-pool-457	1	1	FAIR
tenants-pool-813	1	1	FAIR
tenants-pool-609	1	1	FAIR
tenants-pool-472	1	1	FAIR
tenants-pool-852	1	1	FAIR
tenants-pool-218	1	1	FAIR
tenants-pool-346	1	1	FAIR
tenants-pool-220	1	1	FAIR
tenants-pool-580	1	1	FAIR
tenants-pool-912	1	1	FAIR
tenants-pool-404	1	1	FAIR
tenants-pool-304	1	1	FAIR
tenants-pool-238	1	1	FAIR
tenants-pool-413	1	1	FAIR
tenants-pool-37	1	1	FAIR
tenants-pool-333	1	1	FAIR
tenants-pool-991	1	1	FAIR
tenants-pool-678	1	1	FAIR
tenants-pool-284	1	1	FAIR
tenants-pool-702	1	1	FAIR
tenants-pool-105	1	1	FAIR
tenants-pool-19	1	1	FAIR
tenants-pool-507	1	1	FAIR
tenants-pool-727	1	1	FAIR
tenants-pool-73	1	1	FAIR
tenants-pool-452	1	1	FAIR
tenants-pool-179	1	1	FAIR
tenants-pool-814	1	1	FAIR
tenants-pool-587	1	1	FAIR
tenants-pool-118	1	1	FAIR
tenants-pool-795	1	1	FAIR
tenants-pool-122	1	1	FAIR
tenants-pool-621	1	1	FAIR
tenants-pool-993	1	1	FAIR
tenants-pool-759	1	1	FAIR
tenants-pool-992	1	1	FAIR
tenants-pool-799	1	1	FAIR
tenants-pool-594	1	1	FAIR
tenants-pool-514	1	1	FAIR
tenants-pool-995	1	1	FAIR
tenants-pool-608	1	1	FAIR
tenants-pool-405	1	1	FAIR
tenants-pool-765	1	1	FAIR
tenants-pool-502	1	1	FAIR
tenants-pool-868	1	1	FAIR
tenants-pool-479	1	1	FAIR
tenants-pool-132	1	1	FAIR
tenants-pool-711	1	1	FAIR
tenants-pool-556	1	1	FAIR
tenants-pool-92	1	1	FAIR
tenants-pool-205	1	1	FAIR
tenants-pool-938	1	1	FAIR
tenants-pool-498	1	1	FAIR
tenants-pool-438	1	1	FAIR
tenants-pool-532	1	1	FAIR
tenants-pool-754	1	1	FAIR
tenants-pool-0	1	1	FAIR
tenants-pool-192	1	1	FAIR
tenants-pool-900	1	1	FAIR
tenants-pool-522	1	1	FAIR
tenants-pool-259	1	1	FAIR
tenants-pool-862	1	1	FAIR
tenants-pool-858	1	1	FAIR
tenants-pool-698	1	1	FAIR
tenants-pool-198	1	1	FAIR
tenants-pool-302	1	1	FAIR
tenants-pool-620	1	1	FAIR
tenants-pool-435	1	1	FAIR
tenants-pool-55	1	1	FAIR
tenants-pool-297	1	1	FAIR
tenants-pool-163	1	1	FAIR
tenants-pool-857	1	1	FAIR
tenants-pool-590	1	1	FAIR
tenants-pool-41	1	1	FAIR
tenants-pool-164	1	1	FAIR
tenants-pool-436	1	1	FAIR
tenants-pool-824	1	1	FAIR
tenants-pool-920	1	1	FAIR
tenants-pool-17	1	1	FAIR
tenants-pool-855	1	1	FAIR
tenants-pool-863	1	1	FAIR
tenants-pool-789	1	1	FAIR
tenants-pool-752	1	1	FAIR
tenants-pool-314	1	1	FAIR
tenants-pool-279	1	1	FAIR
tenants-pool-240	1	1	FAIR
tenants-pool-228	1	1	FAIR
tenants-pool-454	1	1	FAIR
tenants-pool-660	1	1	FAIR
tenants-pool-549	1	1	FAIR
tenants-pool-626	1	1	FAIR
tenants-pool-583	1	1	FAIR
tenants-pool-579	1	1	FAIR
tenants-pool-352	1	1	FAIR
tenants-pool-843	1	1	FAIR
tenants-pool-568	1	1	FAIR
tenants-pool-701	1	1	FAIR
tenants-pool-787	1	1	FAIR
tenants-pool-676	1	1	FAIR
tenants-pool-916	1	1	FAIR
tenants-pool-272	1	1	FAIR
tenants-pool-880	1	1	FAIR
tenants-pool-361	1	1	FAIR
tenants-pool-463	1	1	FAIR
tenants-pool-779	1	1	FAIR
tenants-pool-517	1	1	FAIR
tenants-pool-495	1	1	FAIR
tenants-pool-622	1	1	FAIR
tenants-pool-562	1	1	FAIR
tenants-pool-22	1	1	FAIR
tenants-pool-177	1	1	FAIR
tenants-pool-271	1	1	FAIR
tenants-pool-682	1	1	FAIR
tenants-pool-911	1	1	FAIR
tenants-pool-94	1	1	FAIR
tenants-pool-368	1	1	FAIR
tenants-pool-888	1	1	FAIR
tenants-pool-5	1	1	FAIR
tenants-pool-20	1	1	FAIR
tenants-pool-3	1	1	FAIR
tenants-pool-253	1	1	FAIR
tenants-pool-474	1	1	FAIR
tenants-pool-396	1	1	FAIR
tenants-pool-575	1	1	FAIR
tenants-pool-647	1	1	FAIR
tenants-pool-270	1	1	FAIR
tenants-pool-287	1	1	FAIR
tenants-pool-16	1	1	FAIR
tenants-pool-909	1	1	FAIR
tenants-pool-141	1	1	FAIR
tenants-pool-631	1	1	FAIR
tenants-pool-176	1	1	FAIR
tenants-pool-658	1	1	FAIR
tenants-pool-925	1	1	FAIR
tenants-pool-524	1	1	FAIR
tenants-pool-805	1	1	FAIR
tenants-pool-551	1	1	FAIR
tenants-pool-600	1	1	FAIR
tenants-pool-882	1	1	FAIR
tenants-pool-923	1	1	FAIR
tenants-pool-127	1	1	FAIR
tenants-pool-557	1	1	FAIR
tenants-pool-45	1	1	FAIR
tenants-pool-854	1	1	FAIR
tenants-pool-100	1	1	FAIR
tenants-pool-501	1	1	FAIR
tenants-pool-892	1	1	FAIR
tenants-pool-979	1	1	FAIR
tenants-pool-598	1	1	FAIR
tenants-pool-989	1	1	FAIR
tenants-pool-307	1	1	FAIR
tenants-pool-69	1	1	FAIR
tenants-pool-531	1	1	FAIR
tenants-pool-325	1	1	FAIR
tenants-pool-699	1	1	FAIR
tenants-pool-29	1	1	FAIR
tenants-pool-221	1	1	FAIR
tenants-pool-239	1	1	FAIR
tenants-pool-791	1	1	FAIR
tenants-pool-277	1	1	FAIR
tenants-pool-340	1	1	FAIR
tenants-pool-687	1	1	FAIR
tenants-pool-2	1	1	FAIR
tenants-pool-572	1	1	FAIR
tenants-pool-183	1	1	FAIR
tenants-pool-542	1	1	FAIR
tenants-pool-997	1	1	FAIR
tenants-pool-576	1	1	FAIR
tenants-pool-877	1	1	FAIR
tenants-pool-33	1	1	FAIR
tenants-pool-809	1	1	FAIR
tenants-pool-810	1	1	FAIR
tenants-pool-10	1	1	FAIR
tenants-pool-639	1	1	FAIR
tenants-pool-460	1	1	FAIR
tenants-pool-12	1	1	FAIR
tenants-pool-40	1	1	FAIR
tenants-pool-955	1	1	FAIR
tenants-pool-6	1	1	FAIR
tenants-pool-978	1	1	FAIR
tenants-pool-653	1	1	FAIR
tenants-pool-303	1	1	FAIR
tenants-pool-800	1	1	FAIR
tenants-pool-944	1	1	FAIR
tenants-pool-306	1	1	FAIR
tenants-pool-901	1	1	FAIR
tenants-pool-381	1	1	FAIR
tenants-pool-963	1	1	FAIR
tenants-pool-173	1	1	FAIR
tenants-pool-801	1	1	FAIR
tenants-pool-744	1	1	FAIR
tenants-pool-237	1	1	FAIR
tenants-pool-510	1	1	FAIR
tenants-pool-169	1	1	FAIR
tenants-pool-725	1	1	FAIR
tenants-pool-818	1	1	FAIR
tenants-pool-706	1	1	FAIR
tenants-pool-209	1	1	FAIR
tenants-pool-39	1	1	FAIR
tenants-pool-730	1	1	FAIR
tenants-pool-113	1	1	FAIR
tenants-pool-355	1	1	FAIR
tenants-pool-739	1	1	FAIR
tenants-pool-31	1	1	FAIR
tenants-pool-884	1	1	FAIR
tenants-pool-491	1	1	FAIR
tenants-pool-511	1	1	FAIR
tenants-pool-596	1	1	FAIR
tenants-pool-371	1	1	FAIR
tenants-pool-939	1	1	FAIR
tenants-pool-835	1	1	FAIR
tenants-pool-871	1	1	FAIR
tenants-pool-703	1	1	FAIR
tenants-pool-48	1	1	FAIR
tenants-pool-219	1	1	FAIR
tenants-pool-353	1	1	FAIR
tenants-pool-636	1	1	FAIR
tenants-pool-889	1	1	FAIR
tenants-pool-376	1	1	FAIR
tenants-pool-96	1	1	FAIR
tenants-pool-990	1	1	FAIR
tenants-pool-382	1	1	FAIR
tenants-pool-937	1	1	FAIR
tenants-pool-917	1	1	FAIR
tenants-pool-145	1	1	FAIR
tenants-pool-525	1	1	FAIR
tenants-pool-403	1	1	FAIR
tenants-pool-125	1	1	FAIR
tenants-pool-184	1	1	FAIR
tenants-pool-986	1	1	FAIR
tenants-pool-872	1	1	FAIR
tenants-pool-767	1	1	FAIR
tenants-pool-540	1	1	FAIR
tenants-pool-503	1	1	FAIR
tenants-pool-379	1	1	FAIR
tenants-pool-732	1	1	FAIR
tenants-pool-630	1	1	FAIR
tenants-pool-717	1	1	FAIR
tenants-pool-780	1	1	FAIR
tenants-pool-106	1	1	FAIR
tenants-pool-64	1	1	FAIR
tenants-pool-61	1	1	FAIR
tenants-pool-607	1	1	FAIR
tenants-pool-137	1	1	FAIR
tenants-pool-190	1	1	FAIR
tenants-pool-820	1	1	FAIR
tenants-pool-362	1	1	FAIR
tenants-pool-692	1	1	FAIR
tenants-pool-504	1	1	FAIR
tenants-pool-200	1	1	FAIR
tenants-pool-81	1	1	FAIR
tenants-pool-286	1	1	FAIR
tenants-pool-664	1	1	FAIR
tenants-pool-394	1	1	FAIR
tenants-pool-936	1	1	FAIR
tenants-pool-679	1	1	FAIR
tenants-pool-298	1	1	FAIR
tenants-pool-544	1	1	FAIR
tenants-pool-836	1	1	FAIR
tenants-pool-783	1	1	FAIR
tenants-pool-266	1	1	FAIR
tenants-pool-666	1	1	FAIR
tenants-pool-401	1	1	FAIR
tenants-pool-792	1	1	FAIR
default	0	1	FIFO
tenants-pool-418	1	1	FAIR
tenants-pool-623	1	1	FAIR
tenants-pool-591	1	1	FAIR
tenants-pool-539	1	1	FAIR
tenants-pool-782	1	1	FAIR
tenants-pool-260	1	1	FAIR
tenants-pool-288	1	1	FAIR
tenants-pool-905	1	1	FAIR
tenants-pool-411	1	1	FAIR
tenants-pool-994	1	1	FAIR
tenants-pool-119	1	1	FAIR
tenants-pool-120	1	1	FAIR
tenants-pool-83	1	1	FAIR
tenants-pool-611	1	1	FAIR
tenants-pool-874	1	1	FAIR
tenants-pool-719	1	1	FAIR
tenants-pool-229	1	1	FAIR
tenants-pool-421	1	1	FAIR
tenants-pool-131	1	1	FAIR
tenants-pool-934	1	1	FAIR
tenants-pool-904	1	1	FAIR
tenants-pool-771	1	1	FAIR
tenants-pool-236	1	1	FAIR
tenants-pool-926	1	1	FAIR
tenants-pool-893	1	1	FAIR
tenants-pool-758	1	1	FAIR
tenants-pool-222	1	1	FAIR
tenants-pool-764	1	1	FAIR
tenants-pool-398	1	1	FAIR
tenants-pool-644	1	1	FAIR
tenants-pool-216	1	1	FAIR
tenants-pool-134	1	1	FAIR
tenants-pool-668	1	1	FAIR
tenants-pool-707	1	1	FAIR
tenants-pool-876	1	1	FAIR
tenants-pool-743	1	1	FAIR
tenants-pool-826	1	1	FAIR
tenants-pool-941	1	1	FAIR
tenants-pool-42	1	1	FAIR
tenants-pool-929	1	1	FAIR
tenants-pool-28	1	1	FAIR
tenants-pool-710	1	1	FAIR
tenants-pool-456	1	1	FAIR
tenants-pool-24	1	1	FAIR
tenants-pool-673	1	1	FAIR
tenants-pool-565	1	1	FAIR
tenants-pool-967	1	1	FAIR
tenants-pool-823	1	1	FAIR
tenants-pool-593	1	1	FAIR
tenants-pool-282	1	1	FAIR
tenants-pool-344	1	1	FAIR
tenants-pool-935	1	1	FAIR
tenants-pool-589	1	1	FAIR
tenants-pool-736	1	1	FAIR
tenants-pool-865	1	1	FAIR
tenants-pool-38	1	1	FAIR
tenants-pool-509	1	1	FAIR
tenants-pool-292	1	1	FAIR
tenants-pool-515	1	1	FAIR
tenants-pool-971	1	1	FAIR
tenants-pool-258	1	1	FAIR
tenants-pool-573	1	1	FAIR
tenants-pool-981	1	1	FAIR
tenants-pool-414	1	1	FAIR
tenants-pool-451	1	1	FAIR
tenants-pool-337	1	1	FAIR
tenants-pool-571	1	1	FAIR
tenants-pool-604	1	1	FAIR
tenants-pool-167	1	1	FAIR
tenants-pool-250	1	1	FAIR
tenants-pool-185	1	1	FAIR
tenants-pool-465	1	1	FAIR
tenants-pool-441	1	1	FAIR
tenants-pool-393	1	1	FAIR
tenants-pool-696	1	1	FAIR
tenants-pool-628	1	1	FAIR
tenants-pool-194	1	1	FAIR
tenants-pool-289	1	1	FAIR
tenants-pool-142	1	1	FAIR
tenants-pool-523	1	1	FAIR
tenants-pool-873	1	1	FAIR
tenants-pool-464	1	1	FAIR
tenants-pool-389	1	1	FAIR
tenants-pool-49	1	1	FAIR
tenants-pool-283	1	1	FAIR
tenants-pool-30	1	1	FAIR
tenants-pool-536	1	1	FAIR
tenants-pool-91	1	1	FAIR
tenants-pool-392	1	1	FAIR
tenants-pool-388	1	1	FAIR
tenants-pool-592	1	1	FAIR
tenants-pool-458	1	1	FAIR
tenants-pool-537	1	1	FAIR
tenants-pool-728	1	1	FAIR
tenants-pool-160	1	1	FAIR
tenants-pool-109	1	1	FAIR
tenants-pool-712	1	1	FAIR
tenants-pool-400	1	1	FAIR
tenants-pool-922	1	1	FAIR
tenants-pool-528	1	1	FAIR
tenants-pool-315	1	1	FAIR
tenants-pool-677	1	1	FAIR
tenants-pool-851	1	1	FAIR
tenants-pool-174	1	1	FAIR
tenants-pool-560	1	1	FAIR
tenants-pool-78	1	1	FAIR
tenants-pool-151	1	1	FAIR
tenants-pool-385	1	1	FAIR
tenants-pool-66	1	1	FAIR
tenants-pool-671	1	1	FAIR
tenants-pool-661	1	1	FAIR
tenants-pool-140	1	1	FAIR
tenants-pool-407	1	1	FAIR
tenants-pool-468	1	1	FAIR
tenants-pool-424	1	1	FAIR
tenants-pool-827	1	1	FAIR
tenants-pool-58	1	1	FAIR
tenants-pool-309	1	1	FAIR
tenants-pool-768	1	1	FAIR
tenants-pool-895	1	1	FAIR
tenants-pool-724	1	1	FAIR
tenants-pool-269	1	1	FAIR
tenants-pool-144	1	1	FAIR
tenants-pool-648	1	1	FAIR
tenants-pool-121	1	1	FAIR
tenants-pool-255	1	1	FAIR
tenants-pool-409	1	1	FAIR
tenants-pool-681	1	1	FAIR
tenants-pool-477	1	1	FAIR
tenants-pool-201	1	1	FAIR
tenants-pool-619	1	1	FAIR
tenants-pool-635	1	1	FAIR
tenants-pool-970	1	1	FAIR
tenants-pool-521	1	1	FAIR
tenants-pool-734	1	1	FAIR
tenants-pool-232	1	1	FAIR
tenants-pool-760	1	1	FAIR
tenants-pool-338	1	1	FAIR
tenants-pool-786	1	1	FAIR
tenants-pool-445	1	1	FAIR
tenants-pool-980	1	1	FAIR
tenants-pool-846	1	1	FAIR
tenants-pool-244	1	1	FAIR
tenants-pool-718	1	1	FAIR
tenants-pool-138	1	1	FAIR
tenants-pool-788	1	1	FAIR
tenants-pool-924	1	1	FAIR
tenants-pool-638	1	1	FAIR
tenants-pool-330	1	1	FAIR
tenants-pool-116	1	1	FAIR
tenants-pool-940	1	1	FAIR
tenants-pool-473	1	1	FAIR
tenants-pool-548	1	1	FAIR
tenants-pool-902	1	1	FAIR
tenants-pool-657	1	1	FAIR
tenants-pool-256	1	1	FAIR
tenants-pool-763	1	1	FAIR
tenants-pool-952	1	1	FAIR
tenants-pool-341	1	1	FAIR
tenants-pool-550	1	1	FAIR
tenants-pool-178	1	1	FAIR
tenants-pool-367	1	1	FAIR
tenants-pool-202	1	1	FAIR
tenants-pool-485	1	1	FAIR
tenants-pool-492	1	1	FAIR
tenants-pool-243	1	1	FAIR
tenants-pool-662	1	1	FAIR
tenants-pool-80	1	1	FAIR
tenants-pool-518	1	1	FAIR
tenants-pool-265	1	1	FAIR
tenants-pool-62	1	1	FAIR
tenants-pool-321	1	1	FAIR
tenants-pool-612	1	1	FAIR
tenants-pool-830	1	1	FAIR
tenants-pool-181	1	1	FAIR
tenants-pool-149	1	1	FAIR
tenants-pool-762	1	1	FAIR
tenants-pool-387	1	1	FAIR
tenants-pool-366	1	1	FAIR
tenants-pool-157	1	1	FAIR
tenants-pool-47	1	1	FAIR
tenants-pool-972	1	1	FAIR
tenants-pool-377	1	1	FAIR
tenants-pool-554	1	1	FAIR
tenants-pool-26	1	1	FAIR
tenants-pool-429	1	1	FAIR
tenants-pool-753	1	1	FAIR
tenants-pool-584	1	1	FAIR
tenants-pool-102	1	1	FAIR
tenants-pool-954	1	1	FAIR
tenants-pool-44	1	1	FAIR
tenants-pool-709	1	1	FAIR
tenants-pool-18	1	1	FAIR
tenants-pool-293	1	1	FAIR
tenants-pool-933	1	1	FAIR
tenants-pool-143	1	1	FAIR
tenants-pool-410	1	1	FAIR
tenants-pool-117	1	1	FAIR
tenants-pool-585	1	1	FAIR
tenants-pool-737	1	1	FAIR
tenants-pool-948	1	1	FAIR
tenants-pool-928	1	1	FAIR
tenants-pool-860	1	1	FAIR
tenants-pool-480	1	1	FAIR
tenants-pool-261	1	1	FAIR
tenants-pool-894	1	1	FAIR
tenants-pool-968	1	1	FAIR
tenants-pool-842	1	1	FAIR
tenants-pool-552	1	1	FAIR
tenants-pool-431	1	1	FAIR
tenants-pool-950	1	1	FAIR
tenants-pool-74	1	1	FAIR
tenants-pool-291	1	1	FAIR
tenants-pool-76	1	1	FAIR
tenants-pool-519	1	1	FAIR
tenants-pool-430	1	1	FAIR
tenants-pool-128	1	1	FAIR
tenants-pool-959	1	1	FAIR
tenants-pool-790	1	1	FAIR
tenants-pool-343	1	1	FAIR
tenants-pool-148	1	1	FAIR
tenants-pool-745	1	1	FAIR
tenants-pool-914	1	1	FAIR
tenants-pool-154	1	1	FAIR
tenants-pool-610	1	1	FAIR
tenants-pool-674	1	1	FAIR
tenants-pool-285	1	1	FAIR
tenants-pool-469	1	1	FAIR
tenants-pool-777	1	1	FAIR
tenants-pool-982	1	1	FAIR
tenants-pool-558	1	1	FAIR
tenants-pool-195	1	1	FAIR
tenants-pool-627	1	1	FAIR
tenants-pool-797	1	1	FAIR
tenants-pool-50	1	1	FAIR
tenants-pool-276	1	1	FAIR
tenants-pool-378	1	1	FAIR
tenants-pool-675	1	1	FAIR
tenants-pool-484	1	1	FAIR
tenants-pool-32	1	1	FAIR
tenants-pool-774	1	1	FAIR
tenants-pool-497	1	1	FAIR
tenants-pool-757	1	1	FAIR
tenants-pool-432	1	1	FAIR
tenants-pool-426	1	1	FAIR
tenants-pool-945	1	1	FAIR
tenants-pool-599	1	1	FAIR
tenants-pool-615	1	1	FAIR
tenants-pool-360	1	1	FAIR
tenants-pool-930	1	1	FAIR
tenants-pool-684	1	1	FAIR
tenants-pool-489	1	1	FAIR
tenants-pool-670	1	1	FAIR
tenants-pool-931	1	1	FAIR
tenants-pool-241	1	1	FAIR
tenants-pool-588	1	1	FAIR
tenants-pool-278	1	1	FAIR
tenants-pool-103	1	1	FAIR
tenants-pool-505	1	1	FAIR
tenants-pool-506	1	1	FAIR
tenants-pool-63	1	1	FAIR
tenants-pool-520	1	1	FAIR
tenants-pool-602	1	1	FAIR
tenants-pool-949	1	1	FAIR
tenants-pool-731	1	1	FAIR
tenants-pool-574	1	1	FAIR
tenants-pool-629	1	1	FAIR
tenants-pool-180	1	1	FAIR
tenants-pool-191	1	1	FAIR
tenants-pool-569	1	1	FAIR
tenants-pool-296	1	1	FAIR
tenants-pool-998	1	1	FAIR
tenants-pool-197	1	1	FAIR
tenants-pool-350	1	1	FAIR
tenants-pool-716	1	1	FAIR
tenants-pool-213	1	1	FAIR
tenants-pool-14	1	1	FAIR
tenants-pool-864	1	1	FAIR
tenants-pool-694	1	1	FAIR
tenants-pool-247	1	1	FAIR
tenants-pool-918	1	1	FAIR
tenants-pool-478	1	1	FAIR
tenants-pool-13	1	1	FAIR
tenants-pool-987	1	1	FAIR
tenants-pool-476	1	1	FAIR
tenants-pool-159	1	1	FAIR
tenants-pool-962	1	1	FAIR
tenants-pool-329	1	1	FAIR
tenants-pool-54	1	1	FAIR
tenants-pool-869	1	1	FAIR
tenants-pool-741	1	1	FAIR
tenants-pool-828	1	1	FAIR
tenants-pool-714	1	1	FAIR
tenants-pool-802	1	1	FAIR
tenants-pool-43	1	1	FAIR
tenants-pool-233	1	1	FAIR
tenants-pool-821	1	1	FAIR
tenants-pool-956	1	1	FAIR
tenants-pool-428	1	1	FAIR
tenants-pool-481	1	1	FAIR
tenants-pool-310	1	1	FAIR
tenants-pool-248	1	1	FAIR
tenants-pool-625	1	1	FAIR
tenants-pool-932	1	1	FAIR
tenants-pool-110	1	1	FAIR
tenants-pool-796	1	1	FAIR
tenants-pool-723	1	1	FAIR
tenants-pool-339	1	1	FAIR
tenants-pool-273	1	1	FAIR
tenants-pool-839	1	1	FAIR
tenants-pool-910	1	1	FAIR
tenants-pool-440	1	1	FAIR
tenants-pool-203	1	1	FAIR
tenants-pool-448	1	1	FAIR
tenants-pool-470	1	1	FAIR
tenants-pool-976	1	1	FAIR
tenants-pool-856	1	1	FAIR
tenants-pool-358	1	1	FAIR
tenants-pool-890	1	1	FAIR
tenants-pool-204	1	1	FAIR
tenants-pool-56	1	1	FAIR
tenants-pool-422	1	1	FAIR
tenants-pool-812	1	1	FAIR
tenants-pool-52	1	1	FAIR
tenants-pool-420	1	1	FAIR
tenants-pool-683	1	1	FAIR
tenants-pool-961	1	1	FAIR
tenants-pool-242	1	1	FAIR
tenants-pool-816	1	1	FAIR
tenants-pool-281	1	1	FAIR
tenants-pool-390	1	1	FAIR
tenants-pool-252	1	1	FAIR
tenants-pool-957	1	1	FAIR
tenants-pool-966	1	1	FAIR
tenants-pool-947	1	1	FAIR
tenants-pool-207	1	1	FAIR
tenants-pool-227	1	1	FAIR
tenants-pool-778	1	1	FAIR
tenants-pool-322	1	1	FAIR
tenants-pool-386	1	1	FAIR
tenants-pool-459	1	1	FAIR
tenants-pool-323	1	1	FAIR
tenants-pool-915	1	1	FAIR
tenants-pool-166	1	1	FAIR
tenants-pool-446	1	1	FAIR
tenants-pool-158	1	1	FAIR
tenants-pool-781	1	1	FAIR
tenants-pool-953	1	1	FAIR
tenants-pool-637	1	1	FAIR
tenants-pool-999	1	1	FAIR
tenants-pool-784	1	1	FAIR
tenants-pool-369	1	1	FAIR
tenants-pool-234	1	1	FAIR
tenants-pool-614	1	1	FAIR
tenants-pool-844	1	1	FAIR
tenants-pool-264	1	1	FAIR
tenants-pool-70	1	1	FAIR
tenants-pool-848	1	1	FAIR
tenants-pool-807	1	1	FAIR
tenants-pool-643	1	1	FAIR
tenants-pool-798	1	1	FAIR
tenants-pool-416	1	1	FAIR
tenants-pool-313	1	1	FAIR
tenants-pool-97	1	1	FAIR
tenants-pool-86	1	1	FAIR
tenants-pool-680	1	1	FAIR
tenants-pool-488	1	1	FAIR
tenants-pool-85	1	1	FAIR
tenants-pool-841	1	1	FAIR
tenants-pool-326	1	1	FAIR
tenants-pool-649	1	1	FAIR
tenants-pool-685	1	1	FAIR
tenants-pool-735	1	1	FAIR
tenants-pool-8	1	1	FAIR
tenants-pool-72	1	1	FAIR
tenants-pool-161	1	1	FAIR
tenants-pool-88	1	1	FAIR
tenants-pool-290	1	1	FAIR
tenants-pool-907	1	1	FAIR

Completed Stages (36)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
67	tenants-pool-286	stream-10000000096-1 id = be248029-438e-4f4d-8777-4439f445c07d runId = 49208f80-235d-43ef-8cae-50261bfa1fbb batch = 0 start at FileStorageAdapterImpl.java:171 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	2026/02/06 10:33:55	0.9 s	1/1		32.5 KiB	1413.0 B
62	tenants-pool-286	stream-10000000096-1 id = be248029-438e-4f4d-8777-4439f445c07d runId = 49208f80-235d-43ef-8cae-50261bfa1fbb batch = 0 start at FileStorageAdapterImpl.java:171 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	2026/02/06 10:33:55	0.3 s	1/1			1329.0 B	973.0 B
59	tenants-pool-286	stream-10000000096-1 id = be248029-438e-4f4d-8777-4439f445c07d runId = 49208f80-235d-43ef-8cae-50261bfa1fbb batch = 0 start at FileStorageAdapterImpl.java:171 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	2026/02/06 10:33:53	1 s	4/4				935.0 B
58	tenants-pool-286	stream-10000000096-1 id = be248029-438e-4f4d-8777-4439f445c07d runId = 49208f80-235d-43ef-8cae-50261bfa1fbb batch = 0 start at FileStorageAdapterImpl.java:171 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	2026/02/06 10:33:53	0.1 s	4/4				440.0 B
57	tenants-pool-286	stream-10000000096-1 id = be248029-438e-4f4d-8777-4439f445c07d runId = 49208f80-235d-43ef-8cae-50261bfa1fbb batch = 0 start at FileStorageAdapterImpl.java:171 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	2026/02/06 10:33:53	1 s	4/4				394.0 B
56	tenants-pool-286	stream-10000000096-1 id = be248029-438e-4f4d-8777-4439f445c07d runId = 49208f80-235d-43ef-8cae-50261bfa1fbb batch = 0 start at FileStorageAdapterImpl.java:171 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	2026/02/06 10:33:53	10 ms	1/1
55	tenants-pool-286	stream-10000000096-1 id = be248029-438e-4f4d-8777-4439f445c07d runId = 49208f80-235d-43ef-8cae-50261bfa1fbb batch = 0 start at FileStorageAdapterImpl.java:171 +details RDD: Exchange hashpartitioning(product#1544, plant#1545, 25), REPARTITION_BY_NUM, [plan_id=1315] +- *(1) Scan ExistingRDD[shardId#1541,worklistShardItemId#1542L,version#1543,product#1544,plant#1545,periodStart#1546,periodEnd#1547,qty#1548] org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	2026/02/06 10:33:53	98 ms	25/25
53	tenants-pool-286	stream-10000000096-1 id = be248029-438e-4f4d-8777-4439f445c07d runId = 49208f80-235d-43ef-8cae-50261bfa1fbb batch = 0 start at FileStorageAdapterImpl.java:171 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	2026/02/06 10:33:53	16 ms	1/1	21.0 B
50	tenants-pool-286	stream-10000000096-1 id = be248029-438e-4f4d-8777-4439f445c07d runId = 49208f80-235d-43ef-8cae-50261bfa1fbb batch = 0 start at FileStorageAdapterImpl.java:171 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	2026/02/06 10:33:53	27 ms	1/1
49	tenants-pool-286	stream-10000000096-1 id = be248029-438e-4f4d-8777-4439f445c07d runId = 49208f80-235d-43ef-8cae-50261bfa1fbb batch = 0 start at FileStorageAdapterImpl.java:171 +details RDD: Delta Table State #0 - hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-update/10000000096/stream-10000000096-1/_delta_log org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	2026/02/06 10:33:53	0.1 s	50/50	1485.0 B
47	tenants-pool-286	stream-10000000096-1 id = be248029-438e-4f4d-8777-4439f445c07d runId = 49208f80-235d-43ef-8cae-50261bfa1fbb batch = 0 start at FileStorageAdapterImpl.java:171 +details RDD: Delta Table State #0 - hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-update/10000000096/stream-10000000096-1/_delta_log org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	2026/02/06 10:33:52	0.8 s	50/50			831.0 B
46	tenants-pool-286	stream-10000000096-1 id = be248029-438e-4f4d-8777-4439f445c07d runId = 49208f80-235d-43ef-8cae-50261bfa1fbb batch = 0 start at FileStorageAdapterImpl.java:171 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	2026/02/06 10:33:51	0.3 s	1/1				831.0 B
45	tenants-pool-286	replenishmentRunId = 10000000096 tenantId = 6944346648028224943 activityType = PrepareStreams activityId = c74251b9-bee8-3017-b945-8a3eca197278 workflowType = CalculateOrderProposalsWorkflow workflowId = 9e4477b5-be60-3834-83e9-5b127657b9b8 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD $anonfun$withThreadLocalCaptured$2 at <unknown>:0 +details org.apache.spark.sql.execution.SQLExecution$.$anonfun$withThreadLocalCaptured$2(SQLExecution.scala:316) java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	2026/02/06 10:33:49	0.9 s	1/1		29.4 KiB	266.0 B
40	tenants-pool-286	replenishmentRunId = 10000000096 tenantId = 6944346648028224943 activityType = PrepareStreams activityId = c74251b9-bee8-3017-b945-8a3eca197278 workflowType = CalculateOrderProposalsWorkflow workflowId = 9e4477b5-be60-3834-83e9-5b127657b9b8 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD $anonfun$withThreadLocalCaptured$2 at <unknown>:0 +details org.apache.spark.sql.execution.SQLExecution$.$anonfun$withThreadLocalCaptured$2(SQLExecution.scala:316) java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	2026/02/06 10:33:48	0.4 s	1/1			261.0 B	169.0 B
37	tenants-pool-286	replenishmentRunId = 10000000096 tenantId = 6944346648028224943 activityType = PrepareStreams activityId = c74251b9-bee8-3017-b945-8a3eca197278 workflowType = CalculateOrderProposalsWorkflow workflowId = 9e4477b5-be60-3834-83e9-5b127657b9b8 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD $anonfun$withThreadLocalCaptured$2 at <unknown>:0 +details org.apache.spark.sql.execution.SQLExecution$.$anonfun$withThreadLocalCaptured$2(SQLExecution.scala:316) java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	2026/02/06 10:33:48	0.3 s	1/1				162.0 B
36	tenants-pool-286	replenishmentRunId = 10000000096 tenantId = 6944346648028224943 activityType = PrepareStreams activityId = c74251b9-bee8-3017-b945-8a3eca197278 workflowType = CalculateOrderProposalsWorkflow workflowId = 9e4477b5-be60-3834-83e9-5b127657b9b8 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD $anonfun$withThreadLocalCaptured$2 at <unknown>:0 +details org.apache.spark.sql.execution.SQLExecution$.$anonfun$withThreadLocalCaptured$2(SQLExecution.scala:316) java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	2026/02/06 10:33:48	80 ms	1/1				99.0 B
35	tenants-pool-286	replenishmentRunId = 10000000096 tenantId = 6944346648028224943 activityType = PrepareStreams activityId = c74251b9-bee8-3017-b945-8a3eca197278 workflowType = CalculateOrderProposalsWorkflow workflowId = 9e4477b5-be60-3834-83e9-5b127657b9b8 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD $anonfun$withThreadLocalCaptured$2 at <unknown>:0 +details org.apache.spark.sql.execution.SQLExecution$.$anonfun$withThreadLocalCaptured$2(SQLExecution.scala:316) java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	2026/02/06 10:33:48	0.5 s	1/1				97.0 B
34	tenants-pool-286	replenishmentRunId = 10000000096 tenantId = 6944346648028224943 activityType = PrepareStreams activityId = c74251b9-bee8-3017-b945-8a3eca197278 workflowType = CalculateOrderProposalsWorkflow workflowId = 9e4477b5-be60-3834-83e9-5b127657b9b8 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD save at FileStorageAdapterImpl.java:129 +details org.apache.spark.sql.classic.DataFrameWriter.save(DataFrameWriter.scala:118) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.writeToStorage(FileStorageAdapterImpl.java:129) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.prepareKpiCurveUpdateStream(FileStorageAdapterImpl.java:118) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.prepareStreams(KpiCalculationStreamingActivityImpl.java:47) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	2026/02/06 10:33:45	0.6 s	1/1		1198.0 B
33	tenants-pool-286	stream-10000000095-1 id = 24896f85-9daa-48da-9091-8300a4724264 runId = 838a6e4f-fcfd-48b4-8e86-83234309cbb3 batch = 0 start at FileStorageAdapterImpl.java:171 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	2026/02/06 06:55:22	0.9 s	1/1		32.5 KiB	1446.0 B
28	tenants-pool-286	stream-10000000095-1 id = 24896f85-9daa-48da-9091-8300a4724264 runId = 838a6e4f-fcfd-48b4-8e86-83234309cbb3 batch = 0 start at FileStorageAdapterImpl.java:171 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	2026/02/06 06:55:22	0.3 s	1/1			1356.0 B	1004.0 B
25	tenants-pool-286	stream-10000000095-1 id = 24896f85-9daa-48da-9091-8300a4724264 runId = 838a6e4f-fcfd-48b4-8e86-83234309cbb3 batch = 0 start at FileStorageAdapterImpl.java:171 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	2026/02/06 06:55:21	0.6 s	4/4				965.0 B
24	tenants-pool-286	stream-10000000095-1 id = 24896f85-9daa-48da-9091-8300a4724264 runId = 838a6e4f-fcfd-48b4-8e86-83234309cbb3 batch = 0 start at FileStorageAdapterImpl.java:171 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	2026/02/06 06:55:21	0.1 s	4/4				442.0 B
23	tenants-pool-286	stream-10000000095-1 id = 24896f85-9daa-48da-9091-8300a4724264 runId = 838a6e4f-fcfd-48b4-8e86-83234309cbb3 batch = 0 start at FileStorageAdapterImpl.java:171 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	2026/02/06 06:55:21	0.1 s	4/4				391.0 B
22	tenants-pool-286	stream-10000000095-1 id = 24896f85-9daa-48da-9091-8300a4724264 runId = 838a6e4f-fcfd-48b4-8e86-83234309cbb3 batch = 0 start at FileStorageAdapterImpl.java:171 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	2026/02/06 06:55:21	11 ms	1/1
21	tenants-pool-286	stream-10000000095-1 id = 24896f85-9daa-48da-9091-8300a4724264 runId = 838a6e4f-fcfd-48b4-8e86-83234309cbb3 batch = 0 start at FileStorageAdapterImpl.java:171 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	2026/02/06 06:55:20	0.5 s	25/25
19	tenants-pool-286	stream-10000000095-1 id = 24896f85-9daa-48da-9091-8300a4724264 runId = 838a6e4f-fcfd-48b4-8e86-83234309cbb3 batch = 0 start at FileStorageAdapterImpl.java:171 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	2026/02/06 06:55:20	20 ms	1/1	21.0 B
16	tenants-pool-286	stream-10000000095-1 id = 24896f85-9daa-48da-9091-8300a4724264 runId = 838a6e4f-fcfd-48b4-8e86-83234309cbb3 batch = 0 start at FileStorageAdapterImpl.java:171 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	2026/02/06 06:55:20	0.2 s	1/1
15	tenants-pool-286	stream-10000000095-1 id = 24896f85-9daa-48da-9091-8300a4724264 runId = 838a6e4f-fcfd-48b4-8e86-83234309cbb3 batch = 0 start at FileStorageAdapterImpl.java:171 +details RDD: Delta Table State #0 - hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-update/10000000095/stream-10000000095-1/_delta_log org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	2026/02/06 06:55:19	0.2 s	50/50	1485.0 B
13	tenants-pool-286	stream-10000000095-1 id = 24896f85-9daa-48da-9091-8300a4724264 runId = 838a6e4f-fcfd-48b4-8e86-83234309cbb3 batch = 0 start at FileStorageAdapterImpl.java:171 +details RDD: Delta Table State #0 - hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-update/10000000095/stream-10000000095-1/_delta_log org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	2026/02/06 06:55:15	4 s	50/50			831.0 B
12	tenants-pool-286	stream-10000000095-1 id = 24896f85-9daa-48da-9091-8300a4724264 runId = 838a6e4f-fcfd-48b4-8e86-83234309cbb3 batch = 0 start at FileStorageAdapterImpl.java:171 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	2026/02/06 06:55:14	0.5 s	1/1				831.0 B
11	tenants-pool-286	replenishmentRunId = 10000000095 tenantId = 6944346648028224943 activityType = PrepareStreams activityId = f7c8bcdf-0636-3283-a6d4-2f6723afc071 workflowType = CalculateOrderProposalsWorkflow workflowId = eba25ea7-bf45-3f36-ad32-cdab1a2c01e5 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD $anonfun$withThreadLocalCaptured$2 at <unknown>:0 +details org.apache.spark.sql.execution.SQLExecution$.$anonfun$withThreadLocalCaptured$2(SQLExecution.scala:316) java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	2026/02/06 06:55:10	2 s	1/1		29.4 KiB	295.0 B
6	tenants-pool-286	replenishmentRunId = 10000000095 tenantId = 6944346648028224943 activityType = PrepareStreams activityId = f7c8bcdf-0636-3283-a6d4-2f6723afc071 workflowType = CalculateOrderProposalsWorkflow workflowId = eba25ea7-bf45-3f36-ad32-cdab1a2c01e5 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD $anonfun$withThreadLocalCaptured$2 at <unknown>:0 +details org.apache.spark.sql.execution.SQLExecution$.$anonfun$withThreadLocalCaptured$2(SQLExecution.scala:316) java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	2026/02/06 06:55:10	0.6 s	1/1			284.0 B	195.0 B
3	tenants-pool-286	replenishmentRunId = 10000000095 tenantId = 6944346648028224943 activityType = PrepareStreams activityId = f7c8bcdf-0636-3283-a6d4-2f6723afc071 workflowType = CalculateOrderProposalsWorkflow workflowId = eba25ea7-bf45-3f36-ad32-cdab1a2c01e5 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD $anonfun$withThreadLocalCaptured$2 at <unknown>:0 +details org.apache.spark.sql.execution.SQLExecution$.$anonfun$withThreadLocalCaptured$2(SQLExecution.scala:316) java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	2026/02/06 06:55:07	2 s	1/1				187.0 B
2	tenants-pool-286	replenishmentRunId = 10000000095 tenantId = 6944346648028224943 activityType = PrepareStreams activityId = f7c8bcdf-0636-3283-a6d4-2f6723afc071 workflowType = CalculateOrderProposalsWorkflow workflowId = eba25ea7-bf45-3f36-ad32-cdab1a2c01e5 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD $anonfun$withThreadLocalCaptured$2 at <unknown>:0 +details org.apache.spark.sql.execution.SQLExecution$.$anonfun$withThreadLocalCaptured$2(SQLExecution.scala:316) java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	2026/02/06 06:55:07	2 s	1/1				97.0 B
1	tenants-pool-286	replenishmentRunId = 10000000095 tenantId = 6944346648028224943 activityType = PrepareStreams activityId = f7c8bcdf-0636-3283-a6d4-2f6723afc071 workflowType = CalculateOrderProposalsWorkflow workflowId = eba25ea7-bf45-3f36-ad32-cdab1a2c01e5 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD $anonfun$withThreadLocalCaptured$2 at <unknown>:0 +details org.apache.spark.sql.execution.SQLExecution$.$anonfun$withThreadLocalCaptured$2(SQLExecution.scala:316) java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	2026/02/06 06:55:07	0.7 s	1/1				100.0 B
0	tenants-pool-286	replenishmentRunId = 10000000095 tenantId = 6944346648028224943 activityType = PrepareStreams activityId = f7c8bcdf-0636-3283-a6d4-2f6723afc071 workflowType = CalculateOrderProposalsWorkflow workflowId = eba25ea7-bf45-3f36-ad32-cdab1a2c01e5 attempt = 1 cornerstoneTenantId = 8378 marketUnit = Daily_grocery scenario = STANDARD save at FileStorageAdapterImpl.java:129 +details org.apache.spark.sql.classic.DataFrameWriter.save(DataFrameWriter.scala:118) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.writeToStorage(FileStorageAdapterImpl.java:129) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.prepareKpiCurveUpdateStream(FileStorageAdapterImpl.java:118) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.prepareStreams(KpiCalculationStreamingActivityImpl.java:47) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	2026/02/06 06:54:58	5 s	1/1		1198.0 B

Page:

Skipped Stages (32)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total
66	default	start at FileStorageAdapterImpl.java:171 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	Unknown	Unknown	0/1
65	default	start at FileStorageAdapterImpl.java:171 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	Unknown	Unknown	0/4
64	default	start at FileStorageAdapterImpl.java:171 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	Unknown	Unknown	0/4
63	default	start at FileStorageAdapterImpl.java:171 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	Unknown	Unknown	0/4
61	default	start at FileStorageAdapterImpl.java:171 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	Unknown	Unknown	0/4
60	default	start at FileStorageAdapterImpl.java:171 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	Unknown	Unknown	0/4
54	default	start at FileStorageAdapterImpl.java:171 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	Unknown	Unknown	0/0
52	default	start at FileStorageAdapterImpl.java:171 +details RDD: Delta Table State #0 - hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-update/10000000096/stream-10000000096-1/_delta_log org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	Unknown	Unknown	0/50
51	default	start at FileStorageAdapterImpl.java:171 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	Unknown	Unknown	0/1
48	default	start at FileStorageAdapterImpl.java:171 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	Unknown	Unknown	0/1
44	default	$anonfun$withThreadLocalCaptured$2 at <unknown>:0 +details org.apache.spark.sql.execution.SQLExecution$.$anonfun$withThreadLocalCaptured$2(SQLExecution.scala:316) java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	Unknown	Unknown	0/1
43	default	$anonfun$withThreadLocalCaptured$2 at <unknown>:0 +details org.apache.spark.sql.execution.SQLExecution$.$anonfun$withThreadLocalCaptured$2(SQLExecution.scala:316) java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	Unknown	Unknown	0/1
42	default	$anonfun$withThreadLocalCaptured$2 at <unknown>:0 +details org.apache.spark.sql.execution.SQLExecution$.$anonfun$withThreadLocalCaptured$2(SQLExecution.scala:316) java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	Unknown	Unknown	0/1
41	default	$anonfun$withThreadLocalCaptured$2 at <unknown>:0 +details org.apache.spark.sql.execution.SQLExecution$.$anonfun$withThreadLocalCaptured$2(SQLExecution.scala:316) java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	Unknown	Unknown	0/1
39	default	$anonfun$withThreadLocalCaptured$2 at <unknown>:0 +details org.apache.spark.sql.execution.SQLExecution$.$anonfun$withThreadLocalCaptured$2(SQLExecution.scala:316) java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	Unknown	Unknown	0/1
38	default	$anonfun$withThreadLocalCaptured$2 at <unknown>:0 +details org.apache.spark.sql.execution.SQLExecution$.$anonfun$withThreadLocalCaptured$2(SQLExecution.scala:316) java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	Unknown	Unknown	0/1
32	default	start at FileStorageAdapterImpl.java:171 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	Unknown	Unknown	0/4
31	default	start at FileStorageAdapterImpl.java:171 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	Unknown	Unknown	0/1
30	default	start at FileStorageAdapterImpl.java:171 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	Unknown	Unknown	0/4
29	default	start at FileStorageAdapterImpl.java:171 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	Unknown	Unknown	0/4
27	default	start at FileStorageAdapterImpl.java:171 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	Unknown	Unknown	0/4
26	default	start at FileStorageAdapterImpl.java:171 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	Unknown	Unknown	0/4
20	default	start at FileStorageAdapterImpl.java:171 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	Unknown	Unknown	0/0
18	default	start at FileStorageAdapterImpl.java:171 +details RDD: Delta Table State #0 - hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/out/order-proposal-update/10000000095/stream-10000000095-1/_delta_log org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	Unknown	Unknown	0/50
17	default	start at FileStorageAdapterImpl.java:171 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	Unknown	Unknown	0/1
14	default	start at FileStorageAdapterImpl.java:171 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:171) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:63) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.base/java.lang.reflect.Method.invoke(Unknown Source) io.temporal.internal.activity.RootActivityInboundCallsInterceptor$POJOActivityInboundCallsInterceptor.executeActivity(RootActivityInboundCallsInterceptor.java:44) io.temporal.internal.activity.RootActivityInboundCallsInterceptor.execute(RootActivityInboundCallsInterceptor.java:23) io.temporal.internal.activity.ActivityTaskExecutors$BaseActivityTaskExecutor.execute(ActivityTaskExecutors.java:88) io.temporal.internal.activity.ActivityTaskHandlerImpl.handle(ActivityTaskHandlerImpl.java:105) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handleActivity(ActivityWorker.java:294) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:258) io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:221) io.temporal.internal.worker.PollTaskExecutor.lambda$process$1(PollTaskExecutor.java:76) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	Unknown	Unknown	0/1
10	default	$anonfun$withThreadLocalCaptured$2 at <unknown>:0 +details org.apache.spark.sql.execution.SQLExecution$.$anonfun$withThreadLocalCaptured$2(SQLExecution.scala:316) java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	Unknown	Unknown	0/1
9	default	$anonfun$withThreadLocalCaptured$2 at <unknown>:0 +details org.apache.spark.sql.execution.SQLExecution$.$anonfun$withThreadLocalCaptured$2(SQLExecution.scala:316) java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	Unknown	Unknown	0/1
8	default	$anonfun$withThreadLocalCaptured$2 at <unknown>:0 +details org.apache.spark.sql.execution.SQLExecution$.$anonfun$withThreadLocalCaptured$2(SQLExecution.scala:316) java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	Unknown	Unknown	0/1
7	default	$anonfun$withThreadLocalCaptured$2 at <unknown>:0 +details org.apache.spark.sql.execution.SQLExecution$.$anonfun$withThreadLocalCaptured$2(SQLExecution.scala:316) java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	Unknown	Unknown	0/1
5	default	$anonfun$withThreadLocalCaptured$2 at <unknown>:0 +details org.apache.spark.sql.execution.SQLExecution$.$anonfun$withThreadLocalCaptured$2(SQLExecution.scala:316) java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	Unknown	Unknown	0/1
4	default	$anonfun$withThreadLocalCaptured$2 at <unknown>:0 +details org.apache.spark.sql.execution.SQLExecution$.$anonfun$withThreadLocalCaptured$2(SQLExecution.scala:316) java.base/java.util.concurrent.CompletableFuture$AsyncSupply.run(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) java.base/java.lang.Thread.run(Unknown Source)	Unknown	Unknown	0/1

Page: