crp-order-qty-opt-service - Details for Query 12771

Submitted Time: 2026/08/31 13:56:40
Duration: 7 ms

Plan Visualization

Show the Stage ID and Task ID that corresponds to the max metric

digraph G { 0 [id="node0" labelType="html" label=" DeserializeToObject " tooltip="DeserializeToObject createexternalrow(invoke(shardId#3426590.toString()), static_invoke(java.lang.Long.valueOf(worklistShardItemId#3426591L)), static_invoke(java.lang.Double.valueOf(qty#3426592)), invoke(demandChannel#3426593.toString()), invoke(demandStream#3426594.toString()), mapobjects(lambdavariable(MapObject, StructField(label,StringType,true), StructField(dateTime,TimestampType,true), StructField(value,DoubleType,true), false, -1), createexternalrow(invoke(lambdavariable(MapObject, StructField(label,StringType,true), StructField(dateTime,TimestampType,true), StructField(value,DoubleType,true), false, -1).label.toString()), static_invoke(DateTimeUtils.toJavaTimestamp(lambdavariable(MapObject, StructField(label,StringType,true), StructField(dateTime,TimestampType,true), StructField(value,DoubleType,true), false, -1).dateTime)), static_invoke(java.lang.Double.valueOf(lambdavariable(MapObject, StructField(label,StringType,true), StructField(dateTime,TimestampType,true), StructField(value,DoubleType,true), false, -1).value)), StructField(label,StringType,true), StructField(dateTime,TimestampType,true), StructField(value,DoubleType,true)), kpis#3426595, Some(class scala.collection.mutable.ArraySeq)), StructField(shardId,StringType,true), StructField(worklistShardItemId,LongType,true), StructField(qty,DoubleType,true), StructField(demandChannel,StringType,true), StructField(demandStream,StringType,true), StructField(kpis,ArrayType(StructType(StructField(label,StringType,true),StructField(dateTime,TimestampType,true),StructField(value,DoubleType,true)),false),true)), obj#3426622: org.apache.spark.sql.Row"]; subgraph cluster1 { isCluster="true"; id="cluster1"; label="WholeStageCodegen (1)"; tooltip="WholeStageCodegen (1)"; 2 [id="node2" labelType="html" label=" Filter " tooltip="Filter (isnotnull(shardId#3426590) AND NOT (shardId#3426590 = 0_5_10000000532))"]; 3 [id="node3" labelType="html" label=" Scan ExistingRDD " tooltip="Scan ExistingRDD[shardId#3426590,worklistShardItemId#3426591L,qty#3426592,demandChannel#3426593,demandStream#3426594,kpis#3426595]"]; } 2->0; 3->2; }

Details

== Physical Plan ==
DeserializeToObject (3)
+- * Filter (2)
   +- * Scan ExistingRDD (1)


(1) Scan ExistingRDD [codegen id : 1]
Output [6]: [shardId#3426590, worklistShardItemId#3426591L, qty#3426592, demandChannel#3426593, demandStream#3426594, kpis#3426595]
Arguments: [shardId#3426590, worklistShardItemId#3426591L, qty#3426592, demandChannel#3426593, demandStream#3426594, kpis#3426595], MapPartitionsRDD[145579] at start at FileStorageAdapterImpl.java:596, ExistingRDD, UnknownPartitioning(0)

(2) Filter [codegen id : 1]
Input [6]: [shardId#3426590, worklistShardItemId#3426591L, qty#3426592, demandChannel#3426593, demandStream#3426594, kpis#3426595]
Condition : (isnotnull(shardId#3426590) AND NOT (shardId#3426590 = 0_5_10000000532))

(3) DeserializeToObject
Input [6]: [shardId#3426590, worklistShardItemId#3426591L, qty#3426592, demandChannel#3426593, demandStream#3426594, kpis#3426595]
Arguments: createexternalrow(invoke(shardId#3426590.toString()), static_invoke(java.lang.Long.valueOf(worklistShardItemId#3426591L)), static_invoke(java.lang.Double.valueOf(qty#3426592)), invoke(demandChannel#3426593.toString()), invoke(demandStream#3426594.toString()), mapobjects(lambdavariable(MapObject, StructField(label,StringType,true), StructField(dateTime,TimestampType,true), StructField(value,DoubleType,true), false, -1), createexternalrow(invoke(lambdavariable(MapObject, StructField(label,StringType,true), StructField(dateTime,TimestampType,true), StructField(value,DoubleType,true), false, -1).label.toString()), static_invoke(DateTimeUtils.toJavaTimestamp(lambdavariable(MapObject, StructField(label,StringType,true), StructField(dateTime,TimestampType,true), StructField(value,DoubleType,true), false, -1).dateTime)), static_invoke(java.lang.Double.valueOf(lambdavariable(MapObject, StructField(label,StringType,true), StructField(dateTime,TimestampType,true), StructField(value,DoubleType,true), false, -1).value)), StructField(label,StringType,true), StructField(dateTime,TimestampType,true), StructField(value,DoubleType,true)), kpis#3426595, Some(class scala.collection.mutable.ArraySeq)), StructField(shardId,StringType,true), StructField(worklistShardItemId,LongType,true), StructField(qty,DoubleType,true), StructField(demandChannel,StringType,true), StructField(demandStream,StringType,true), StructField(kpis,ArrayType(StructType(StructField(label,StringType,true),StructField(dateTime,TimestampType,true),StructField(value,DoubleType,true)),false),true)), obj#3426622: org.apache.spark.sql.Row

SQL / DataFrame Properties

Name	Value
spark.activity.clearDeltaLogCache	false
spark.activity.clearSqlCache	false
spark.activity.hdlfsEnabled	true
spark.activity.isolateSession	true
spark.databricks.delta.lastCommitVersionInSession	48
spark.sql.adaptive.enabled	false
spark.sql.cbo.enabled	false
spark.sql.optimizer.pruneFiltersCanPruneStreamingSubplan	false
spark.sql.parquet.fieldId.read.enabled	true
spark.sql.parquet.fieldId.write.enabled	true
spark.sql.requireAllClusterKeysForDistribution	false
spark.sql.shuffle.partitions	30
spark.sql.streaming.aggregation.stateFormatVersion	2
spark.sql.streaming.flatMapGroupsWithState.stateFormatVersion	2
spark.sql.streaming.join.stateFormatVersion	2
spark.sql.streaming.multipleWatermarkPolicy	min
spark.sql.streaming.stateStore.compression.codec	lz4
spark.sql.streaming.stateStore.encodingFormat	unsaferow
spark.sql.streaming.stateStore.providerClass	org.apache.spark.sql.execution.streaming.state.HDFSBackedStateStoreProvider
spark.sql.streaming.stateStore.rocksdb.formatVersion	5
spark.sql.streaming.statefulOperator.useStrictDistribution	true
temporal.activity.id	b13104f5-e344-322f-bff3-a09d5377c4e4
temporal.activity.type	RunStreamWithId