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

Status: SUCCEEDED
Submitted: 2026/07/21 20:59:03
Duration: 0.2 s
Associated SQL Query: 38769
Job Group: 7e223599-2bbc-4b04-bb19-188f6b84ba3d
Completed Stages: 2
Skipped Stages: 6

Enable zooming

digraph G { id="graph_173282"; subgraph graph_stage_173282 { id="graph_stage_173282"; isCluster="true"; label="Stage 173282 (skipped)"; subgraph cluster_1243871 { id="cluster_1243871"; isCluster="true"; label="Scan parquet "; 483879 [id="node_483879" labelType="html" label="FileScanRDD [483879] start at FileStorageAdapterImpl.java:179}"]; 483880 [id="node_483880" labelType="html" label="MapPartitionsRDD [483880] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243867 { id="cluster_1243867"; isCluster="true"; label="WholeStageCodegen (1)"; 483881 [id="node_483881" labelType="html" label="MapPartitionsRDD [483881] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243866 { id="cluster_1243866"; isCluster="true"; label="Exchange"; 483882 [id="node_483882" labelType="html" label="MapPartitionsRDD [483882] start at FileStorageAdapterImpl.java:179}"]; } } 483879->483880; 483880->483881; 483881->483882; }

digraph G { id="graph_173283"; subgraph graph_stage_173283 { id="graph_stage_173283"; isCluster="true"; label="Stage 173283 (skipped)"; subgraph cluster_1243904 { id="cluster_1243904"; isCluster="true"; label="Scan parquet "; 483890 [id="node_483890" labelType="html" label="FileScanRDD [483890] start at FileStorageAdapterImpl.java:179}"]; 483891 [id="node_483891" labelType="html" label="MapPartitionsRDD [483891] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243900 { id="cluster_1243900"; isCluster="true"; label="WholeStageCodegen (7)"; 483892 [id="node_483892" labelType="html" label="MapPartitionsRDD [483892] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243899 { id="cluster_1243899"; isCluster="true"; label="Exchange"; 483893 [id="node_483893" labelType="html" label="MapPartitionsRDD [483893] start at FileStorageAdapterImpl.java:179}"]; } } 483890->483891; 483891->483892; 483892->483893; }

digraph G { id="graph_173284"; subgraph graph_stage_173284 { id="graph_stage_173284"; isCluster="true"; label="Stage 173284 (skipped)"; subgraph cluster_1243899 { id="cluster_1243899"; isCluster="true"; label="Exchange"; 483894 [id="node_483894" labelType="html" label="ShuffledRowRDD [483894] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243877 { id="cluster_1243877"; isCluster="true"; label="WholeStageCodegen (11)"; 483895 [id="node_483895" labelType="html" label="MapPartitionsRDD [483895] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243876 { id="cluster_1243876"; isCluster="true"; label="Exchange"; 483896 [id="node_483896" labelType="html" label="MapPartitionsRDD [483896] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 483894->483895; 483895->483896; }

483893,483894

digraph G { id="graph_173285"; subgraph graph_stage_173285 { id="graph_stage_173285"; isCluster="true"; label="Stage 173285 (skipped)"; subgraph cluster_1243866 { id="cluster_1243866"; isCluster="true"; label="Exchange"; 483883 [id="node_483883" labelType="html" label="ShuffledRowRDD [483883] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243845 { id="cluster_1243845"; isCluster="true"; label="WholeStageCodegen (5)"; 483884 [id="node_483884" labelType="html" label="MapPartitionsRDD [483884] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243844 { id="cluster_1243844"; isCluster="true"; label="Exchange"; 483885 [id="node_483885" labelType="html" label="MapPartitionsRDD [483885] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 483883->483884; 483884->483885; }

483882,483883

digraph G { id="graph_173286"; subgraph graph_stage_173286 { id="graph_stage_173286"; isCluster="true"; label="Stage 173286 (skipped)"; subgraph cluster_1243844 { id="cluster_1243844"; isCluster="true"; label="Exchange"; 483886 [id="node_483886" labelType="html" label="ShuffledRowRDD [483886] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243841 { id="cluster_1243841"; isCluster="true"; label="WholeStageCodegen (6)"; 483887 [id="node_483887" labelType="html" label="MapPartitionsRDD [483887] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243876 { id="cluster_1243876"; isCluster="true"; label="Exchange"; 483897 [id="node_483897" labelType="html" label="ShuffledRowRDD [483897] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243873 { id="cluster_1243873"; isCluster="true"; label="WholeStageCodegen (12)"; 483898 [id="node_483898" labelType="html" label="MapPartitionsRDD [483898] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243837 { id="cluster_1243837"; isCluster="true"; label="WholeStageCodegen (13)"; 483899 [id="node_483899" labelType="html" label="ZippedPartitionsRDD2 [483899] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 483900 [id="node_483900" labelType="html" label="MapPartitionsRDD [483900] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243836 { id="cluster_1243836"; isCluster="true"; label="ObjectHashAggregate"; 483901 [id="node_483901" labelType="html" label="MapPartitionsRDD [483901] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243835 { id="cluster_1243835"; isCluster="true"; label="Exchange"; 483902 [id="node_483902" labelType="html" label="MapPartitionsRDD [483902] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 483886->483887; 483897->483898; 483887->483899; 483898->483899; 483899->483900; 483900->483901; 483901->483902; }

483885,483886

483896,483897

digraph G { id="graph_173287"; subgraph graph_stage_173287 { id="graph_stage_173287"; isCluster="true"; label="Stage 173287 (skipped)"; 483911 [id="node_483911" labelType="html" label="SQLExecutionRDD [483911] [Unordered] start at FileStorageAdapterImpl.java:179}"]; subgraph cluster_1243835 { id="cluster_1243835"; isCluster="true"; label="Exchange"; 483903 [id="node_483903" labelType="html" label="ShuffledRowRDD [483903] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243834 { id="cluster_1243834"; isCluster="true"; label="ObjectHashAggregate"; 483904 [id="node_483904" labelType="html" label="MapPartitionsRDD [483904] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243833 { id="cluster_1243833"; isCluster="true"; label="Project"; 483905 [id="node_483905" labelType="html" label="MapPartitionsRDD [483905] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243812 { id="cluster_1243812"; isCluster="true"; label="WholeStageCodegen (16)"; 483906 [id="node_483906" labelType="html" label="MapPartitionsRDD [483906] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243811 { id="cluster_1243811"; isCluster="true"; label="DeserializeToObject"; 483907 [id="node_483907" labelType="html" label="MapPartitionsRDD [483907] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243810 { id="cluster_1243810"; isCluster="true"; label="MapPartitions"; 483908 [id="node_483908" labelType="html" label="MapPartitionsRDD [483908] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243756 { id="cluster_1243756"; isCluster="true"; label="WholeStageCodegen (19)"; 483909 [id="node_483909" labelType="html" label="MapPartitionsRDD [483909] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243735 { id="cluster_1243735"; isCluster="true"; label="DeserializeToObject"; 483910 [id="node_483910" labelType="html" label="MapPartitionsRDD [483910] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243912 { id="cluster_1243912"; isCluster="true"; label="mapPartitions"; 483912 [id="node_483912" labelType="html" label="MapPartitionsRDD [483912] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243913 { id="cluster_1243913"; isCluster="true"; label="mapPartitions"; 483913 [id="node_483913" labelType="html" label="MapPartitionsRDD [483913] [Cached] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243981 { id="cluster_1243981"; isCluster="true"; label="Scan"; 483919 [id="node_483919" labelType="html" label="MapPartitionsRDD [483919] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243975 { id="cluster_1243975"; isCluster="true"; label="WholeStageCodegen (1)"; 483920 [id="node_483920" labelType="html" label="MapPartitionsRDD [483920] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243974 { id="cluster_1243974"; isCluster="true"; label="InMemoryTableScan"; 483921 [id="node_483921" labelType="html" label="MapPartitionsRDD [483921] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 483922 [id="node_483922" labelType="html" label="*(1) Generate explode(prodPlantResults#8565766), false, [prodPlantResults#8565773]\n+- *(1) Project [prodPlantResults#8565766]\n +- *(1) Filter ((size(prodPlantResults#8565766, true) > 0) AND isnotnull(prodPlantResults#8565766))\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,String... [483922] [Cached] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 483923 [id="node_483923" labelType="html" label="MapPartitionsRDD [483923] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 483924 [id="node_483924" labelType="html" label="MapPartitionsRDD [483924] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 483925 [id="node_483925" labelType="html" label="MapPartitionsRDD [483925] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243973 { id="cluster_1243973"; isCluster="true"; label="Project"; 483926 [id="node_483926" labelType="html" label="MapPartitionsRDD [483926] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243988 { id="cluster_1243988"; isCluster="true"; label="InMemoryTableScan"; 483927 [id="node_483927" labelType="html" label="MapPartitionsRDD [483927] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 483928 [id="node_483928" labelType="html" label="MapPartitionsRDD [483928] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 483929 [id="node_483929" labelType="html" label="MapPartitionsRDD [483929] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243983 { id="cluster_1243983"; isCluster="true"; label="WholeStageCodegen (1)"; 483930 [id="node_483930" labelType="html" label="MapPartitionsRDD [483930] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243982 { id="cluster_1243982"; isCluster="true"; label="Project"; 483931 [id="node_483931" labelType="html" label="MapPartitionsRDD [483931] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243995 { id="cluster_1243995"; isCluster="true"; label="InMemoryTableScan"; 483932 [id="node_483932" labelType="html" label="MapPartitionsRDD [483932] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 483933 [id="node_483933" labelType="html" label="MapPartitionsRDD [483933] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 483934 [id="node_483934" labelType="html" label="MapPartitionsRDD [483934] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243990 { id="cluster_1243990"; isCluster="true"; label="WholeStageCodegen (2)"; 483935 [id="node_483935" labelType="html" label="MapPartitionsRDD [483935] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243989 { id="cluster_1243989"; isCluster="true"; label="Project"; 483936 [id="node_483936" labelType="html" label="MapPartitionsRDD [483936] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243972 { id="cluster_1243972"; isCluster="true"; label="Union"; 483937 [id="node_483937" labelType="html" label="UnionRDD [483937] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243957 { id="cluster_1243957"; isCluster="true"; label="WholeStageCodegen (4)"; 483938 [id="node_483938" labelType="html" label="MapPartitionsRDD [483938] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243956 { id="cluster_1243956"; isCluster="true"; label="SortAggregate"; 483939 [id="node_483939" labelType="html" label="MapPartitionsRDD [483939] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243955 { id="cluster_1243955"; isCluster="true"; label="Exchange"; 483940 [id="node_483940" labelType="html" label="MapPartitionsRDD [483940] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 483903->483904; 483904->483905; 483905->483906; 483906->483907; 483907->483908; 483908->483909; 483909->483910; 483910->483911; 483911->483912; 483912->483913; 483913->483919; 483919->483920; 483920->483921; 483921->483922; 483922->483923; 483923->483924; 483924->483925; 483925->483926; 483922->483927; 483927->483928; 483928->483929; 483929->483930; 483930->483931; 483922->483932; 483932->483933; 483933->483934; 483934->483935; 483935->483936; 483926->483937; 483931->483937; 483936->483937; 483937->483938; 483938->483939; 483939->483940; }

483902,483903

483913

483922

digraph G { id="graph_173288"; subgraph graph_stage_173288 { id="graph_stage_173288"; isCluster="true"; label="Stage 173288"; subgraph cluster_1243955 { id="cluster_1243955"; isCluster="true"; label="Exchange"; 483941 [id="node_483941" labelType="html" label="ShuffledRowRDD [483941] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243950 { id="cluster_1243950"; isCluster="true"; label="WholeStageCodegen (5)"; 483942 [id="node_483942" labelType="html" label="MapPartitionsRDD [483942] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243949 { id="cluster_1243949"; isCluster="true"; label="SortAggregate"; 483943 [id="node_483943" labelType="html" label="MapPartitionsRDD [483943] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1243948 { id="cluster_1243948"; isCluster="true"; label="InMemoryTableScan"; 483944 [id="node_483944" labelType="html" label="MapPartitionsRDD [483944] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 483945 [id="node_483945" labelType="html" label="SortAggregate(key=[demandChannel#8565799, shardId#7905118, qty#8565819, worklistShardItemId#7905119L, demandStream#8565800], functions=[first(kpis#8565828, false)], output=[shardId#7905118, worklistShardItemId#7905119L, qty#8565819, demandChannel#8565799, demandStream#8565800, kpis#8565941])\n+- *(5) Sort [demandChannel#8565799 ASC NULLS FIRST, shardId#7905118 ASC NULLS FIRST, qty#8565819 ASC NULLS FIRST, worklistShardItemId#7905119L ASC NULLS FIRST, demandStream#8565800 ASC NULLS FIRST], false, 0\n +- Exchange hashpartitioning(demandChannel#8565799, shardId#7905118, qty#8565819, worklistShardItemId#7905119L, demandStream#8565800, 30), ENSURE_REQUIREMENTS, [plan_id=11193216]\n +- SortAggregate(key=[demandChannel#8565799, shardId#7905118, knownfloatingpointnormalized(normalizenanandzero(qty#8565819)) AS qty#8565819, worklistShardItemId#7905119L, demandStream#8565800], functions=[partial_first(kpis#8565828, false)], output=[demandChannel#8565799, shardId#7905118, qty#8565819, worklistShardItemId#7905119L... [483945] [Cached] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1244060 { id="cluster_1244060"; isCluster="true"; label="InMemoryTableScan"; 483960 [id="node_483960" labelType="html" label="MapPartitionsRDD [483960] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 483961 [id="node_483961" labelType="html" label="MapPartitionsRDD [483961] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 483962 [id="node_483962" labelType="html" label="MapPartitionsRDD [483962] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1244035 { id="cluster_1244035"; isCluster="true"; label="WholeStageCodegen (3)"; 483963 [id="node_483963" labelType="html" label="MapPartitionsRDD [483963] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1244034 { id="cluster_1244034"; isCluster="true"; label="InMemoryTableScan"; 483964 [id="node_483964" labelType="html" label="MapPartitionsRDD [483964] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 483965 [id="node_483965" labelType="html" label="*(3) Project [shardId#7905118, worklistShardItemId#7905119L, version#8566290, qty#8565819, demandChannel#8565799, demandStream#8565800, kpis#8565828]\n+- *(3) BroadcastHashJoin [shardId#7905118, worklistShardItemId#7905119L], [shardId#8566295, worklistShardItemId#8566296L], Inner, BuildRight, false\n :- *(3) Filter (isnotnull(shardId#7905118) AND isnotnull(worklistShardItemId#7905119L))\n : +- InMemoryTableScan [shardId#7905118, worklistShardItemId#7905119L, qty#8565819, demandChannel#8565799, demandStream#8565800, kpis#8565828], [isnotnull(shardId#7905118), isnotnull(worklistShardItemId#7905119L)]\n : +- InMemoryRelation [shardId#7905118, worklistShardItemId#7905119L, qty#8565819, demandChannel#8565799, demandStream#8565800, kpis#8565828], StorageLevel(disk, memory, 2 replicas)\n : +- SortAggregate(key=[demandChannel#8565799, shardId#7905118, qty#8565819, worklistShardItemId#7905119L, demandStream#8565800], functions=[first(kpis#8565828, false)], output=[shardId#7905118, worklistSh... [483965] [Cached] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 483966 [id="node_483966" labelType="html" label="MapPartitionsRDD [483966] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 483967 [id="node_483967" labelType="html" label="MapPartitionsRDD [483967] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 483968 [id="node_483968" labelType="html" label="MapPartitionsRDD [483968] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1244033 { id="cluster_1244033"; isCluster="true"; label="CollectLimit"; 483969 [id="node_483969" labelType="html" label="MapPartitionsRDD [483969] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 483970 [id="node_483970" labelType="html" label="MapPartitionsRDD [483970] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 483941->483942; 483942->483943; 483943->483944; 483944->483945; 483945->483960; 483960->483961; 483961->483962; 483962->483963; 483963->483964; 483964->483965; 483965->483966; 483966->483967; 483967->483968; 483968->483969; 483969->483970; }

483940,483941

483945

483965

digraph G { id="graph_173289"; subgraph graph_stage_173289 { id="graph_stage_173289"; isCluster="true"; label="Stage 173289"; subgraph cluster_1244033 { id="cluster_1244033"; isCluster="true"; label="CollectLimit"; 483971 [id="node_483971" labelType="html" label="ShuffledRowRDD [483971] [Unordered] start at FileStorageAdapterImpl.java:179}"]; 483972 [id="node_483972" labelType="html" label="MapPartitionsRDD [483972] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } subgraph cluster_1244061 { id="cluster_1244061"; isCluster="true"; label="mapPartitionsInternal"; 483973 [id="node_483973" labelType="html" label="MapPartitionsRDD [483973] [Unordered] start at FileStorageAdapterImpl.java:179}"]; } } 483971->483972; 483972->483973; }

483970,483971

Completed Stages (2)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total	Input	Output	Shuffle Read	Shuffle Write
173289	tenants-pool-169	stream-10000001445-1 id = 1a962402-34b5-483c-bd51-187baf232cbc runId = 7e223599-2bbc-4b04-bb19-188f6b84ba3d batch = 102 start at FileStorageAdapterImpl.java:179 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:179) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor711.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/21 20:59:03	7 ms	1/1
173288	tenants-pool-169	stream-10000001445-1 id = 1a962402-34b5-483c-bd51-187baf232cbc runId = 7e223599-2bbc-4b04-bb19-188f6b84ba3d batch = 102 start at FileStorageAdapterImpl.java:179 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:179) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor711.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/21 20:59:03	0.2 s	30/30	2010.0 B			124.0 B

Stage Id ▾

Pool Name

Description

Submitted

Duration

Tasks: Succeeded/Total

Input

Output

Shuffle Read

Shuffle Write

173289

tenants-pool-169

stream-10000001445-1 id = 1a962402-34b5-483c-bd51-187baf232cbc runId = 7e223599-2bbc-4b04-bb19-188f6b84ba3d batch = 102 start at FileStorageAdapterImpl.java:179 +details

org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:179)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62)
jdk.internal.reflect.GeneratedMethodAccessor711.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/21 20:59:03

7 ms

1/1

173288

tenants-pool-169

stream-10000001445-1 id = 1a962402-34b5-483c-bd51-187baf232cbc runId = 7e223599-2bbc-4b04-bb19-188f6b84ba3d batch = 102 start at FileStorageAdapterImpl.java:179 +details

org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:179)
com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62)
jdk.internal.reflect.GeneratedMethodAccessor711.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/21 20:59:03

0.2 s

30/30

2010.0 B

124.0 B

Page:

Skipped Stages (6)

Page:

Stage Id ▾	Pool Name	Description	Submitted	Duration	Tasks: Succeeded/Total
173287	default	start at FileStorageAdapterImpl.java:179 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:179) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor711.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/90
173286	default	start at FileStorageAdapterImpl.java:179 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:179) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor711.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/30
173285	default	start at FileStorageAdapterImpl.java:179 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:179) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor711.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/30
173284	default	start at FileStorageAdapterImpl.java:179 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:179) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor711.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/30
173283	default	start at FileStorageAdapterImpl.java:179 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:179) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor711.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/26
173282	default	start at FileStorageAdapterImpl.java:179 +details org.apache.spark.sql.classic.DataStreamWriter.start(DataStreamWriter.scala:136) com.sap.s4hana.eureka.business.crporderquantitykpiservice.storageaccess.FileStorageAdapterImpl.triggerOrderProposalUpdateStream(FileStorageAdapterImpl.java:179) com.sap.s4hana.eureka.business.crporderquantitykpiservice.core.controller.KpiCalculationStreamingActivityImpl.runStreamWithId(KpiCalculationStreamingActivityImpl.java:62) jdk.internal.reflect.GeneratedMethodAccessor711.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/26

Page: