crp-order-quantity-kpi-service - Details for Job 663

Status: SUCCEEDED
Submitted: 2026/07/05 14:35:44
Duration: 0.4 s
Associated SQL Query: 316
Job Group: cd2848b0-327d-42fa-997f-ab27cc4e5d7d
Completed Stages: 1
Skipped Stages: 6

Enable zooming

digraph G { id="graph_1452"; subgraph graph_stage_1452 { id="graph_stage_1452"; isCluster="true"; label="Stage 1452 (skipped)"; subgraph cluster_11685 { id="cluster_11685"; isCluster="true"; label="Scan parquet "; 3708 [id="node_3708" labelType="html" label="FileScanRDD [3708] start at FileStorageAdapterImpl.java:174}"]; 3709 [id="node_3709" labelType="html" label="MapPartitionsRDD [3709] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_11681 { id="cluster_11681"; isCluster="true"; label="WholeStageCodegen (1)"; 3710 [id="node_3710" labelType="html" label="MapPartitionsRDD [3710] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_11680 { id="cluster_11680"; isCluster="true"; label="Exchange"; 3711 [id="node_3711" labelType="html" label="MapPartitionsRDD [3711] start at FileStorageAdapterImpl.java:174}"]; } } 3708->3709; 3709->3710; 3710->3711; }

digraph G { id="graph_1453"; subgraph graph_stage_1453 { id="graph_stage_1453"; isCluster="true"; label="Stage 1453 (skipped)"; 3651 [id="node_3651" labelType="html" label="SQLExecutionRDD [3651] start at FileStorageAdapterImpl.java:174}"]; subgraph cluster_11519 { id="cluster_11519"; isCluster="true"; label="Scan parquet "; 3648 [id="node_3648" labelType="html" label="FileScanRDD [3648] start at FileStorageAdapterImpl.java:174}"]; 3649 [id="node_3649" labelType="html" label="MapPartitionsRDD [3649] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_11516 { id="cluster_11516"; isCluster="true"; label="WholeStageCodegen (1)"; 3650 [id="node_3650" labelType="html" label="MapPartitionsRDD [3650] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_11523 { id="cluster_11523"; isCluster="true"; label="WholeStageCodegen (1)"; 3652 [id="node_3652" labelType="html" label="MapPartitionsRDD [3652] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_11522 { id="cluster_11522"; isCluster="true"; label="Exchange"; 3653 [id="node_3653" labelType="html" label="MapPartitionsRDD [3653] start at FileStorageAdapterImpl.java:174}"]; } } 3648->3649; 3649->3650; 3650->3651; 3651->3652; 3652->3653; }

digraph G { id="graph_1454"; subgraph graph_stage_1454 { id="graph_stage_1454"; isCluster="true"; label="Stage 1454 (skipped)"; subgraph cluster_11522 { id="cluster_11522"; isCluster="true"; label="Exchange"; 3654 [id="node_3654" labelType="html" label="ShuffledRowRDD [3654] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_11521 { id="cluster_11521"; isCluster="true"; label="InMemoryTableScan"; 3655 [id="node_3655" labelType="html" label="MapPartitionsRDD [3655] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 3656 [id="node_3656" labelType="html" label="Exchange hashpartitioning(product#49874, plant#49875, 8), REPARTITION_BY_NUM, [plan_id=331328]\n+- *(1) Scan ExistingRDD[shardId#49871,worklistShardItemId#49872L,version#49873,product#49874,plant#49875,periodStart#49876,periodEnd#49877,qty#49878]\n [3656] [Cached] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_11704 { id="cluster_11704"; isCluster="true"; label="InMemoryTableScan"; 3717 [id="node_3717" labelType="html" label="MapPartitionsRDD [3717] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 3718 [id="node_3718" labelType="html" label="MapPartitionsRDD [3718] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 3719 [id="node_3719" labelType="html" label="MapPartitionsRDD [3719] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_11691 { id="cluster_11691"; isCluster="true"; label="WholeStageCodegen (6)"; 3720 [id="node_3720" labelType="html" label="MapPartitionsRDD [3720] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_11690 { id="cluster_11690"; isCluster="true"; label="Exchange"; 3721 [id="node_3721" labelType="html" label="MapPartitionsRDD [3721] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 3654->3655; 3655->3656; 3656->3717; 3717->3718; 3718->3719; 3719->3720; 3720->3721; }

3653,3654

3656

digraph G { id="graph_1455"; subgraph graph_stage_1455 { id="graph_stage_1455"; isCluster="true"; label="Stage 1455 (skipped)"; subgraph cluster_11680 { id="cluster_11680"; isCluster="true"; label="Exchange"; 3712 [id="node_3712" labelType="html" label="ShuffledRowRDD [3712] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_11671 { id="cluster_11671"; isCluster="true"; label="WholeStageCodegen (3)"; 3713 [id="node_3713" labelType="html" label="MapPartitionsRDD [3713] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_11670 { id="cluster_11670"; isCluster="true"; label="Exchange"; 3714 [id="node_3714" labelType="html" label="MapPartitionsRDD [3714] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 3712->3713; 3713->3714; }

3711,3712

digraph G { id="graph_1456"; subgraph graph_stage_1456 { id="graph_stage_1456"; isCluster="true"; label="Stage 1456 (skipped)"; subgraph cluster_11670 { id="cluster_11670"; isCluster="true"; label="Exchange"; 3715 [id="node_3715" labelType="html" label="ShuffledRowRDD [3715] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_11667 { id="cluster_11667"; isCluster="true"; label="WholeStageCodegen (4)"; 3716 [id="node_3716" labelType="html" label="MapPartitionsRDD [3716] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_11690 { id="cluster_11690"; isCluster="true"; label="Exchange"; 3722 [id="node_3722" labelType="html" label="ShuffledRowRDD [3722] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_11687 { id="cluster_11687"; isCluster="true"; label="WholeStageCodegen (7)"; 3723 [id="node_3723" labelType="html" label="MapPartitionsRDD [3723] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_11663 { id="cluster_11663"; isCluster="true"; label="WholeStageCodegen (8)"; 3724 [id="node_3724" labelType="html" label="ZippedPartitionsRDD2 [3724] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 3725 [id="node_3725" labelType="html" label="MapPartitionsRDD [3725] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_11662 { id="cluster_11662"; isCluster="true"; label="ObjectHashAggregate"; 3726 [id="node_3726" labelType="html" label="MapPartitionsRDD [3726] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_11661 { id="cluster_11661"; isCluster="true"; label="Exchange"; 3727 [id="node_3727" labelType="html" label="MapPartitionsRDD [3727] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 3715->3716; 3722->3723; 3716->3724; 3723->3724; 3724->3725; 3725->3726; 3726->3727; }

3714,3715

3721,3722

digraph G { id="graph_1457"; subgraph graph_stage_1457 { id="graph_stage_1457"; isCluster="true"; label="Stage 1457 (skipped)"; 3736 [id="node_3736" labelType="html" label="SQLExecutionRDD [3736] [Unordered] start at FileStorageAdapterImpl.java:174}"]; subgraph cluster_11661 { id="cluster_11661"; isCluster="true"; label="Exchange"; 3728 [id="node_3728" labelType="html" label="ShuffledRowRDD [3728] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_11660 { id="cluster_11660"; isCluster="true"; label="ObjectHashAggregate"; 3729 [id="node_3729" labelType="html" label="MapPartitionsRDD [3729] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_11659 { id="cluster_11659"; isCluster="true"; label="Project"; 3730 [id="node_3730" labelType="html" label="MapPartitionsRDD [3730] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_11646 { id="cluster_11646"; isCluster="true"; label="WholeStageCodegen (11)"; 3731 [id="node_3731" labelType="html" label="MapPartitionsRDD [3731] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_11645 { id="cluster_11645"; isCluster="true"; label="DeserializeToObject"; 3732 [id="node_3732" labelType="html" label="MapPartitionsRDD [3732] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_11644 { id="cluster_11644"; isCluster="true"; label="MapPartitions"; 3733 [id="node_3733" labelType="html" label="MapPartitionsRDD [3733] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_11586 { id="cluster_11586"; isCluster="true"; label="WholeStageCodegen (14)"; 3734 [id="node_3734" labelType="html" label="MapPartitionsRDD [3734] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_11571 { id="cluster_11571"; isCluster="true"; label="DeserializeToObject"; 3735 [id="node_3735" labelType="html" label="MapPartitionsRDD [3735] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_11705 { id="cluster_11705"; isCluster="true"; label="mapPartitions"; 3737 [id="node_3737" labelType="html" label="MapPartitionsRDD [3737] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_11706 { id="cluster_11706"; isCluster="true"; label="mapPartitions"; 3738 [id="node_3738" labelType="html" label="MapPartitionsRDD [3738] [Cached] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_11773 { id="cluster_11773"; isCluster="true"; label="Scan"; 3744 [id="node_3744" labelType="html" label="MapPartitionsRDD [3744] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_11767 { id="cluster_11767"; isCluster="true"; label="WholeStageCodegen (1)"; 3745 [id="node_3745" labelType="html" label="MapPartitionsRDD [3745] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_11766 { id="cluster_11766"; isCluster="true"; label="InMemoryTableScan"; 3746 [id="node_3746" labelType="html" label="MapPartitionsRDD [3746] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 3747 [id="node_3747" labelType="html" label="*(1) Generate explode(prodPlantResults#73079), false, [prodPlantResults#73086]\n+- *(1) Project [prodPlantResults#73079]\n +- *(1) Filter ((size(prodPlantResults#73079, true) > 0) AND isnotnull(prodPlantResults#73079))\n +- *(1) SerializeFromObject [mapobjects(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -1), if (isnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -1), StructField(measuredUnit,StringType,true), StructField(numberOfCalls,LongType,false), StructField(parent,StringType,true), StructField(runtime,LongType,false), ObjectType(class com.sap.s4hana.eureka.business.crporderquantitykpicalculation.dto.PerformanceMeasurement)))) null else named_struct(measuredUnit, static_invoke(UTF8String.fromString(invoke(knownnotnull(validateexternaltype(lambdavariable(MapObject, ObjectType(class java.lang.Object), true, -1), StructField(measuredUnit,StringType,true), StructField(numberOfCalls,LongType,false), StructField(parent,StringType,true)... [3747] [Cached] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 3748 [id="node_3748" labelType="html" label="MapPartitionsRDD [3748] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 3749 [id="node_3749" labelType="html" label="MapPartitionsRDD [3749] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 3750 [id="node_3750" labelType="html" label="MapPartitionsRDD [3750] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_11765 { id="cluster_11765"; isCluster="true"; label="Project"; 3751 [id="node_3751" labelType="html" label="MapPartitionsRDD [3751] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_11780 { id="cluster_11780"; isCluster="true"; label="InMemoryTableScan"; 3752 [id="node_3752" labelType="html" label="MapPartitionsRDD [3752] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 3753 [id="node_3753" labelType="html" label="MapPartitionsRDD [3753] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 3754 [id="node_3754" labelType="html" label="MapPartitionsRDD [3754] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_11775 { id="cluster_11775"; isCluster="true"; label="WholeStageCodegen (1)"; 3755 [id="node_3755" labelType="html" label="MapPartitionsRDD [3755] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_11774 { id="cluster_11774"; isCluster="true"; label="Project"; 3756 [id="node_3756" labelType="html" label="MapPartitionsRDD [3756] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_11787 { id="cluster_11787"; isCluster="true"; label="InMemoryTableScan"; 3757 [id="node_3757" labelType="html" label="MapPartitionsRDD [3757] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 3758 [id="node_3758" labelType="html" label="MapPartitionsRDD [3758] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 3759 [id="node_3759" labelType="html" label="MapPartitionsRDD [3759] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_11782 { id="cluster_11782"; isCluster="true"; label="WholeStageCodegen (2)"; 3760 [id="node_3760" labelType="html" label="MapPartitionsRDD [3760] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_11781 { id="cluster_11781"; isCluster="true"; label="Project"; 3761 [id="node_3761" labelType="html" label="MapPartitionsRDD [3761] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_11764 { id="cluster_11764"; isCluster="true"; label="Union"; 3762 [id="node_3762" labelType="html" label="UnionRDD [3762] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_11750 { id="cluster_11750"; isCluster="true"; label="WholeStageCodegen (4)"; 3763 [id="node_3763" labelType="html" label="MapPartitionsRDD [3763] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_11749 { id="cluster_11749"; isCluster="true"; label="SortAggregate"; 3764 [id="node_3764" labelType="html" label="MapPartitionsRDD [3764] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_11748 { id="cluster_11748"; isCluster="true"; label="Exchange"; 3765 [id="node_3765" labelType="html" label="MapPartitionsRDD [3765] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 3728->3729; 3729->3730; 3730->3731; 3731->3732; 3732->3733; 3733->3734; 3734->3735; 3735->3736; 3736->3737; 3737->3738; 3738->3744; 3744->3745; 3745->3746; 3746->3747; 3747->3748; 3748->3749; 3749->3750; 3750->3751; 3747->3752; 3752->3753; 3753->3754; 3754->3755; 3755->3756; 3747->3757; 3757->3758; 3758->3759; 3759->3760; 3760->3761; 3751->3762; 3756->3762; 3761->3762; 3762->3763; 3763->3764; 3764->3765; }

3727,3728

3738

3747

digraph G { id="graph_1458"; subgraph graph_stage_1458 { id="graph_stage_1458"; isCluster="true"; label="Stage 1458"; subgraph cluster_11748 { id="cluster_11748"; isCluster="true"; label="Exchange"; 3766 [id="node_3766" labelType="html" label="ShuffledRowRDD [3766] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_11742 { id="cluster_11742"; isCluster="true"; label="WholeStageCodegen (5)"; 3767 [id="node_3767" labelType="html" label="MapPartitionsRDD [3767] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_11741 { id="cluster_11741"; isCluster="true"; label="SortAggregate"; 3768 [id="node_3768" labelType="html" label="MapPartitionsRDD [3768] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_11740 { id="cluster_11740"; isCluster="true"; label="InMemoryTableScan"; 3769 [id="node_3769" labelType="html" label="MapPartitionsRDD [3769] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 3770 [id="node_3770" labelType="html" label="SortAggregate(key=[demandChannel#73112, shardId#49871, qty#73132, worklistShardItemId#49872L, demandStream#73113], functions=[first(kpis#73141, false)], output=[shardId#49871, worklistShardItemId#49872L, qty#73132, demandChannel#73112, demandStream#73113, kpis#73254])\n+- *(5) Sort [demandChannel#73112 ASC NULLS FIRST, shardId#49871 ASC NULLS FIRST, qty#73132 ASC NULLS FIRST, worklistShardItemId#49872L ASC NULLS FIRST, demandStream#73113 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#73112, shardId#49871, qty#73132, worklistShardItemId#49872L, demandStream#73113, 8), ENSURE_REQUIREMENTS, [plan_id=332016]\n +- SortAggregate(key=[demandChannel#73112, shardId#49871, knownfloatingpointnormalized(normalizenanandzero(qty#73132)) AS qty#73132, worklistShardItemId#49872L, demandStream#73113], functions=[partial_first(kpis#73141, false)], output=[demandChannel#73112, shardId#49871, qty#73132, worklistShardItemId#49872L, demandStream#73113, first#73320, valueSet#73321])\n +- *(4) ... [3770] [Cached] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_11852 { id="cluster_11852"; isCluster="true"; label="InMemoryTableScan"; 3785 [id="node_3785" labelType="html" label="MapPartitionsRDD [3785] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 3786 [id="node_3786" labelType="html" label="MapPartitionsRDD [3786] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 3787 [id="node_3787" labelType="html" label="MapPartitionsRDD [3787] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_11827 { id="cluster_11827"; isCluster="true"; label="WholeStageCodegen (3)"; 3788 [id="node_3788" labelType="html" label="MapPartitionsRDD [3788] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_11826 { id="cluster_11826"; isCluster="true"; label="InMemoryTableScan"; 3789 [id="node_3789" labelType="html" label="MapPartitionsRDD [3789] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 3790 [id="node_3790" labelType="html" label="*(3) Project [shardId#49871, worklistShardItemId#49872L, version#73603, qty#73132, demandChannel#73112, demandStream#73113, kpis#73141]\n+- *(3) BroadcastHashJoin [shardId#49871, worklistShardItemId#49872L], [shardId#73608, worklistShardItemId#73609L], Inner, BuildRight, false\n :- *(3) Filter (isnotnull(shardId#49871) AND isnotnull(worklistShardItemId#49872L))\n : +- InMemoryTableScan [shardId#49871, worklistShardItemId#49872L, qty#73132, demandChannel#73112, demandStream#73113, kpis#73141], [isnotnull(shardId#49871), isnotnull(worklistShardItemId#49872L)]\n : +- InMemoryRelation [shardId#49871, worklistShardItemId#49872L, qty#73132, demandChannel#73112, demandStream#73113, kpis#73141], StorageLevel(disk, memory, 2 replicas)\n : +- SortAggregate(key=[demandChannel#73112, shardId#49871, qty#73132, worklistShardItemId#49872L, demandStream#73113], functions=[first(kpis#73141, false)], output=[shardId#49871, worklistShardItemId#49872L, qty#73132, demandChannel#73112, demandStream#73113... [3790] [Cached] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } subgraph cluster_11870 { id="cluster_11870"; isCluster="true"; label="InMemoryTableScan"; 3799 [id="node_3799" labelType="html" label="MapPartitionsRDD [3799] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 3800 [id="node_3800" labelType="html" label="MapPartitionsRDD [3800] [Unordered] start at FileStorageAdapterImpl.java:174}"]; 3801 [id="node_3801" labelType="html" label="MapPartitionsRDD [3801] [Unordered] start at FileStorageAdapterImpl.java:174}"]; } } 3766->3767; 3767->3768; 3768->3769; 3769->3770; 3770->3785; 3785->3786; 3786->3787; 3787->3788; 3788->3789; 3789->3790; 3790->3799; 3799->3800; 3800->3801; }

3765,3766

3770

3790

Completed Stages (1)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
1458	tenants-pool-21	stream-10000000006-1 id = 008a9252-b74b-47a5-9492-5dcb2fdff8df runId = cd2848b0-327d-42fa-997f-ab27cc4e5d7d batch = 3 start at FileStorageAdapterImpl.java:174 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:174) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) 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/07/05 14:35:44	0.4 s	8/8	25.3 KiB	38.6 KiB

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

1458

tenants-pool-21

stream-10000000006-1 id = 008a9252-b74b-47a5-9492-5dcb2fdff8df runId = cd2848b0-327d-42fa-997f-ab27cc4e5d7d batch = 3 start at FileStorageAdapterImpl.java:174 +details

org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:174)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62)
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/07/05 14:35:44

0.4 s

8/8

25.3 KiB

38.6 KiB

Page:

Skipped Stages (6)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total
1457	default	start at FileStorageAdapterImpl.java:174 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:174) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) 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/24
1456	default	start at FileStorageAdapterImpl.java:174 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:174) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) 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/8
1455	default	start at FileStorageAdapterImpl.java:174 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:174) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) 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/8
1454	default	start at FileStorageAdapterImpl.java:174 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:174) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) 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/8
1453	default	start at FileStorageAdapterImpl.java:174 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:174) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) 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/10
1452	default	start at FileStorageAdapterImpl.java:174 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:174) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) 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

Page: