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

Submitted Time: 2026/09/02 14:12:39
Duration: 0.5 s
Succeeded Jobs: 86096

Plan Visualization

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

digraph G { 0 [id="node0" labelType="html" label=" Project " tooltip="Project [path#16396202, partitionValues#16396203, size#16396204L, modificationTime#16396205L, dataChange#16396206, null AS stats#16695435, tags#16396208, deletionVector#16396209, baseRowId#16396210L, defaultRowCommitVersion#16396211L, clusteringProvider#16396212]"]; 1 [id="node1" labelType="html" label="Filter number of output rows: 37" tooltip="Filter ((UDF(true, size#16396204L, (stats#16396213.numRecords - coalesce(deletionVector#16396209.cardinality, 0)), stats#16396213.numRecords) AND if (isnull((((isnotnull(partitionValues#16396203[shardId]) AND isnotnull(cast(partitionValues#16396203[sequenceId] as int))) AND (partitionValues#16396203[shardId] = 0_3_10000000548)) AND (cast(partitionValues#16396203[sequenceId] as int) = 25)))) false else UDF(knownnotnull((((isnotnull(partitionValues#16396203[shardId]) AND isnotnull(cast(partitionValues#16396203[sequenceId] as int))) AND (partitionValues#16396203[shardId] = 0_3_10000000548)) AND (cast(partitionValues#16396203[sequenceId] as int) = 25))), size#16396204L, (stats#16396213.numRecords - coalesce(deletionVector#16396209.cardinality, 0)), stats#16396213.numRecords)) AND if (isnull(((stats#16396213.nullCount.worklistShardItemId < stats#16396213.numRecords) OR (isnull(stats#16396213.nullCount.worklistShardItemId) OR isnull(stats#16396213.numRecords))))) false else UDF(knownnotnull(((stats#16396213.nullCount.worklistShardItemId < stats#16396213.numRecords) OR (isnull(stats#16396213.nullCount.worklistShardItemId) OR isnull(stats#16396213.numRecords)))), size#16396204L, (stats#16396213.numRecords - coalesce(deletionVector#16396209.cardinality, 0)), stats#16396213.numRecords))"]; 2 [id="node2" labelType="html" label="Scan ExistingRDD Delta Table State with Stats #2 - hdlfs://7da5304c-1f57-47fa-b75a-0f0b4349c280.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/internal/prod-plant-snapshot/10000000548/_delta_log number of output rows: 2,886" tooltip="Scan ExistingRDD Delta Table State with Stats #2 - hdlfs://7da5304c-1f57-47fa-b75a-0f0b4349c280.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/internal/prod-plant-snapshot/10000000548/_delta_log[path#16396202,partitionValues#16396203,size#16396204L,modificationTime#16396205L,dataChange#16396206,stats#16396213,tags#16396208,deletionVector#16396209,baseRowId#16396210L,defaultRowCommitVersion#16396211L,clusteringProvider#16396212]"]; 1->0; 2->1; }

Details

== Physical Plan ==
Project (3)
+- Filter (2)
   +- Scan ExistingRDD Delta Table State with Stats #2 - hdlfs://7da5304c-1f57-47fa-b75a-0f0b4349c280.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/internal/prod-plant-snapshot/10000000548/_delta_log (1)


(1) Scan ExistingRDD Delta Table State with Stats #2 - hdlfs://7da5304c-1f57-47fa-b75a-0f0b4349c280.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/internal/prod-plant-snapshot/10000000548/_delta_log
Output [11]: [path#16396202, partitionValues#16396203, size#16396204L, modificationTime#16396205L, dataChange#16396206, stats#16396213, tags#16396208, deletionVector#16396209, baseRowId#16396210L, defaultRowCommitVersion#16396211L, clusteringProvider#16396212]
Arguments: [path#16396202, partitionValues#16396203, size#16396204L, modificationTime#16396205L, dataChange#16396206, stats#16396213, tags#16396208, deletionVector#16396209, baseRowId#16396210L, defaultRowCommitVersion#16396211L, clusteringProvider#16396212], Delta Table State with Stats #2 - hdlfs://7da5304c-1f57-47fa-b75a-0f0b4349c280.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/internal/prod-plant-snapshot/10000000548/_delta_log MapPartitionsRDD[697645] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)

(2) Filter
Input [11]: [path#16396202, partitionValues#16396203, size#16396204L, modificationTime#16396205L, dataChange#16396206, stats#16396213, tags#16396208, deletionVector#16396209, baseRowId#16396210L, defaultRowCommitVersion#16396211L, clusteringProvider#16396212]
Condition : ((UDF(true, size#16396204L, (stats#16396213.numRecords - coalesce(deletionVector#16396209.cardinality, 0)), stats#16396213.numRecords) AND if (isnull((((isnotnull(partitionValues#16396203[shardId]) AND isnotnull(cast(partitionValues#16396203[sequenceId] as int))) AND (partitionValues#16396203[shardId] = 0_3_10000000548)) AND (cast(partitionValues#16396203[sequenceId] as int) = 25)))) false else UDF(knownnotnull((((isnotnull(partitionValues#16396203[shardId]) AND isnotnull(cast(partitionValues#16396203[sequenceId] as int))) AND (partitionValues#16396203[shardId] = 0_3_10000000548)) AND (cast(partitionValues#16396203[sequenceId] as int) = 25))), size#16396204L, (stats#16396213.numRecords - coalesce(deletionVector#16396209.cardinality, 0)), stats#16396213.numRecords)) AND if (isnull(((stats#16396213.nullCount.worklistShardItemId < stats#16396213.numRecords) OR (isnull(stats#16396213.nullCount.worklistShardItemId) OR isnull(stats#16396213.numRecords))))) false else UDF(knownnotnull(((stats#16396213.nullCount.worklistShardItemId < stats#16396213.numRecords) OR (isnull(stats#16396213.nullCount.worklistShardItemId) OR isnull(stats#16396213.numRecords)))), size#16396204L, (stats#16396213.numRecords - coalesce(deletionVector#16396209.cardinality, 0)), stats#16396213.numRecords))

(3) Project
Output [11]: [path#16396202, partitionValues#16396203, size#16396204L, modificationTime#16396205L, dataChange#16396206, null AS stats#16695435, tags#16396208, deletionVector#16396209, baseRowId#16396210L, defaultRowCommitVersion#16396211L, clusteringProvider#16396212]
Input [11]: [path#16396202, partitionValues#16396203, size#16396204L, modificationTime#16396205L, dataChange#16396206, stats#16396213, tags#16396208, deletionVector#16396209, baseRowId#16396210L, defaultRowCommitVersion#16396211L, clusteringProvider#16396212]

SQL / DataFrame Properties

Name	Value
spark.activity.clearDeltaLogCache	false
spark.activity.clearSqlCache	false
spark.activity.hdlfsEnabled	true
spark.activity.isolateSession	true
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	c9993c94-c70c-370b-bf99-0989a3151b8b
temporal.activity.type	RunStreamWithId