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

Submitted Time: 2026/08/31 13:54:40
Duration: 0.6 s
Succeeded Jobs: 17680

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#2434772, partitionValues#2434773, size#2434774L, modificationTime#2434775L, dataChange#2434776, null AS stats#3394091, tags#2434778, deletionVector#2434779, baseRowId#2434780L, defaultRowCommitVersion#2434781L, clusteringProvider#2434782]"]; 1 [id="node1" labelType="html" label="Filter number of output rows: 37" tooltip="Filter ((UDF(true, size#2434774L, (stats#2434783.numRecords - coalesce(deletionVector#2434779.cardinality, 0)), stats#2434783.numRecords) AND if (isnull((((isnotnull(partitionValues#2434773[shardId]) AND isnotnull(cast(partitionValues#2434773[sequenceId] as int))) AND (partitionValues#2434773[shardId] = 0_5_10000000532)) AND (cast(partitionValues#2434773[sequenceId] as int) = 2)))) false else UDF(knownnotnull((((isnotnull(partitionValues#2434773[shardId]) AND isnotnull(cast(partitionValues#2434773[sequenceId] as int))) AND (partitionValues#2434773[shardId] = 0_5_10000000532)) AND (cast(partitionValues#2434773[sequenceId] as int) = 2))), size#2434774L, (stats#2434783.numRecords - coalesce(deletionVector#2434779.cardinality, 0)), stats#2434783.numRecords)) AND if (isnull(((stats#2434783.nullCount.worklistShardItemId < stats#2434783.numRecords) OR (isnull(stats#2434783.nullCount.worklistShardItemId) OR isnull(stats#2434783.numRecords))))) false else UDF(knownnotnull(((stats#2434783.nullCount.worklistShardItemId < stats#2434783.numRecords) OR (isnull(stats#2434783.nullCount.worklistShardItemId) OR isnull(stats#2434783.numRecords)))), size#2434774L, (stats#2434783.numRecords - coalesce(deletionVector#2434779.cardinality, 0)), stats#2434783.numRecords))"]; 2 [id="node2" labelType="html" label="Scan ExistingRDD Delta Table State with Stats #5 - hdlfs://7da5304c-1f57-47fa-b75a-0f0b4349c280.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/internal/prod-plant-snapshot/10000000532/_delta_log number of output rows: 5,772" tooltip="Scan ExistingRDD Delta Table State with Stats #5 - hdlfs://7da5304c-1f57-47fa-b75a-0f0b4349c280.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/internal/prod-plant-snapshot/10000000532/_delta_log[path#2434772,partitionValues#2434773,size#2434774L,modificationTime#2434775L,dataChange#2434776,stats#2434783,tags#2434778,deletionVector#2434779,baseRowId#2434780L,defaultRowCommitVersion#2434781L,clusteringProvider#2434782]"]; 1->0; 2->1; }

Details

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


(1) Scan ExistingRDD Delta Table State with Stats #5 - hdlfs://7da5304c-1f57-47fa-b75a-0f0b4349c280.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/internal/prod-plant-snapshot/10000000532/_delta_log
Output [11]: [path#2434772, partitionValues#2434773, size#2434774L, modificationTime#2434775L, dataChange#2434776, stats#2434783, tags#2434778, deletionVector#2434779, baseRowId#2434780L, defaultRowCommitVersion#2434781L, clusteringProvider#2434782]
Arguments: [path#2434772, partitionValues#2434773, size#2434774L, modificationTime#2434775L, dataChange#2434776, stats#2434783, tags#2434778, deletionVector#2434779, baseRowId#2434780L, defaultRowCommitVersion#2434781L, clusteringProvider#2434782], Delta Table State with Stats #5 - hdlfs://7da5304c-1f57-47fa-b75a-0f0b4349c280.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-qty-opt-service/internal/prod-plant-snapshot/10000000532/_delta_log MapPartitionsRDD[103225] at $anonfun$recordDeltaOperationInternal$1 at DatabricksLogging.scala:128, ExistingRDD, UnknownPartitioning(0)

(2) Filter
Input [11]: [path#2434772, partitionValues#2434773, size#2434774L, modificationTime#2434775L, dataChange#2434776, stats#2434783, tags#2434778, deletionVector#2434779, baseRowId#2434780L, defaultRowCommitVersion#2434781L, clusteringProvider#2434782]
Condition : ((UDF(true, size#2434774L, (stats#2434783.numRecords - coalesce(deletionVector#2434779.cardinality, 0)), stats#2434783.numRecords) AND if (isnull((((isnotnull(partitionValues#2434773[shardId]) AND isnotnull(cast(partitionValues#2434773[sequenceId] as int))) AND (partitionValues#2434773[shardId] = 0_5_10000000532)) AND (cast(partitionValues#2434773[sequenceId] as int) = 2)))) false else UDF(knownnotnull((((isnotnull(partitionValues#2434773[shardId]) AND isnotnull(cast(partitionValues#2434773[sequenceId] as int))) AND (partitionValues#2434773[shardId] = 0_5_10000000532)) AND (cast(partitionValues#2434773[sequenceId] as int) = 2))), size#2434774L, (stats#2434783.numRecords - coalesce(deletionVector#2434779.cardinality, 0)), stats#2434783.numRecords)) AND if (isnull(((stats#2434783.nullCount.worklistShardItemId < stats#2434783.numRecords) OR (isnull(stats#2434783.nullCount.worklistShardItemId) OR isnull(stats#2434783.numRecords))))) false else UDF(knownnotnull(((stats#2434783.nullCount.worklistShardItemId < stats#2434783.numRecords) OR (isnull(stats#2434783.nullCount.worklistShardItemId) OR isnull(stats#2434783.numRecords)))), size#2434774L, (stats#2434783.numRecords - coalesce(deletionVector#2434779.cardinality, 0)), stats#2434783.numRecords))

(3) Project
Output [11]: [path#2434772, partitionValues#2434773, size#2434774L, modificationTime#2434775L, dataChange#2434776, null AS stats#3394091, tags#2434778, deletionVector#2434779, baseRowId#2434780L, defaultRowCommitVersion#2434781L, clusteringProvider#2434782]
Input [11]: [path#2434772, partitionValues#2434773, size#2434774L, modificationTime#2434775L, dataChange#2434776, stats#2434783, tags#2434778, deletionVector#2434779, baseRowId#2434780L, defaultRowCommitVersion#2434781L, clusteringProvider#2434782]

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	b13104f5-e344-322f-bff3-a09d5377c4e4
temporal.activity.type	RunStreamWithId