== Physical Plan ==
AdaptiveSparkPlan (40)
+- == Final Plan ==
ResultQueryStage (27), Statistics(sizeInBytes=8.0 EiB)
+- Execute InsertIntoHadoopFsRelationCommand (26)
+- WriteFiles (25)
+- * Sort (24)
+- * Project (23)
+- * SortMergeJoin FullOuter (22)
:- * Sort (16)
: +- AQEShuffleRead (15)
: +- ShuffleQueryStage (14), Statistics(sizeInBytes=1896.0 B, rowCount=3)
: +- Exchange (13)
: +- * Project (12)
: +- * SortMergeJoin FullOuter (11)
: :- * Sort (5)
: : +- AQEShuffleRead (4)
: : +- ShuffleQueryStage (3), Statistics(sizeInBytes=1824.0 B, rowCount=3)
: : +- Exchange (2)
: : +- LocalTableScan (1)
: +- * Sort (10)
: +- AQEShuffleRead (9)
: +- ShuffleQueryStage (8), Statistics(sizeInBytes=144.0 B, rowCount=3)
: +- Exchange (7)
: +- LocalTableScan (6)
+- * Sort (21)
+- AQEShuffleRead (20)
+- ShuffleQueryStage (19), Statistics(sizeInBytes=192.0 B, rowCount=3)
+- Exchange (18)
+- LocalTableScan (17)
+- == Initial Plan ==
Execute InsertIntoHadoopFsRelationCommand (39)
+- WriteFiles (38)
+- Sort (37)
+- Project (36)
+- SortMergeJoin FullOuter (35)
:- Sort (33)
: +- Exchange (32)
: +- Project (31)
: +- SortMergeJoin FullOuter (30)
: :- Sort (28)
: : +- Exchange (2)
: : +- LocalTableScan (1)
: +- Sort (29)
: +- Exchange (7)
: +- LocalTableScan (6)
+- Sort (34)
+- Exchange (18)
+- LocalTableScan (17)
(1) LocalTableScan
Output [73]: [jobId#3473, stageCount#3474L, totalTaskCount#3475L, minTaskCountPerStage#3476L, maxTaskCountPerStage#3477L, medianTaskCountPerStage#3478L, bytesSpilledToDiskSerializedTotal#3479L, bytesSpilledToDiskSerializedMin#3480L, bytesSpilledToDiskSerializedMax#3481L, bytesSpilledToDiskSerializedMedian#3482L, taskCpuTimeTotal#3483L, taskCpuTimeMin#3484L, taskCpuTimeMax#3485L, taskCpuTimeMedian#3486L, taskDeserializeCpuTimeTotal#3487L, taskDeserializeCpuTimeMin#3488L, taskDeserializeCpuTimeMax#3489L, taskDeserializeCpuTimeMedian#3490L, taskDeserializeTimeTotal#3491L, taskDeserializeTimeMin#3492L, taskDeserializeTimeMax#3493L, taskDeserializeTimeMedian#3494L, taskRunTimeTotal#3495L, taskRunTimeMin#3496L, taskRunTimeMax#3497L, taskRunTimeMedian#3498L, jvmGcTimeTotal#3499L, jvmGcTimeMin#3500L, jvmGcTimeMax#3501L, jvmGcTimeMedian#3502L, bytesSpilledToDiskRawTotal#3503L, bytesSpilledToDiskRawMin#3504L, bytesSpilledToDiskRawMax#3505L, bytesSpilledToDiskRawMedian#3506L, resultSerializationTimeTotal#3507L, resultSerializationTimeMin#3508L, resultSerializationTimeMax#3509L, resultSerializationTimeMedian#3510L, resultSizeToDriverTotal#3511L, resultSizeToDriverMin#3512L, resultSizeToDriverMax#3513L, resultSizeToDriverMedian#3514L, taskPeakExecutionMemoryMin#3515L, taskPeakExecutionMemoryMax#3516L, taskPeakExecutionMemoryMedian#3517L, persistencyBytesReadTotal#3518L, persistencyBytesReadMin#3519L, persistencyBytesReadMax#3520L, persistencyBytesReadMedian#3521L, persistencyRecordsReadTotal#3522L, persistencyRecordsReadMin#3523L, persistencyRecordsReadMax#3524L, persistencyRecordsReadMedian#3525L, persistencyBytesWrittenTotal#3526L, persistencyBytesWrittenMin#3527L, persistencyBytesWrittenMax#3528L, persistencyBytesWrittenMedian#3529L, persistencyRecordsWrittenTotal#3530L, persistencyRecordsWrittenMin#3531L, persistencyRecordsWrittenMax#3532L, persistencyRecordsWrittenMedian#3533L, shuffleConsumeRecordsReadTotal#3534L, shuffleConsumeRemoteBlocksFetchedTotal#3535L, shuffleConsumeLocalBlocksFetchedTotal#3536L, shuffleConsumeTotalBlocksFetchedTotal#3537L, shuffleConsumeRemoteBytesReadTotal#3538L, shuffleConsumeLocalBytesReadTotal#3539L, shuffleConsumeTotalBytesReadTotal#3540L, shuffleConsumeRemoteBytesReadToDiskTotal#3541L, shuffleConsumeFetchWaitTimeTotal#3542L, shuffleProduceBytesWrittenTotal#3543L, shuffleProduceRecordsWrittenTotal#3544L, shuffleProduceWriteTimeTotal#3545L]
Arguments: [jobId#3473, stageCount#3474L, totalTaskCount#3475L, minTaskCountPerStage#3476L, maxTaskCountPerStage#3477L, medianTaskCountPerStage#3478L, bytesSpilledToDiskSerializedTotal#3479L, bytesSpilledToDiskSerializedMin#3480L, bytesSpilledToDiskSerializedMax#3481L, bytesSpilledToDiskSerializedMedian#3482L, taskCpuTimeTotal#3483L, taskCpuTimeMin#3484L, taskCpuTimeMax#3485L, taskCpuTimeMedian#3486L, taskDeserializeCpuTimeTotal#3487L, taskDeserializeCpuTimeMin#3488L, taskDeserializeCpuTimeMax#3489L, taskDeserializeCpuTimeMedian#3490L, taskDeserializeTimeTotal#3491L, taskDeserializeTimeMin#3492L, taskDeserializeTimeMax#3493L, taskDeserializeTimeMedian#3494L, taskRunTimeTotal#3495L, taskRunTimeMin#3496L, taskRunTimeMax#3497L, ... 48 more fields]
(2) Exchange
Input [73]: [jobId#3473, stageCount#3474L, totalTaskCount#3475L, minTaskCountPerStage#3476L, maxTaskCountPerStage#3477L, medianTaskCountPerStage#3478L, bytesSpilledToDiskSerializedTotal#3479L, bytesSpilledToDiskSerializedMin#3480L, bytesSpilledToDiskSerializedMax#3481L, bytesSpilledToDiskSerializedMedian#3482L, taskCpuTimeTotal#3483L, taskCpuTimeMin#3484L, taskCpuTimeMax#3485L, taskCpuTimeMedian#3486L, taskDeserializeCpuTimeTotal#3487L, taskDeserializeCpuTimeMin#3488L, taskDeserializeCpuTimeMax#3489L, taskDeserializeCpuTimeMedian#3490L, taskDeserializeTimeTotal#3491L, taskDeserializeTimeMin#3492L, taskDeserializeTimeMax#3493L, taskDeserializeTimeMedian#3494L, taskRunTimeTotal#3495L, taskRunTimeMin#3496L, taskRunTimeMax#3497L, taskRunTimeMedian#3498L, jvmGcTimeTotal#3499L, jvmGcTimeMin#3500L, jvmGcTimeMax#3501L, jvmGcTimeMedian#3502L, bytesSpilledToDiskRawTotal#3503L, bytesSpilledToDiskRawMin#3504L, bytesSpilledToDiskRawMax#3505L, bytesSpilledToDiskRawMedian#3506L, resultSerializationTimeTotal#3507L, resultSerializationTimeMin#3508L, resultSerializationTimeMax#3509L, resultSerializationTimeMedian#3510L, resultSizeToDriverTotal#3511L, resultSizeToDriverMin#3512L, resultSizeToDriverMax#3513L, resultSizeToDriverMedian#3514L, taskPeakExecutionMemoryMin#3515L, taskPeakExecutionMemoryMax#3516L, taskPeakExecutionMemoryMedian#3517L, persistencyBytesReadTotal#3518L, persistencyBytesReadMin#3519L, persistencyBytesReadMax#3520L, persistencyBytesReadMedian#3521L, persistencyRecordsReadTotal#3522L, persistencyRecordsReadMin#3523L, persistencyRecordsReadMax#3524L, persistencyRecordsReadMedian#3525L, persistencyBytesWrittenTotal#3526L, persistencyBytesWrittenMin#3527L, persistencyBytesWrittenMax#3528L, persistencyBytesWrittenMedian#3529L, persistencyRecordsWrittenTotal#3530L, persistencyRecordsWrittenMin#3531L, persistencyRecordsWrittenMax#3532L, persistencyRecordsWrittenMedian#3533L, shuffleConsumeRecordsReadTotal#3534L, shuffleConsumeRemoteBlocksFetchedTotal#3535L, shuffleConsumeLocalBlocksFetchedTotal#3536L, shuffleConsumeTotalBlocksFetchedTotal#3537L, shuffleConsumeRemoteBytesReadTotal#3538L, shuffleConsumeLocalBytesReadTotal#3539L, shuffleConsumeTotalBytesReadTotal#3540L, shuffleConsumeRemoteBytesReadToDiskTotal#3541L, shuffleConsumeFetchWaitTimeTotal#3542L, shuffleProduceBytesWrittenTotal#3543L, shuffleProduceRecordsWrittenTotal#3544L, shuffleProduceWriteTimeTotal#3545L]
Arguments: hashpartitioning(jobId#3473, 200), ENSURE_REQUIREMENTS, [plan_id=4451]
(3) ShuffleQueryStage
Output [73]: [jobId#3473, stageCount#3474L, totalTaskCount#3475L, minTaskCountPerStage#3476L, maxTaskCountPerStage#3477L, medianTaskCountPerStage#3478L, bytesSpilledToDiskSerializedTotal#3479L, bytesSpilledToDiskSerializedMin#3480L, bytesSpilledToDiskSerializedMax#3481L, bytesSpilledToDiskSerializedMedian#3482L, taskCpuTimeTotal#3483L, taskCpuTimeMin#3484L, taskCpuTimeMax#3485L, taskCpuTimeMedian#3486L, taskDeserializeCpuTimeTotal#3487L, taskDeserializeCpuTimeMin#3488L, taskDeserializeCpuTimeMax#3489L, taskDeserializeCpuTimeMedian#3490L, taskDeserializeTimeTotal#3491L, taskDeserializeTimeMin#3492L, taskDeserializeTimeMax#3493L, taskDeserializeTimeMedian#3494L, taskRunTimeTotal#3495L, taskRunTimeMin#3496L, taskRunTimeMax#3497L, taskRunTimeMedian#3498L, jvmGcTimeTotal#3499L, jvmGcTimeMin#3500L, jvmGcTimeMax#3501L, jvmGcTimeMedian#3502L, bytesSpilledToDiskRawTotal#3503L, bytesSpilledToDiskRawMin#3504L, bytesSpilledToDiskRawMax#3505L, bytesSpilledToDiskRawMedian#3506L, resultSerializationTimeTotal#3507L, resultSerializationTimeMin#3508L, resultSerializationTimeMax#3509L, resultSerializationTimeMedian#3510L, resultSizeToDriverTotal#3511L, resultSizeToDriverMin#3512L, resultSizeToDriverMax#3513L, resultSizeToDriverMedian#3514L, taskPeakExecutionMemoryMin#3515L, taskPeakExecutionMemoryMax#3516L, taskPeakExecutionMemoryMedian#3517L, persistencyBytesReadTotal#3518L, persistencyBytesReadMin#3519L, persistencyBytesReadMax#3520L, persistencyBytesReadMedian#3521L, persistencyRecordsReadTotal#3522L, persistencyRecordsReadMin#3523L, persistencyRecordsReadMax#3524L, persistencyRecordsReadMedian#3525L, persistencyBytesWrittenTotal#3526L, persistencyBytesWrittenMin#3527L, persistencyBytesWrittenMax#3528L, persistencyBytesWrittenMedian#3529L, persistencyRecordsWrittenTotal#3530L, persistencyRecordsWrittenMin#3531L, persistencyRecordsWrittenMax#3532L, persistencyRecordsWrittenMedian#3533L, shuffleConsumeRecordsReadTotal#3534L, shuffleConsumeRemoteBlocksFetchedTotal#3535L, shuffleConsumeLocalBlocksFetchedTotal#3536L, shuffleConsumeTotalBlocksFetchedTotal#3537L, shuffleConsumeRemoteBytesReadTotal#3538L, shuffleConsumeLocalBytesReadTotal#3539L, shuffleConsumeTotalBytesReadTotal#3540L, shuffleConsumeRemoteBytesReadToDiskTotal#3541L, shuffleConsumeFetchWaitTimeTotal#3542L, shuffleProduceBytesWrittenTotal#3543L, shuffleProduceRecordsWrittenTotal#3544L, shuffleProduceWriteTimeTotal#3545L]
Arguments: 0
(4) AQEShuffleRead
Input [73]: [jobId#3473, stageCount#3474L, totalTaskCount#3475L, minTaskCountPerStage#3476L, maxTaskCountPerStage#3477L, medianTaskCountPerStage#3478L, bytesSpilledToDiskSerializedTotal#3479L, bytesSpilledToDiskSerializedMin#3480L, bytesSpilledToDiskSerializedMax#3481L, bytesSpilledToDiskSerializedMedian#3482L, taskCpuTimeTotal#3483L, taskCpuTimeMin#3484L, taskCpuTimeMax#3485L, taskCpuTimeMedian#3486L, taskDeserializeCpuTimeTotal#3487L, taskDeserializeCpuTimeMin#3488L, taskDeserializeCpuTimeMax#3489L, taskDeserializeCpuTimeMedian#3490L, taskDeserializeTimeTotal#3491L, taskDeserializeTimeMin#3492L, taskDeserializeTimeMax#3493L, taskDeserializeTimeMedian#3494L, taskRunTimeTotal#3495L, taskRunTimeMin#3496L, taskRunTimeMax#3497L, taskRunTimeMedian#3498L, jvmGcTimeTotal#3499L, jvmGcTimeMin#3500L, jvmGcTimeMax#3501L, jvmGcTimeMedian#3502L, bytesSpilledToDiskRawTotal#3503L, bytesSpilledToDiskRawMin#3504L, bytesSpilledToDiskRawMax#3505L, bytesSpilledToDiskRawMedian#3506L, resultSerializationTimeTotal#3507L, resultSerializationTimeMin#3508L, resultSerializationTimeMax#3509L, resultSerializationTimeMedian#3510L, resultSizeToDriverTotal#3511L, resultSizeToDriverMin#3512L, resultSizeToDriverMax#3513L, resultSizeToDriverMedian#3514L, taskPeakExecutionMemoryMin#3515L, taskPeakExecutionMemoryMax#3516L, taskPeakExecutionMemoryMedian#3517L, persistencyBytesReadTotal#3518L, persistencyBytesReadMin#3519L, persistencyBytesReadMax#3520L, persistencyBytesReadMedian#3521L, persistencyRecordsReadTotal#3522L, persistencyRecordsReadMin#3523L, persistencyRecordsReadMax#3524L, persistencyRecordsReadMedian#3525L, persistencyBytesWrittenTotal#3526L, persistencyBytesWrittenMin#3527L, persistencyBytesWrittenMax#3528L, persistencyBytesWrittenMedian#3529L, persistencyRecordsWrittenTotal#3530L, persistencyRecordsWrittenMin#3531L, persistencyRecordsWrittenMax#3532L, persistencyRecordsWrittenMedian#3533L, shuffleConsumeRecordsReadTotal#3534L, shuffleConsumeRemoteBlocksFetchedTotal#3535L, shuffleConsumeLocalBlocksFetchedTotal#3536L, shuffleConsumeTotalBlocksFetchedTotal#3537L, shuffleConsumeRemoteBytesReadTotal#3538L, shuffleConsumeLocalBytesReadTotal#3539L, shuffleConsumeTotalBytesReadTotal#3540L, shuffleConsumeRemoteBytesReadToDiskTotal#3541L, shuffleConsumeFetchWaitTimeTotal#3542L, shuffleProduceBytesWrittenTotal#3543L, shuffleProduceRecordsWrittenTotal#3544L, shuffleProduceWriteTimeTotal#3545L]
Arguments: coalesced
(5) Sort [codegen id : 1]
Input [73]: [jobId#3473, stageCount#3474L, totalTaskCount#3475L, minTaskCountPerStage#3476L, maxTaskCountPerStage#3477L, medianTaskCountPerStage#3478L, bytesSpilledToDiskSerializedTotal#3479L, bytesSpilledToDiskSerializedMin#3480L, bytesSpilledToDiskSerializedMax#3481L, bytesSpilledToDiskSerializedMedian#3482L, taskCpuTimeTotal#3483L, taskCpuTimeMin#3484L, taskCpuTimeMax#3485L, taskCpuTimeMedian#3486L, taskDeserializeCpuTimeTotal#3487L, taskDeserializeCpuTimeMin#3488L, taskDeserializeCpuTimeMax#3489L, taskDeserializeCpuTimeMedian#3490L, taskDeserializeTimeTotal#3491L, taskDeserializeTimeMin#3492L, taskDeserializeTimeMax#3493L, taskDeserializeTimeMedian#3494L, taskRunTimeTotal#3495L, taskRunTimeMin#3496L, taskRunTimeMax#3497L, taskRunTimeMedian#3498L, jvmGcTimeTotal#3499L, jvmGcTimeMin#3500L, jvmGcTimeMax#3501L, jvmGcTimeMedian#3502L, bytesSpilledToDiskRawTotal#3503L, bytesSpilledToDiskRawMin#3504L, bytesSpilledToDiskRawMax#3505L, bytesSpilledToDiskRawMedian#3506L, resultSerializationTimeTotal#3507L, resultSerializationTimeMin#3508L, resultSerializationTimeMax#3509L, resultSerializationTimeMedian#3510L, resultSizeToDriverTotal#3511L, resultSizeToDriverMin#3512L, resultSizeToDriverMax#3513L, resultSizeToDriverMedian#3514L, taskPeakExecutionMemoryMin#3515L, taskPeakExecutionMemoryMax#3516L, taskPeakExecutionMemoryMedian#3517L, persistencyBytesReadTotal#3518L, persistencyBytesReadMin#3519L, persistencyBytesReadMax#3520L, persistencyBytesReadMedian#3521L, persistencyRecordsReadTotal#3522L, persistencyRecordsReadMin#3523L, persistencyRecordsReadMax#3524L, persistencyRecordsReadMedian#3525L, persistencyBytesWrittenTotal#3526L, persistencyBytesWrittenMin#3527L, persistencyBytesWrittenMax#3528L, persistencyBytesWrittenMedian#3529L, persistencyRecordsWrittenTotal#3530L, persistencyRecordsWrittenMin#3531L, persistencyRecordsWrittenMax#3532L, persistencyRecordsWrittenMedian#3533L, shuffleConsumeRecordsReadTotal#3534L, shuffleConsumeRemoteBlocksFetchedTotal#3535L, shuffleConsumeLocalBlocksFetchedTotal#3536L, shuffleConsumeTotalBlocksFetchedTotal#3537L, shuffleConsumeRemoteBytesReadTotal#3538L, shuffleConsumeLocalBytesReadTotal#3539L, shuffleConsumeTotalBytesReadTotal#3540L, shuffleConsumeRemoteBytesReadToDiskTotal#3541L, shuffleConsumeFetchWaitTimeTotal#3542L, shuffleProduceBytesWrittenTotal#3543L, shuffleProduceRecordsWrittenTotal#3544L, shuffleProduceWriteTimeTotal#3545L]
Arguments: [jobId#3473 ASC NULLS FIRST], false, 0
(6) LocalTableScan
Output [4]: [jobId#3546, peakExecutionMemory#3547L, peakExecutionMemoryCliqueDuration#3548L, peakExecutionMemoryCliqueSize#3549L]
Arguments: [jobId#3546, peakExecutionMemory#3547L, peakExecutionMemoryCliqueDuration#3548L, peakExecutionMemoryCliqueSize#3549L]
(7) Exchange
Input [4]: [jobId#3546, peakExecutionMemory#3547L, peakExecutionMemoryCliqueDuration#3548L, peakExecutionMemoryCliqueSize#3549L]
Arguments: hashpartitioning(jobId#3546, 200), ENSURE_REQUIREMENTS, [plan_id=4452]
(8) ShuffleQueryStage
Output [4]: [jobId#3546, peakExecutionMemory#3547L, peakExecutionMemoryCliqueDuration#3548L, peakExecutionMemoryCliqueSize#3549L]
Arguments: 1
(9) AQEShuffleRead
Input [4]: [jobId#3546, peakExecutionMemory#3547L, peakExecutionMemoryCliqueDuration#3548L, peakExecutionMemoryCliqueSize#3549L]
Arguments: coalesced
(10) Sort [codegen id : 2]
Input [4]: [jobId#3546, peakExecutionMemory#3547L, peakExecutionMemoryCliqueDuration#3548L, peakExecutionMemoryCliqueSize#3549L]
Arguments: [jobId#3546 ASC NULLS FIRST], false, 0
(11) SortMergeJoin [codegen id : 3]
Left keys [1]: [jobId#3473]
Right keys [1]: [jobId#3546]
Join type: FullOuter
Join condition: None
(12) Project [codegen id : 3]
Output [76]: [coalesce(jobId#3473, jobId#3546) AS jobId#3556, stageCount#3474L, totalTaskCount#3475L, minTaskCountPerStage#3476L, maxTaskCountPerStage#3477L, medianTaskCountPerStage#3478L, bytesSpilledToDiskSerializedTotal#3479L, bytesSpilledToDiskSerializedMin#3480L, bytesSpilledToDiskSerializedMax#3481L, bytesSpilledToDiskSerializedMedian#3482L, taskCpuTimeTotal#3483L, taskCpuTimeMin#3484L, taskCpuTimeMax#3485L, taskCpuTimeMedian#3486L, taskDeserializeCpuTimeTotal#3487L, taskDeserializeCpuTimeMin#3488L, taskDeserializeCpuTimeMax#3489L, taskDeserializeCpuTimeMedian#3490L, taskDeserializeTimeTotal#3491L, taskDeserializeTimeMin#3492L, taskDeserializeTimeMax#3493L, taskDeserializeTimeMedian#3494L, taskRunTimeTotal#3495L, taskRunTimeMin#3496L, taskRunTimeMax#3497L, taskRunTimeMedian#3498L, jvmGcTimeTotal#3499L, jvmGcTimeMin#3500L, jvmGcTimeMax#3501L, jvmGcTimeMedian#3502L, bytesSpilledToDiskRawTotal#3503L, bytesSpilledToDiskRawMin#3504L, bytesSpilledToDiskRawMax#3505L, bytesSpilledToDiskRawMedian#3506L, resultSerializationTimeTotal#3507L, resultSerializationTimeMin#3508L, resultSerializationTimeMax#3509L, resultSerializationTimeMedian#3510L, resultSizeToDriverTotal#3511L, resultSizeToDriverMin#3512L, resultSizeToDriverMax#3513L, resultSizeToDriverMedian#3514L, taskPeakExecutionMemoryMin#3515L, taskPeakExecutionMemoryMax#3516L, taskPeakExecutionMemoryMedian#3517L, persistencyBytesReadTotal#3518L, persistencyBytesReadMin#3519L, persistencyBytesReadMax#3520L, persistencyBytesReadMedian#3521L, persistencyRecordsReadTotal#3522L, persistencyRecordsReadMin#3523L, persistencyRecordsReadMax#3524L, persistencyRecordsReadMedian#3525L, persistencyBytesWrittenTotal#3526L, persistencyBytesWrittenMin#3527L, persistencyBytesWrittenMax#3528L, persistencyBytesWrittenMedian#3529L, persistencyRecordsWrittenTotal#3530L, persistencyRecordsWrittenMin#3531L, persistencyRecordsWrittenMax#3532L, persistencyRecordsWrittenMedian#3533L, shuffleConsumeRecordsReadTotal#3534L, shuffleConsumeRemoteBlocksFetchedTotal#3535L, shuffleConsumeLocalBlocksFetchedTotal#3536L, shuffleConsumeTotalBlocksFetchedTotal#3537L, shuffleConsumeRemoteBytesReadTotal#3538L, shuffleConsumeLocalBytesReadTotal#3539L, shuffleConsumeTotalBytesReadTotal#3540L, shuffleConsumeRemoteBytesReadToDiskTotal#3541L, shuffleConsumeFetchWaitTimeTotal#3542L, shuffleProduceBytesWrittenTotal#3543L, shuffleProduceRecordsWrittenTotal#3544L, shuffleProduceWriteTimeTotal#3545L, peakExecutionMemory#3547L, peakExecutionMemoryCliqueDuration#3548L, peakExecutionMemoryCliqueSize#3549L]
Input [77]: [jobId#3473, stageCount#3474L, totalTaskCount#3475L, minTaskCountPerStage#3476L, maxTaskCountPerStage#3477L, medianTaskCountPerStage#3478L, bytesSpilledToDiskSerializedTotal#3479L, bytesSpilledToDiskSerializedMin#3480L, bytesSpilledToDiskSerializedMax#3481L, bytesSpilledToDiskSerializedMedian#3482L, taskCpuTimeTotal#3483L, taskCpuTimeMin#3484L, taskCpuTimeMax#3485L, taskCpuTimeMedian#3486L, taskDeserializeCpuTimeTotal#3487L, taskDeserializeCpuTimeMin#3488L, taskDeserializeCpuTimeMax#3489L, taskDeserializeCpuTimeMedian#3490L, taskDeserializeTimeTotal#3491L, taskDeserializeTimeMin#3492L, taskDeserializeTimeMax#3493L, taskDeserializeTimeMedian#3494L, taskRunTimeTotal#3495L, taskRunTimeMin#3496L, taskRunTimeMax#3497L, taskRunTimeMedian#3498L, jvmGcTimeTotal#3499L, jvmGcTimeMin#3500L, jvmGcTimeMax#3501L, jvmGcTimeMedian#3502L, bytesSpilledToDiskRawTotal#3503L, bytesSpilledToDiskRawMin#3504L, bytesSpilledToDiskRawMax#3505L, bytesSpilledToDiskRawMedian#3506L, resultSerializationTimeTotal#3507L, resultSerializationTimeMin#3508L, resultSerializationTimeMax#3509L, resultSerializationTimeMedian#3510L, resultSizeToDriverTotal#3511L, resultSizeToDriverMin#3512L, resultSizeToDriverMax#3513L, resultSizeToDriverMedian#3514L, taskPeakExecutionMemoryMin#3515L, taskPeakExecutionMemoryMax#3516L, taskPeakExecutionMemoryMedian#3517L, persistencyBytesReadTotal#3518L, persistencyBytesReadMin#3519L, persistencyBytesReadMax#3520L, persistencyBytesReadMedian#3521L, persistencyRecordsReadTotal#3522L, persistencyRecordsReadMin#3523L, persistencyRecordsReadMax#3524L, persistencyRecordsReadMedian#3525L, persistencyBytesWrittenTotal#3526L, persistencyBytesWrittenMin#3527L, persistencyBytesWrittenMax#3528L, persistencyBytesWrittenMedian#3529L, persistencyRecordsWrittenTotal#3530L, persistencyRecordsWrittenMin#3531L, persistencyRecordsWrittenMax#3532L, persistencyRecordsWrittenMedian#3533L, shuffleConsumeRecordsReadTotal#3534L, shuffleConsumeRemoteBlocksFetchedTotal#3535L, shuffleConsumeLocalBlocksFetchedTotal#3536L, shuffleConsumeTotalBlocksFetchedTotal#3537L, shuffleConsumeRemoteBytesReadTotal#3538L, shuffleConsumeLocalBytesReadTotal#3539L, shuffleConsumeTotalBytesReadTotal#3540L, shuffleConsumeRemoteBytesReadToDiskTotal#3541L, shuffleConsumeFetchWaitTimeTotal#3542L, shuffleProduceBytesWrittenTotal#3543L, shuffleProduceRecordsWrittenTotal#3544L, shuffleProduceWriteTimeTotal#3545L, jobId#3546, peakExecutionMemory#3547L, peakExecutionMemoryCliqueDuration#3548L, peakExecutionMemoryCliqueSize#3549L]
(13) Exchange
Input [76]: [jobId#3556, stageCount#3474L, totalTaskCount#3475L, minTaskCountPerStage#3476L, maxTaskCountPerStage#3477L, medianTaskCountPerStage#3478L, bytesSpilledToDiskSerializedTotal#3479L, bytesSpilledToDiskSerializedMin#3480L, bytesSpilledToDiskSerializedMax#3481L, bytesSpilledToDiskSerializedMedian#3482L, taskCpuTimeTotal#3483L, taskCpuTimeMin#3484L, taskCpuTimeMax#3485L, taskCpuTimeMedian#3486L, taskDeserializeCpuTimeTotal#3487L, taskDeserializeCpuTimeMin#3488L, taskDeserializeCpuTimeMax#3489L, taskDeserializeCpuTimeMedian#3490L, taskDeserializeTimeTotal#3491L, taskDeserializeTimeMin#3492L, taskDeserializeTimeMax#3493L, taskDeserializeTimeMedian#3494L, taskRunTimeTotal#3495L, taskRunTimeMin#3496L, taskRunTimeMax#3497L, taskRunTimeMedian#3498L, jvmGcTimeTotal#3499L, jvmGcTimeMin#3500L, jvmGcTimeMax#3501L, jvmGcTimeMedian#3502L, bytesSpilledToDiskRawTotal#3503L, bytesSpilledToDiskRawMin#3504L, bytesSpilledToDiskRawMax#3505L, bytesSpilledToDiskRawMedian#3506L, resultSerializationTimeTotal#3507L, resultSerializationTimeMin#3508L, resultSerializationTimeMax#3509L, resultSerializationTimeMedian#3510L, resultSizeToDriverTotal#3511L, resultSizeToDriverMin#3512L, resultSizeToDriverMax#3513L, resultSizeToDriverMedian#3514L, taskPeakExecutionMemoryMin#3515L, taskPeakExecutionMemoryMax#3516L, taskPeakExecutionMemoryMedian#3517L, persistencyBytesReadTotal#3518L, persistencyBytesReadMin#3519L, persistencyBytesReadMax#3520L, persistencyBytesReadMedian#3521L, persistencyRecordsReadTotal#3522L, persistencyRecordsReadMin#3523L, persistencyRecordsReadMax#3524L, persistencyRecordsReadMedian#3525L, persistencyBytesWrittenTotal#3526L, persistencyBytesWrittenMin#3527L, persistencyBytesWrittenMax#3528L, persistencyBytesWrittenMedian#3529L, persistencyRecordsWrittenTotal#3530L, persistencyRecordsWrittenMin#3531L, persistencyRecordsWrittenMax#3532L, persistencyRecordsWrittenMedian#3533L, shuffleConsumeRecordsReadTotal#3534L, shuffleConsumeRemoteBlocksFetchedTotal#3535L, shuffleConsumeLocalBlocksFetchedTotal#3536L, shuffleConsumeTotalBlocksFetchedTotal#3537L, shuffleConsumeRemoteBytesReadTotal#3538L, shuffleConsumeLocalBytesReadTotal#3539L, shuffleConsumeTotalBytesReadTotal#3540L, shuffleConsumeRemoteBytesReadToDiskTotal#3541L, shuffleConsumeFetchWaitTimeTotal#3542L, shuffleProduceBytesWrittenTotal#3543L, shuffleProduceRecordsWrittenTotal#3544L, shuffleProduceWriteTimeTotal#3545L, peakExecutionMemory#3547L, peakExecutionMemoryCliqueDuration#3548L, peakExecutionMemoryCliqueSize#3549L]
Arguments: hashpartitioning(jobId#3556, 200), ENSURE_REQUIREMENTS, [plan_id=4656]
(14) ShuffleQueryStage
Output [76]: [jobId#3556, stageCount#3474L, totalTaskCount#3475L, minTaskCountPerStage#3476L, maxTaskCountPerStage#3477L, medianTaskCountPerStage#3478L, bytesSpilledToDiskSerializedTotal#3479L, bytesSpilledToDiskSerializedMin#3480L, bytesSpilledToDiskSerializedMax#3481L, bytesSpilledToDiskSerializedMedian#3482L, taskCpuTimeTotal#3483L, taskCpuTimeMin#3484L, taskCpuTimeMax#3485L, taskCpuTimeMedian#3486L, taskDeserializeCpuTimeTotal#3487L, taskDeserializeCpuTimeMin#3488L, taskDeserializeCpuTimeMax#3489L, taskDeserializeCpuTimeMedian#3490L, taskDeserializeTimeTotal#3491L, taskDeserializeTimeMin#3492L, taskDeserializeTimeMax#3493L, taskDeserializeTimeMedian#3494L, taskRunTimeTotal#3495L, taskRunTimeMin#3496L, taskRunTimeMax#3497L, taskRunTimeMedian#3498L, jvmGcTimeTotal#3499L, jvmGcTimeMin#3500L, jvmGcTimeMax#3501L, jvmGcTimeMedian#3502L, bytesSpilledToDiskRawTotal#3503L, bytesSpilledToDiskRawMin#3504L, bytesSpilledToDiskRawMax#3505L, bytesSpilledToDiskRawMedian#3506L, resultSerializationTimeTotal#3507L, resultSerializationTimeMin#3508L, resultSerializationTimeMax#3509L, resultSerializationTimeMedian#3510L, resultSizeToDriverTotal#3511L, resultSizeToDriverMin#3512L, resultSizeToDriverMax#3513L, resultSizeToDriverMedian#3514L, taskPeakExecutionMemoryMin#3515L, taskPeakExecutionMemoryMax#3516L, taskPeakExecutionMemoryMedian#3517L, persistencyBytesReadTotal#3518L, persistencyBytesReadMin#3519L, persistencyBytesReadMax#3520L, persistencyBytesReadMedian#3521L, persistencyRecordsReadTotal#3522L, persistencyRecordsReadMin#3523L, persistencyRecordsReadMax#3524L, persistencyRecordsReadMedian#3525L, persistencyBytesWrittenTotal#3526L, persistencyBytesWrittenMin#3527L, persistencyBytesWrittenMax#3528L, persistencyBytesWrittenMedian#3529L, persistencyRecordsWrittenTotal#3530L, persistencyRecordsWrittenMin#3531L, persistencyRecordsWrittenMax#3532L, persistencyRecordsWrittenMedian#3533L, shuffleConsumeRecordsReadTotal#3534L, shuffleConsumeRemoteBlocksFetchedTotal#3535L, shuffleConsumeLocalBlocksFetchedTotal#3536L, shuffleConsumeTotalBlocksFetchedTotal#3537L, shuffleConsumeRemoteBytesReadTotal#3538L, shuffleConsumeLocalBytesReadTotal#3539L, shuffleConsumeTotalBytesReadTotal#3540L, shuffleConsumeRemoteBytesReadToDiskTotal#3541L, shuffleConsumeFetchWaitTimeTotal#3542L, shuffleProduceBytesWrittenTotal#3543L, shuffleProduceRecordsWrittenTotal#3544L, shuffleProduceWriteTimeTotal#3545L, peakExecutionMemory#3547L, peakExecutionMemoryCliqueDuration#3548L, peakExecutionMemoryCliqueSize#3549L]
Arguments: 3
(15) AQEShuffleRead
Input [76]: [jobId#3556, stageCount#3474L, totalTaskCount#3475L, minTaskCountPerStage#3476L, maxTaskCountPerStage#3477L, medianTaskCountPerStage#3478L, bytesSpilledToDiskSerializedTotal#3479L, bytesSpilledToDiskSerializedMin#3480L, bytesSpilledToDiskSerializedMax#3481L, bytesSpilledToDiskSerializedMedian#3482L, taskCpuTimeTotal#3483L, taskCpuTimeMin#3484L, taskCpuTimeMax#3485L, taskCpuTimeMedian#3486L, taskDeserializeCpuTimeTotal#3487L, taskDeserializeCpuTimeMin#3488L, taskDeserializeCpuTimeMax#3489L, taskDeserializeCpuTimeMedian#3490L, taskDeserializeTimeTotal#3491L, taskDeserializeTimeMin#3492L, taskDeserializeTimeMax#3493L, taskDeserializeTimeMedian#3494L, taskRunTimeTotal#3495L, taskRunTimeMin#3496L, taskRunTimeMax#3497L, taskRunTimeMedian#3498L, jvmGcTimeTotal#3499L, jvmGcTimeMin#3500L, jvmGcTimeMax#3501L, jvmGcTimeMedian#3502L, bytesSpilledToDiskRawTotal#3503L, bytesSpilledToDiskRawMin#3504L, bytesSpilledToDiskRawMax#3505L, bytesSpilledToDiskRawMedian#3506L, resultSerializationTimeTotal#3507L, resultSerializationTimeMin#3508L, resultSerializationTimeMax#3509L, resultSerializationTimeMedian#3510L, resultSizeToDriverTotal#3511L, resultSizeToDriverMin#3512L, resultSizeToDriverMax#3513L, resultSizeToDriverMedian#3514L, taskPeakExecutionMemoryMin#3515L, taskPeakExecutionMemoryMax#3516L, taskPeakExecutionMemoryMedian#3517L, persistencyBytesReadTotal#3518L, persistencyBytesReadMin#3519L, persistencyBytesReadMax#3520L, persistencyBytesReadMedian#3521L, persistencyRecordsReadTotal#3522L, persistencyRecordsReadMin#3523L, persistencyRecordsReadMax#3524L, persistencyRecordsReadMedian#3525L, persistencyBytesWrittenTotal#3526L, persistencyBytesWrittenMin#3527L, persistencyBytesWrittenMax#3528L, persistencyBytesWrittenMedian#3529L, persistencyRecordsWrittenTotal#3530L, persistencyRecordsWrittenMin#3531L, persistencyRecordsWrittenMax#3532L, persistencyRecordsWrittenMedian#3533L, shuffleConsumeRecordsReadTotal#3534L, shuffleConsumeRemoteBlocksFetchedTotal#3535L, shuffleConsumeLocalBlocksFetchedTotal#3536L, shuffleConsumeTotalBlocksFetchedTotal#3537L, shuffleConsumeRemoteBytesReadTotal#3538L, shuffleConsumeLocalBytesReadTotal#3539L, shuffleConsumeTotalBytesReadTotal#3540L, shuffleConsumeRemoteBytesReadToDiskTotal#3541L, shuffleConsumeFetchWaitTimeTotal#3542L, shuffleProduceBytesWrittenTotal#3543L, shuffleProduceRecordsWrittenTotal#3544L, shuffleProduceWriteTimeTotal#3545L, peakExecutionMemory#3547L, peakExecutionMemoryCliqueDuration#3548L, peakExecutionMemoryCliqueSize#3549L]
Arguments: coalesced
(16) Sort [codegen id : 4]
Input [76]: [jobId#3556, stageCount#3474L, totalTaskCount#3475L, minTaskCountPerStage#3476L, maxTaskCountPerStage#3477L, medianTaskCountPerStage#3478L, bytesSpilledToDiskSerializedTotal#3479L, bytesSpilledToDiskSerializedMin#3480L, bytesSpilledToDiskSerializedMax#3481L, bytesSpilledToDiskSerializedMedian#3482L, taskCpuTimeTotal#3483L, taskCpuTimeMin#3484L, taskCpuTimeMax#3485L, taskCpuTimeMedian#3486L, taskDeserializeCpuTimeTotal#3487L, taskDeserializeCpuTimeMin#3488L, taskDeserializeCpuTimeMax#3489L, taskDeserializeCpuTimeMedian#3490L, taskDeserializeTimeTotal#3491L, taskDeserializeTimeMin#3492L, taskDeserializeTimeMax#3493L, taskDeserializeTimeMedian#3494L, taskRunTimeTotal#3495L, taskRunTimeMin#3496L, taskRunTimeMax#3497L, taskRunTimeMedian#3498L, jvmGcTimeTotal#3499L, jvmGcTimeMin#3500L, jvmGcTimeMax#3501L, jvmGcTimeMedian#3502L, bytesSpilledToDiskRawTotal#3503L, bytesSpilledToDiskRawMin#3504L, bytesSpilledToDiskRawMax#3505L, bytesSpilledToDiskRawMedian#3506L, resultSerializationTimeTotal#3507L, resultSerializationTimeMin#3508L, resultSerializationTimeMax#3509L, resultSerializationTimeMedian#3510L, resultSizeToDriverTotal#3511L, resultSizeToDriverMin#3512L, resultSizeToDriverMax#3513L, resultSizeToDriverMedian#3514L, taskPeakExecutionMemoryMin#3515L, taskPeakExecutionMemoryMax#3516L, taskPeakExecutionMemoryMedian#3517L, persistencyBytesReadTotal#3518L, persistencyBytesReadMin#3519L, persistencyBytesReadMax#3520L, persistencyBytesReadMedian#3521L, persistencyRecordsReadTotal#3522L, persistencyRecordsReadMin#3523L, persistencyRecordsReadMax#3524L, persistencyRecordsReadMedian#3525L, persistencyBytesWrittenTotal#3526L, persistencyBytesWrittenMin#3527L, persistencyBytesWrittenMax#3528L, persistencyBytesWrittenMedian#3529L, persistencyRecordsWrittenTotal#3530L, persistencyRecordsWrittenMin#3531L, persistencyRecordsWrittenMax#3532L, persistencyRecordsWrittenMedian#3533L, shuffleConsumeRecordsReadTotal#3534L, shuffleConsumeRemoteBlocksFetchedTotal#3535L, shuffleConsumeLocalBlocksFetchedTotal#3536L, shuffleConsumeTotalBlocksFetchedTotal#3537L, shuffleConsumeRemoteBytesReadTotal#3538L, shuffleConsumeLocalBytesReadTotal#3539L, shuffleConsumeTotalBytesReadTotal#3540L, shuffleConsumeRemoteBytesReadToDiskTotal#3541L, shuffleConsumeFetchWaitTimeTotal#3542L, shuffleProduceBytesWrittenTotal#3543L, shuffleProduceRecordsWrittenTotal#3544L, shuffleProduceWriteTimeTotal#3545L, peakExecutionMemory#3547L, peakExecutionMemoryCliqueDuration#3548L, peakExecutionMemoryCliqueSize#3549L]
Arguments: [jobId#3556 ASC NULLS FIRST], false, 0
(17) LocalTableScan
Output [6]: [jobId#3550, rddStorageDiskSizeTotal#3551L, rddStorageMemSizeTotal#3552L, rddNumCachedPartitionsTotal#3553, rddNumPartitionsTotal#3554, numberOfExecutors#3555]
Arguments: [jobId#3550, rddStorageDiskSizeTotal#3551L, rddStorageMemSizeTotal#3552L, rddNumCachedPartitionsTotal#3553, rddNumPartitionsTotal#3554, numberOfExecutors#3555]
(18) Exchange
Input [6]: [jobId#3550, rddStorageDiskSizeTotal#3551L, rddStorageMemSizeTotal#3552L, rddNumCachedPartitionsTotal#3553, rddNumPartitionsTotal#3554, numberOfExecutors#3555]
Arguments: hashpartitioning(jobId#3550, 200), ENSURE_REQUIREMENTS, [plan_id=4460]
(19) ShuffleQueryStage
Output [6]: [jobId#3550, rddStorageDiskSizeTotal#3551L, rddStorageMemSizeTotal#3552L, rddNumCachedPartitionsTotal#3553, rddNumPartitionsTotal#3554, numberOfExecutors#3555]
Arguments: 2
(20) AQEShuffleRead
Input [6]: [jobId#3550, rddStorageDiskSizeTotal#3551L, rddStorageMemSizeTotal#3552L, rddNumCachedPartitionsTotal#3553, rddNumPartitionsTotal#3554, numberOfExecutors#3555]
Arguments: coalesced
(21) Sort [codegen id : 5]
Input [6]: [jobId#3550, rddStorageDiskSizeTotal#3551L, rddStorageMemSizeTotal#3552L, rddNumCachedPartitionsTotal#3553, rddNumPartitionsTotal#3554, numberOfExecutors#3555]
Arguments: [jobId#3550 ASC NULLS FIRST], false, 0
(22) SortMergeJoin [codegen id : 6]
Left keys [1]: [jobId#3556]
Right keys [1]: [jobId#3550]
Join type: FullOuter
Join condition: None
(23) Project [codegen id : 6]
Output [92]: [coalesce(jobId#3556, jobId#3550) AS jobId#3557, stageCount#3474L, totalTaskCount#3475L, minTaskCountPerStage#3476L, maxTaskCountPerStage#3477L, medianTaskCountPerStage#3478L, bytesSpilledToDiskSerializedTotal#3479L, bytesSpilledToDiskSerializedMin#3480L, bytesSpilledToDiskSerializedMax#3481L, bytesSpilledToDiskSerializedMedian#3482L, taskCpuTimeTotal#3483L, taskCpuTimeMin#3484L, taskCpuTimeMax#3485L, taskCpuTimeMedian#3486L, taskDeserializeCpuTimeTotal#3487L, taskDeserializeCpuTimeMin#3488L, taskDeserializeCpuTimeMax#3489L, taskDeserializeCpuTimeMedian#3490L, taskDeserializeTimeTotal#3491L, taskDeserializeTimeMin#3492L, taskDeserializeTimeMax#3493L, taskDeserializeTimeMedian#3494L, taskRunTimeTotal#3495L, taskRunTimeMin#3496L, taskRunTimeMax#3497L, taskRunTimeMedian#3498L, jvmGcTimeTotal#3499L, jvmGcTimeMin#3500L, jvmGcTimeMax#3501L, jvmGcTimeMedian#3502L, bytesSpilledToDiskRawTotal#3503L, bytesSpilledToDiskRawMin#3504L, bytesSpilledToDiskRawMax#3505L, bytesSpilledToDiskRawMedian#3506L, resultSerializationTimeTotal#3507L, resultSerializationTimeMin#3508L, resultSerializationTimeMax#3509L, resultSerializationTimeMedian#3510L, resultSizeToDriverTotal#3511L, resultSizeToDriverMin#3512L, resultSizeToDriverMax#3513L, resultSizeToDriverMedian#3514L, taskPeakExecutionMemoryMin#3515L, taskPeakExecutionMemoryMax#3516L, taskPeakExecutionMemoryMedian#3517L, persistencyBytesReadTotal#3518L, persistencyBytesReadMin#3519L, persistencyBytesReadMax#3520L, persistencyBytesReadMedian#3521L, persistencyRecordsReadTotal#3522L, persistencyRecordsReadMin#3523L, persistencyRecordsReadMax#3524L, persistencyRecordsReadMedian#3525L, persistencyBytesWrittenTotal#3526L, persistencyBytesWrittenMin#3527L, persistencyBytesWrittenMax#3528L, persistencyBytesWrittenMedian#3529L, persistencyRecordsWrittenTotal#3530L, persistencyRecordsWrittenMin#3531L, persistencyRecordsWrittenMax#3532L, persistencyRecordsWrittenMedian#3533L, shuffleConsumeRecordsReadTotal#3534L, shuffleConsumeRemoteBlocksFetchedTotal#3535L, shuffleConsumeLocalBlocksFetchedTotal#3536L, shuffleConsumeTotalBlocksFetchedTotal#3537L, shuffleConsumeRemoteBytesReadTotal#3538L, shuffleConsumeLocalBytesReadTotal#3539L, shuffleConsumeTotalBytesReadTotal#3540L, shuffleConsumeRemoteBytesReadToDiskTotal#3541L, shuffleConsumeFetchWaitTimeTotal#3542L, shuffleProduceBytesWrittenTotal#3543L, shuffleProduceRecordsWrittenTotal#3544L, shuffleProduceWriteTimeTotal#3545L, peakExecutionMemory#3547L, peakExecutionMemoryCliqueDuration#3548L, peakExecutionMemoryCliqueSize#3549L, rddStorageDiskSizeTotal#3551L, rddStorageMemSizeTotal#3552L, rddNumCachedPartitionsTotal#3553, rddNumPartitionsTotal#3554, numberOfExecutors#3555, 10000000003 AS replenishmentRunId#3558L, 5330363489248697092 AS tenantId#3559, 8495 AS cornerstoneTenantId#3560L, MU_PPP_1 AS marketUnit#3561, STANDARD AS scenario#3562, 88c42b3e-f7b7-3812-8b16-7aa86f5ce414 AS activityId#3563, DetermineWorkLoad AS activityType#3564, ReplenishmentRunWorkflow AS workflowType#3565, RP_SCH_5330363489248697092_5 AS workflowId#3566, 4 AS activityAttempt#3567, unknown GIT COMMIT AS gitCommitId#3569]
Input [82]: [jobId#3556, stageCount#3474L, totalTaskCount#3475L, minTaskCountPerStage#3476L, maxTaskCountPerStage#3477L, medianTaskCountPerStage#3478L, bytesSpilledToDiskSerializedTotal#3479L, bytesSpilledToDiskSerializedMin#3480L, bytesSpilledToDiskSerializedMax#3481L, bytesSpilledToDiskSerializedMedian#3482L, taskCpuTimeTotal#3483L, taskCpuTimeMin#3484L, taskCpuTimeMax#3485L, taskCpuTimeMedian#3486L, taskDeserializeCpuTimeTotal#3487L, taskDeserializeCpuTimeMin#3488L, taskDeserializeCpuTimeMax#3489L, taskDeserializeCpuTimeMedian#3490L, taskDeserializeTimeTotal#3491L, taskDeserializeTimeMin#3492L, taskDeserializeTimeMax#3493L, taskDeserializeTimeMedian#3494L, taskRunTimeTotal#3495L, taskRunTimeMin#3496L, taskRunTimeMax#3497L, taskRunTimeMedian#3498L, jvmGcTimeTotal#3499L, jvmGcTimeMin#3500L, jvmGcTimeMax#3501L, jvmGcTimeMedian#3502L, bytesSpilledToDiskRawTotal#3503L, bytesSpilledToDiskRawMin#3504L, bytesSpilledToDiskRawMax#3505L, bytesSpilledToDiskRawMedian#3506L, resultSerializationTimeTotal#3507L, resultSerializationTimeMin#3508L, resultSerializationTimeMax#3509L, resultSerializationTimeMedian#3510L, resultSizeToDriverTotal#3511L, resultSizeToDriverMin#3512L, resultSizeToDriverMax#3513L, resultSizeToDriverMedian#3514L, taskPeakExecutionMemoryMin#3515L, taskPeakExecutionMemoryMax#3516L, taskPeakExecutionMemoryMedian#3517L, persistencyBytesReadTotal#3518L, persistencyBytesReadMin#3519L, persistencyBytesReadMax#3520L, persistencyBytesReadMedian#3521L, persistencyRecordsReadTotal#3522L, persistencyRecordsReadMin#3523L, persistencyRecordsReadMax#3524L, persistencyRecordsReadMedian#3525L, persistencyBytesWrittenTotal#3526L, persistencyBytesWrittenMin#3527L, persistencyBytesWrittenMax#3528L, persistencyBytesWrittenMedian#3529L, persistencyRecordsWrittenTotal#3530L, persistencyRecordsWrittenMin#3531L, persistencyRecordsWrittenMax#3532L, persistencyRecordsWrittenMedian#3533L, shuffleConsumeRecordsReadTotal#3534L, shuffleConsumeRemoteBlocksFetchedTotal#3535L, shuffleConsumeLocalBlocksFetchedTotal#3536L, shuffleConsumeTotalBlocksFetchedTotal#3537L, shuffleConsumeRemoteBytesReadTotal#3538L, shuffleConsumeLocalBytesReadTotal#3539L, shuffleConsumeTotalBytesReadTotal#3540L, shuffleConsumeRemoteBytesReadToDiskTotal#3541L, shuffleConsumeFetchWaitTimeTotal#3542L, shuffleProduceBytesWrittenTotal#3543L, shuffleProduceRecordsWrittenTotal#3544L, shuffleProduceWriteTimeTotal#3545L, peakExecutionMemory#3547L, peakExecutionMemoryCliqueDuration#3548L, peakExecutionMemoryCliqueSize#3549L, jobId#3550, rddStorageDiskSizeTotal#3551L, rddStorageMemSizeTotal#3552L, rddNumCachedPartitionsTotal#3553, rddNumPartitionsTotal#3554, numberOfExecutors#3555]
(24) Sort [codegen id : 6]
Input [92]: [jobId#3557, stageCount#3474L, totalTaskCount#3475L, minTaskCountPerStage#3476L, maxTaskCountPerStage#3477L, medianTaskCountPerStage#3478L, bytesSpilledToDiskSerializedTotal#3479L, bytesSpilledToDiskSerializedMin#3480L, bytesSpilledToDiskSerializedMax#3481L, bytesSpilledToDiskSerializedMedian#3482L, taskCpuTimeTotal#3483L, taskCpuTimeMin#3484L, taskCpuTimeMax#3485L, taskCpuTimeMedian#3486L, taskDeserializeCpuTimeTotal#3487L, taskDeserializeCpuTimeMin#3488L, taskDeserializeCpuTimeMax#3489L, taskDeserializeCpuTimeMedian#3490L, taskDeserializeTimeTotal#3491L, taskDeserializeTimeMin#3492L, taskDeserializeTimeMax#3493L, taskDeserializeTimeMedian#3494L, taskRunTimeTotal#3495L, taskRunTimeMin#3496L, taskRunTimeMax#3497L, taskRunTimeMedian#3498L, jvmGcTimeTotal#3499L, jvmGcTimeMin#3500L, jvmGcTimeMax#3501L, jvmGcTimeMedian#3502L, bytesSpilledToDiskRawTotal#3503L, bytesSpilledToDiskRawMin#3504L, bytesSpilledToDiskRawMax#3505L, bytesSpilledToDiskRawMedian#3506L, resultSerializationTimeTotal#3507L, resultSerializationTimeMin#3508L, resultSerializationTimeMax#3509L, resultSerializationTimeMedian#3510L, resultSizeToDriverTotal#3511L, resultSizeToDriverMin#3512L, resultSizeToDriverMax#3513L, resultSizeToDriverMedian#3514L, taskPeakExecutionMemoryMin#3515L, taskPeakExecutionMemoryMax#3516L, taskPeakExecutionMemoryMedian#3517L, persistencyBytesReadTotal#3518L, persistencyBytesReadMin#3519L, persistencyBytesReadMax#3520L, persistencyBytesReadMedian#3521L, persistencyRecordsReadTotal#3522L, persistencyRecordsReadMin#3523L, persistencyRecordsReadMax#3524L, persistencyRecordsReadMedian#3525L, persistencyBytesWrittenTotal#3526L, persistencyBytesWrittenMin#3527L, persistencyBytesWrittenMax#3528L, persistencyBytesWrittenMedian#3529L, persistencyRecordsWrittenTotal#3530L, persistencyRecordsWrittenMin#3531L, persistencyRecordsWrittenMax#3532L, persistencyRecordsWrittenMedian#3533L, shuffleConsumeRecordsReadTotal#3534L, shuffleConsumeRemoteBlocksFetchedTotal#3535L, shuffleConsumeLocalBlocksFetchedTotal#3536L, shuffleConsumeTotalBlocksFetchedTotal#3537L, shuffleConsumeRemoteBytesReadTotal#3538L, shuffleConsumeLocalBytesReadTotal#3539L, shuffleConsumeTotalBytesReadTotal#3540L, shuffleConsumeRemoteBytesReadToDiskTotal#3541L, shuffleConsumeFetchWaitTimeTotal#3542L, shuffleProduceBytesWrittenTotal#3543L, shuffleProduceRecordsWrittenTotal#3544L, shuffleProduceWriteTimeTotal#3545L, peakExecutionMemory#3547L, peakExecutionMemoryCliqueDuration#3548L, peakExecutionMemoryCliqueSize#3549L, rddStorageDiskSizeTotal#3551L, rddStorageMemSizeTotal#3552L, rddNumCachedPartitionsTotal#3553, rddNumPartitionsTotal#3554, numberOfExecutors#3555, replenishmentRunId#3558L, tenantId#3559, cornerstoneTenantId#3560L, marketUnit#3561, scenario#3562, activityId#3563, activityType#3564, workflowType#3565, workflowId#3566, activityAttempt#3567, gitCommitId#3569]
Arguments: [activityType#3564 ASC NULLS FIRST], false, 0
(25) WriteFiles
Input [92]: [jobId#3557, stageCount#3474L, totalTaskCount#3475L, minTaskCountPerStage#3476L, maxTaskCountPerStage#3477L, medianTaskCountPerStage#3478L, bytesSpilledToDiskSerializedTotal#3479L, bytesSpilledToDiskSerializedMin#3480L, bytesSpilledToDiskSerializedMax#3481L, bytesSpilledToDiskSerializedMedian#3482L, taskCpuTimeTotal#3483L, taskCpuTimeMin#3484L, taskCpuTimeMax#3485L, taskCpuTimeMedian#3486L, taskDeserializeCpuTimeTotal#3487L, taskDeserializeCpuTimeMin#3488L, taskDeserializeCpuTimeMax#3489L, taskDeserializeCpuTimeMedian#3490L, taskDeserializeTimeTotal#3491L, taskDeserializeTimeMin#3492L, taskDeserializeTimeMax#3493L, taskDeserializeTimeMedian#3494L, taskRunTimeTotal#3495L, taskRunTimeMin#3496L, taskRunTimeMax#3497L, taskRunTimeMedian#3498L, jvmGcTimeTotal#3499L, jvmGcTimeMin#3500L, jvmGcTimeMax#3501L, jvmGcTimeMedian#3502L, bytesSpilledToDiskRawTotal#3503L, bytesSpilledToDiskRawMin#3504L, bytesSpilledToDiskRawMax#3505L, bytesSpilledToDiskRawMedian#3506L, resultSerializationTimeTotal#3507L, resultSerializationTimeMin#3508L, resultSerializationTimeMax#3509L, resultSerializationTimeMedian#3510L, resultSizeToDriverTotal#3511L, resultSizeToDriverMin#3512L, resultSizeToDriverMax#3513L, resultSizeToDriverMedian#3514L, taskPeakExecutionMemoryMin#3515L, taskPeakExecutionMemoryMax#3516L, taskPeakExecutionMemoryMedian#3517L, persistencyBytesReadTotal#3518L, persistencyBytesReadMin#3519L, persistencyBytesReadMax#3520L, persistencyBytesReadMedian#3521L, persistencyRecordsReadTotal#3522L, persistencyRecordsReadMin#3523L, persistencyRecordsReadMax#3524L, persistencyRecordsReadMedian#3525L, persistencyBytesWrittenTotal#3526L, persistencyBytesWrittenMin#3527L, persistencyBytesWrittenMax#3528L, persistencyBytesWrittenMedian#3529L, persistencyRecordsWrittenTotal#3530L, persistencyRecordsWrittenMin#3531L, persistencyRecordsWrittenMax#3532L, persistencyRecordsWrittenMedian#3533L, shuffleConsumeRecordsReadTotal#3534L, shuffleConsumeRemoteBlocksFetchedTotal#3535L, shuffleConsumeLocalBlocksFetchedTotal#3536L, shuffleConsumeTotalBlocksFetchedTotal#3537L, shuffleConsumeRemoteBytesReadTotal#3538L, shuffleConsumeLocalBytesReadTotal#3539L, shuffleConsumeTotalBytesReadTotal#3540L, shuffleConsumeRemoteBytesReadToDiskTotal#3541L, shuffleConsumeFetchWaitTimeTotal#3542L, shuffleProduceBytesWrittenTotal#3543L, shuffleProduceRecordsWrittenTotal#3544L, shuffleProduceWriteTimeTotal#3545L, peakExecutionMemory#3547L, peakExecutionMemoryCliqueDuration#3548L, peakExecutionMemoryCliqueSize#3549L, rddStorageDiskSizeTotal#3551L, rddStorageMemSizeTotal#3552L, rddNumCachedPartitionsTotal#3553, rddNumPartitionsTotal#3554, numberOfExecutors#3555, replenishmentRunId#3558L, tenantId#3559, cornerstoneTenantId#3560L, marketUnit#3561, scenario#3562, activityId#3563, activityType#3564, workflowType#3565, workflowId#3566, activityAttempt#3567, gitCommitId#3569]
(26) Execute InsertIntoHadoopFsRelationCommand
Input: []
Arguments: hdlfs://065c2b6f-41bb-4a20-b7a2-eb965f9cb071.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-workload-determination-service/in/performance-metrics/10000000003, false, [activityType#3564], Parquet, [__partition_columns=["activityType"], path=hdlfs://065c2b6f-41bb-4a20-b7a2-eb965f9cb071.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-workload-determination-service/in/performance-metrics/10000000003/], Append, [jobId, stageCount, totalTaskCount, minTaskCountPerStage, maxTaskCountPerStage, medianTaskCountPerStage, bytesSpilledToDiskSerializedTotal, bytesSpilledToDiskSerializedMin, bytesSpilledToDiskSerializedMax, bytesSpilledToDiskSerializedMedian, taskCpuTimeTotal, taskCpuTimeMin, taskCpuTimeMax, taskCpuTimeMedian, taskDeserializeCpuTimeTotal, taskDeserializeCpuTimeMin, taskDeserializeCpuTimeMax, taskDeserializeCpuTimeMedian, taskDeserializeTimeTotal, taskDeserializeTimeMin, taskDeserializeTimeMax, taskDeserializeTimeMedian, taskRunTimeTotal, taskRunTimeMin, taskRunTimeMax, ... 67 more fields]
(27) ResultQueryStage
Output: []
Arguments: 4
(28) Sort
Input [73]: [jobId#3473, stageCount#3474L, totalTaskCount#3475L, minTaskCountPerStage#3476L, maxTaskCountPerStage#3477L, medianTaskCountPerStage#3478L, bytesSpilledToDiskSerializedTotal#3479L, bytesSpilledToDiskSerializedMin#3480L, bytesSpilledToDiskSerializedMax#3481L, bytesSpilledToDiskSerializedMedian#3482L, taskCpuTimeTotal#3483L, taskCpuTimeMin#3484L, taskCpuTimeMax#3485L, taskCpuTimeMedian#3486L, taskDeserializeCpuTimeTotal#3487L, taskDeserializeCpuTimeMin#3488L, taskDeserializeCpuTimeMax#3489L, taskDeserializeCpuTimeMedian#3490L, taskDeserializeTimeTotal#3491L, taskDeserializeTimeMin#3492L, taskDeserializeTimeMax#3493L, taskDeserializeTimeMedian#3494L, taskRunTimeTotal#3495L, taskRunTimeMin#3496L, taskRunTimeMax#3497L, taskRunTimeMedian#3498L, jvmGcTimeTotal#3499L, jvmGcTimeMin#3500L, jvmGcTimeMax#3501L, jvmGcTimeMedian#3502L, bytesSpilledToDiskRawTotal#3503L, bytesSpilledToDiskRawMin#3504L, bytesSpilledToDiskRawMax#3505L, bytesSpilledToDiskRawMedian#3506L, resultSerializationTimeTotal#3507L, resultSerializationTimeMin#3508L, resultSerializationTimeMax#3509L, resultSerializationTimeMedian#3510L, resultSizeToDriverTotal#3511L, resultSizeToDriverMin#3512L, resultSizeToDriverMax#3513L, resultSizeToDriverMedian#3514L, taskPeakExecutionMemoryMin#3515L, taskPeakExecutionMemoryMax#3516L, taskPeakExecutionMemoryMedian#3517L, persistencyBytesReadTotal#3518L, persistencyBytesReadMin#3519L, persistencyBytesReadMax#3520L, persistencyBytesReadMedian#3521L, persistencyRecordsReadTotal#3522L, persistencyRecordsReadMin#3523L, persistencyRecordsReadMax#3524L, persistencyRecordsReadMedian#3525L, persistencyBytesWrittenTotal#3526L, persistencyBytesWrittenMin#3527L, persistencyBytesWrittenMax#3528L, persistencyBytesWrittenMedian#3529L, persistencyRecordsWrittenTotal#3530L, persistencyRecordsWrittenMin#3531L, persistencyRecordsWrittenMax#3532L, persistencyRecordsWrittenMedian#3533L, shuffleConsumeRecordsReadTotal#3534L, shuffleConsumeRemoteBlocksFetchedTotal#3535L, shuffleConsumeLocalBlocksFetchedTotal#3536L, shuffleConsumeTotalBlocksFetchedTotal#3537L, shuffleConsumeRemoteBytesReadTotal#3538L, shuffleConsumeLocalBytesReadTotal#3539L, shuffleConsumeTotalBytesReadTotal#3540L, shuffleConsumeRemoteBytesReadToDiskTotal#3541L, shuffleConsumeFetchWaitTimeTotal#3542L, shuffleProduceBytesWrittenTotal#3543L, shuffleProduceRecordsWrittenTotal#3544L, shuffleProduceWriteTimeTotal#3545L]
Arguments: [jobId#3473 ASC NULLS FIRST], false, 0
(29) Sort
Input [4]: [jobId#3546, peakExecutionMemory#3547L, peakExecutionMemoryCliqueDuration#3548L, peakExecutionMemoryCliqueSize#3549L]
Arguments: [jobId#3546 ASC NULLS FIRST], false, 0
(30) SortMergeJoin
Left keys [1]: [jobId#3473]
Right keys [1]: [jobId#3546]
Join type: FullOuter
Join condition: None
(31) Project
Output [76]: [coalesce(jobId#3473, jobId#3546) AS jobId#3556, stageCount#3474L, totalTaskCount#3475L, minTaskCountPerStage#3476L, maxTaskCountPerStage#3477L, medianTaskCountPerStage#3478L, bytesSpilledToDiskSerializedTotal#3479L, bytesSpilledToDiskSerializedMin#3480L, bytesSpilledToDiskSerializedMax#3481L, bytesSpilledToDiskSerializedMedian#3482L, taskCpuTimeTotal#3483L, taskCpuTimeMin#3484L, taskCpuTimeMax#3485L, taskCpuTimeMedian#3486L, taskDeserializeCpuTimeTotal#3487L, taskDeserializeCpuTimeMin#3488L, taskDeserializeCpuTimeMax#3489L, taskDeserializeCpuTimeMedian#3490L, taskDeserializeTimeTotal#3491L, taskDeserializeTimeMin#3492L, taskDeserializeTimeMax#3493L, taskDeserializeTimeMedian#3494L, taskRunTimeTotal#3495L, taskRunTimeMin#3496L, taskRunTimeMax#3497L, taskRunTimeMedian#3498L, jvmGcTimeTotal#3499L, jvmGcTimeMin#3500L, jvmGcTimeMax#3501L, jvmGcTimeMedian#3502L, bytesSpilledToDiskRawTotal#3503L, bytesSpilledToDiskRawMin#3504L, bytesSpilledToDiskRawMax#3505L, bytesSpilledToDiskRawMedian#3506L, resultSerializationTimeTotal#3507L, resultSerializationTimeMin#3508L, resultSerializationTimeMax#3509L, resultSerializationTimeMedian#3510L, resultSizeToDriverTotal#3511L, resultSizeToDriverMin#3512L, resultSizeToDriverMax#3513L, resultSizeToDriverMedian#3514L, taskPeakExecutionMemoryMin#3515L, taskPeakExecutionMemoryMax#3516L, taskPeakExecutionMemoryMedian#3517L, persistencyBytesReadTotal#3518L, persistencyBytesReadMin#3519L, persistencyBytesReadMax#3520L, persistencyBytesReadMedian#3521L, persistencyRecordsReadTotal#3522L, persistencyRecordsReadMin#3523L, persistencyRecordsReadMax#3524L, persistencyRecordsReadMedian#3525L, persistencyBytesWrittenTotal#3526L, persistencyBytesWrittenMin#3527L, persistencyBytesWrittenMax#3528L, persistencyBytesWrittenMedian#3529L, persistencyRecordsWrittenTotal#3530L, persistencyRecordsWrittenMin#3531L, persistencyRecordsWrittenMax#3532L, persistencyRecordsWrittenMedian#3533L, shuffleConsumeRecordsReadTotal#3534L, shuffleConsumeRemoteBlocksFetchedTotal#3535L, shuffleConsumeLocalBlocksFetchedTotal#3536L, shuffleConsumeTotalBlocksFetchedTotal#3537L, shuffleConsumeRemoteBytesReadTotal#3538L, shuffleConsumeLocalBytesReadTotal#3539L, shuffleConsumeTotalBytesReadTotal#3540L, shuffleConsumeRemoteBytesReadToDiskTotal#3541L, shuffleConsumeFetchWaitTimeTotal#3542L, shuffleProduceBytesWrittenTotal#3543L, shuffleProduceRecordsWrittenTotal#3544L, shuffleProduceWriteTimeTotal#3545L, peakExecutionMemory#3547L, peakExecutionMemoryCliqueDuration#3548L, peakExecutionMemoryCliqueSize#3549L]
Input [77]: [jobId#3473, stageCount#3474L, totalTaskCount#3475L, minTaskCountPerStage#3476L, maxTaskCountPerStage#3477L, medianTaskCountPerStage#3478L, bytesSpilledToDiskSerializedTotal#3479L, bytesSpilledToDiskSerializedMin#3480L, bytesSpilledToDiskSerializedMax#3481L, bytesSpilledToDiskSerializedMedian#3482L, taskCpuTimeTotal#3483L, taskCpuTimeMin#3484L, taskCpuTimeMax#3485L, taskCpuTimeMedian#3486L, taskDeserializeCpuTimeTotal#3487L, taskDeserializeCpuTimeMin#3488L, taskDeserializeCpuTimeMax#3489L, taskDeserializeCpuTimeMedian#3490L, taskDeserializeTimeTotal#3491L, taskDeserializeTimeMin#3492L, taskDeserializeTimeMax#3493L, taskDeserializeTimeMedian#3494L, taskRunTimeTotal#3495L, taskRunTimeMin#3496L, taskRunTimeMax#3497L, taskRunTimeMedian#3498L, jvmGcTimeTotal#3499L, jvmGcTimeMin#3500L, jvmGcTimeMax#3501L, jvmGcTimeMedian#3502L, bytesSpilledToDiskRawTotal#3503L, bytesSpilledToDiskRawMin#3504L, bytesSpilledToDiskRawMax#3505L, bytesSpilledToDiskRawMedian#3506L, resultSerializationTimeTotal#3507L, resultSerializationTimeMin#3508L, resultSerializationTimeMax#3509L, resultSerializationTimeMedian#3510L, resultSizeToDriverTotal#3511L, resultSizeToDriverMin#3512L, resultSizeToDriverMax#3513L, resultSizeToDriverMedian#3514L, taskPeakExecutionMemoryMin#3515L, taskPeakExecutionMemoryMax#3516L, taskPeakExecutionMemoryMedian#3517L, persistencyBytesReadTotal#3518L, persistencyBytesReadMin#3519L, persistencyBytesReadMax#3520L, persistencyBytesReadMedian#3521L, persistencyRecordsReadTotal#3522L, persistencyRecordsReadMin#3523L, persistencyRecordsReadMax#3524L, persistencyRecordsReadMedian#3525L, persistencyBytesWrittenTotal#3526L, persistencyBytesWrittenMin#3527L, persistencyBytesWrittenMax#3528L, persistencyBytesWrittenMedian#3529L, persistencyRecordsWrittenTotal#3530L, persistencyRecordsWrittenMin#3531L, persistencyRecordsWrittenMax#3532L, persistencyRecordsWrittenMedian#3533L, shuffleConsumeRecordsReadTotal#3534L, shuffleConsumeRemoteBlocksFetchedTotal#3535L, shuffleConsumeLocalBlocksFetchedTotal#3536L, shuffleConsumeTotalBlocksFetchedTotal#3537L, shuffleConsumeRemoteBytesReadTotal#3538L, shuffleConsumeLocalBytesReadTotal#3539L, shuffleConsumeTotalBytesReadTotal#3540L, shuffleConsumeRemoteBytesReadToDiskTotal#3541L, shuffleConsumeFetchWaitTimeTotal#3542L, shuffleProduceBytesWrittenTotal#3543L, shuffleProduceRecordsWrittenTotal#3544L, shuffleProduceWriteTimeTotal#3545L, jobId#3546, peakExecutionMemory#3547L, peakExecutionMemoryCliqueDuration#3548L, peakExecutionMemoryCliqueSize#3549L]
(32) Exchange
Input [76]: [jobId#3556, stageCount#3474L, totalTaskCount#3475L, minTaskCountPerStage#3476L, maxTaskCountPerStage#3477L, medianTaskCountPerStage#3478L, bytesSpilledToDiskSerializedTotal#3479L, bytesSpilledToDiskSerializedMin#3480L, bytesSpilledToDiskSerializedMax#3481L, bytesSpilledToDiskSerializedMedian#3482L, taskCpuTimeTotal#3483L, taskCpuTimeMin#3484L, taskCpuTimeMax#3485L, taskCpuTimeMedian#3486L, taskDeserializeCpuTimeTotal#3487L, taskDeserializeCpuTimeMin#3488L, taskDeserializeCpuTimeMax#3489L, taskDeserializeCpuTimeMedian#3490L, taskDeserializeTimeTotal#3491L, taskDeserializeTimeMin#3492L, taskDeserializeTimeMax#3493L, taskDeserializeTimeMedian#3494L, taskRunTimeTotal#3495L, taskRunTimeMin#3496L, taskRunTimeMax#3497L, taskRunTimeMedian#3498L, jvmGcTimeTotal#3499L, jvmGcTimeMin#3500L, jvmGcTimeMax#3501L, jvmGcTimeMedian#3502L, bytesSpilledToDiskRawTotal#3503L, bytesSpilledToDiskRawMin#3504L, bytesSpilledToDiskRawMax#3505L, bytesSpilledToDiskRawMedian#3506L, resultSerializationTimeTotal#3507L, resultSerializationTimeMin#3508L, resultSerializationTimeMax#3509L, resultSerializationTimeMedian#3510L, resultSizeToDriverTotal#3511L, resultSizeToDriverMin#3512L, resultSizeToDriverMax#3513L, resultSizeToDriverMedian#3514L, taskPeakExecutionMemoryMin#3515L, taskPeakExecutionMemoryMax#3516L, taskPeakExecutionMemoryMedian#3517L, persistencyBytesReadTotal#3518L, persistencyBytesReadMin#3519L, persistencyBytesReadMax#3520L, persistencyBytesReadMedian#3521L, persistencyRecordsReadTotal#3522L, persistencyRecordsReadMin#3523L, persistencyRecordsReadMax#3524L, persistencyRecordsReadMedian#3525L, persistencyBytesWrittenTotal#3526L, persistencyBytesWrittenMin#3527L, persistencyBytesWrittenMax#3528L, persistencyBytesWrittenMedian#3529L, persistencyRecordsWrittenTotal#3530L, persistencyRecordsWrittenMin#3531L, persistencyRecordsWrittenMax#3532L, persistencyRecordsWrittenMedian#3533L, shuffleConsumeRecordsReadTotal#3534L, shuffleConsumeRemoteBlocksFetchedTotal#3535L, shuffleConsumeLocalBlocksFetchedTotal#3536L, shuffleConsumeTotalBlocksFetchedTotal#3537L, shuffleConsumeRemoteBytesReadTotal#3538L, shuffleConsumeLocalBytesReadTotal#3539L, shuffleConsumeTotalBytesReadTotal#3540L, shuffleConsumeRemoteBytesReadToDiskTotal#3541L, shuffleConsumeFetchWaitTimeTotal#3542L, shuffleProduceBytesWrittenTotal#3543L, shuffleProduceRecordsWrittenTotal#3544L, shuffleProduceWriteTimeTotal#3545L, peakExecutionMemory#3547L, peakExecutionMemoryCliqueDuration#3548L, peakExecutionMemoryCliqueSize#3549L]
Arguments: hashpartitioning(jobId#3556, 200), ENSURE_REQUIREMENTS, [plan_id=4459]
(33) Sort
Input [76]: [jobId#3556, stageCount#3474L, totalTaskCount#3475L, minTaskCountPerStage#3476L, maxTaskCountPerStage#3477L, medianTaskCountPerStage#3478L, bytesSpilledToDiskSerializedTotal#3479L, bytesSpilledToDiskSerializedMin#3480L, bytesSpilledToDiskSerializedMax#3481L, bytesSpilledToDiskSerializedMedian#3482L, taskCpuTimeTotal#3483L, taskCpuTimeMin#3484L, taskCpuTimeMax#3485L, taskCpuTimeMedian#3486L, taskDeserializeCpuTimeTotal#3487L, taskDeserializeCpuTimeMin#3488L, taskDeserializeCpuTimeMax#3489L, taskDeserializeCpuTimeMedian#3490L, taskDeserializeTimeTotal#3491L, taskDeserializeTimeMin#3492L, taskDeserializeTimeMax#3493L, taskDeserializeTimeMedian#3494L, taskRunTimeTotal#3495L, taskRunTimeMin#3496L, taskRunTimeMax#3497L, taskRunTimeMedian#3498L, jvmGcTimeTotal#3499L, jvmGcTimeMin#3500L, jvmGcTimeMax#3501L, jvmGcTimeMedian#3502L, bytesSpilledToDiskRawTotal#3503L, bytesSpilledToDiskRawMin#3504L, bytesSpilledToDiskRawMax#3505L, bytesSpilledToDiskRawMedian#3506L, resultSerializationTimeTotal#3507L, resultSerializationTimeMin#3508L, resultSerializationTimeMax#3509L, resultSerializationTimeMedian#3510L, resultSizeToDriverTotal#3511L, resultSizeToDriverMin#3512L, resultSizeToDriverMax#3513L, resultSizeToDriverMedian#3514L, taskPeakExecutionMemoryMin#3515L, taskPeakExecutionMemoryMax#3516L, taskPeakExecutionMemoryMedian#3517L, persistencyBytesReadTotal#3518L, persistencyBytesReadMin#3519L, persistencyBytesReadMax#3520L, persistencyBytesReadMedian#3521L, persistencyRecordsReadTotal#3522L, persistencyRecordsReadMin#3523L, persistencyRecordsReadMax#3524L, persistencyRecordsReadMedian#3525L, persistencyBytesWrittenTotal#3526L, persistencyBytesWrittenMin#3527L, persistencyBytesWrittenMax#3528L, persistencyBytesWrittenMedian#3529L, persistencyRecordsWrittenTotal#3530L, persistencyRecordsWrittenMin#3531L, persistencyRecordsWrittenMax#3532L, persistencyRecordsWrittenMedian#3533L, shuffleConsumeRecordsReadTotal#3534L, shuffleConsumeRemoteBlocksFetchedTotal#3535L, shuffleConsumeLocalBlocksFetchedTotal#3536L, shuffleConsumeTotalBlocksFetchedTotal#3537L, shuffleConsumeRemoteBytesReadTotal#3538L, shuffleConsumeLocalBytesReadTotal#3539L, shuffleConsumeTotalBytesReadTotal#3540L, shuffleConsumeRemoteBytesReadToDiskTotal#3541L, shuffleConsumeFetchWaitTimeTotal#3542L, shuffleProduceBytesWrittenTotal#3543L, shuffleProduceRecordsWrittenTotal#3544L, shuffleProduceWriteTimeTotal#3545L, peakExecutionMemory#3547L, peakExecutionMemoryCliqueDuration#3548L, peakExecutionMemoryCliqueSize#3549L]
Arguments: [jobId#3556 ASC NULLS FIRST], false, 0
(34) Sort
Input [6]: [jobId#3550, rddStorageDiskSizeTotal#3551L, rddStorageMemSizeTotal#3552L, rddNumCachedPartitionsTotal#3553, rddNumPartitionsTotal#3554, numberOfExecutors#3555]
Arguments: [jobId#3550 ASC NULLS FIRST], false, 0
(35) SortMergeJoin
Left keys [1]: [jobId#3556]
Right keys [1]: [jobId#3550]
Join type: FullOuter
Join condition: None
(36) Project
Output [92]: [coalesce(jobId#3556, jobId#3550) AS jobId#3557, stageCount#3474L, totalTaskCount#3475L, minTaskCountPerStage#3476L, maxTaskCountPerStage#3477L, medianTaskCountPerStage#3478L, bytesSpilledToDiskSerializedTotal#3479L, bytesSpilledToDiskSerializedMin#3480L, bytesSpilledToDiskSerializedMax#3481L, bytesSpilledToDiskSerializedMedian#3482L, taskCpuTimeTotal#3483L, taskCpuTimeMin#3484L, taskCpuTimeMax#3485L, taskCpuTimeMedian#3486L, taskDeserializeCpuTimeTotal#3487L, taskDeserializeCpuTimeMin#3488L, taskDeserializeCpuTimeMax#3489L, taskDeserializeCpuTimeMedian#3490L, taskDeserializeTimeTotal#3491L, taskDeserializeTimeMin#3492L, taskDeserializeTimeMax#3493L, taskDeserializeTimeMedian#3494L, taskRunTimeTotal#3495L, taskRunTimeMin#3496L, taskRunTimeMax#3497L, taskRunTimeMedian#3498L, jvmGcTimeTotal#3499L, jvmGcTimeMin#3500L, jvmGcTimeMax#3501L, jvmGcTimeMedian#3502L, bytesSpilledToDiskRawTotal#3503L, bytesSpilledToDiskRawMin#3504L, bytesSpilledToDiskRawMax#3505L, bytesSpilledToDiskRawMedian#3506L, resultSerializationTimeTotal#3507L, resultSerializationTimeMin#3508L, resultSerializationTimeMax#3509L, resultSerializationTimeMedian#3510L, resultSizeToDriverTotal#3511L, resultSizeToDriverMin#3512L, resultSizeToDriverMax#3513L, resultSizeToDriverMedian#3514L, taskPeakExecutionMemoryMin#3515L, taskPeakExecutionMemoryMax#3516L, taskPeakExecutionMemoryMedian#3517L, persistencyBytesReadTotal#3518L, persistencyBytesReadMin#3519L, persistencyBytesReadMax#3520L, persistencyBytesReadMedian#3521L, persistencyRecordsReadTotal#3522L, persistencyRecordsReadMin#3523L, persistencyRecordsReadMax#3524L, persistencyRecordsReadMedian#3525L, persistencyBytesWrittenTotal#3526L, persistencyBytesWrittenMin#3527L, persistencyBytesWrittenMax#3528L, persistencyBytesWrittenMedian#3529L, persistencyRecordsWrittenTotal#3530L, persistencyRecordsWrittenMin#3531L, persistencyRecordsWrittenMax#3532L, persistencyRecordsWrittenMedian#3533L, shuffleConsumeRecordsReadTotal#3534L, shuffleConsumeRemoteBlocksFetchedTotal#3535L, shuffleConsumeLocalBlocksFetchedTotal#3536L, shuffleConsumeTotalBlocksFetchedTotal#3537L, shuffleConsumeRemoteBytesReadTotal#3538L, shuffleConsumeLocalBytesReadTotal#3539L, shuffleConsumeTotalBytesReadTotal#3540L, shuffleConsumeRemoteBytesReadToDiskTotal#3541L, shuffleConsumeFetchWaitTimeTotal#3542L, shuffleProduceBytesWrittenTotal#3543L, shuffleProduceRecordsWrittenTotal#3544L, shuffleProduceWriteTimeTotal#3545L, peakExecutionMemory#3547L, peakExecutionMemoryCliqueDuration#3548L, peakExecutionMemoryCliqueSize#3549L, rddStorageDiskSizeTotal#3551L, rddStorageMemSizeTotal#3552L, rddNumCachedPartitionsTotal#3553, rddNumPartitionsTotal#3554, numberOfExecutors#3555, 10000000003 AS replenishmentRunId#3558L, 5330363489248697092 AS tenantId#3559, 8495 AS cornerstoneTenantId#3560L, MU_PPP_1 AS marketUnit#3561, STANDARD AS scenario#3562, 88c42b3e-f7b7-3812-8b16-7aa86f5ce414 AS activityId#3563, DetermineWorkLoad AS activityType#3564, ReplenishmentRunWorkflow AS workflowType#3565, RP_SCH_5330363489248697092_5 AS workflowId#3566, 4 AS activityAttempt#3567, unknown GIT COMMIT AS gitCommitId#3569]
Input [82]: [jobId#3556, stageCount#3474L, totalTaskCount#3475L, minTaskCountPerStage#3476L, maxTaskCountPerStage#3477L, medianTaskCountPerStage#3478L, bytesSpilledToDiskSerializedTotal#3479L, bytesSpilledToDiskSerializedMin#3480L, bytesSpilledToDiskSerializedMax#3481L, bytesSpilledToDiskSerializedMedian#3482L, taskCpuTimeTotal#3483L, taskCpuTimeMin#3484L, taskCpuTimeMax#3485L, taskCpuTimeMedian#3486L, taskDeserializeCpuTimeTotal#3487L, taskDeserializeCpuTimeMin#3488L, taskDeserializeCpuTimeMax#3489L, taskDeserializeCpuTimeMedian#3490L, taskDeserializeTimeTotal#3491L, taskDeserializeTimeMin#3492L, taskDeserializeTimeMax#3493L, taskDeserializeTimeMedian#3494L, taskRunTimeTotal#3495L, taskRunTimeMin#3496L, taskRunTimeMax#3497L, taskRunTimeMedian#3498L, jvmGcTimeTotal#3499L, jvmGcTimeMin#3500L, jvmGcTimeMax#3501L, jvmGcTimeMedian#3502L, bytesSpilledToDiskRawTotal#3503L, bytesSpilledToDiskRawMin#3504L, bytesSpilledToDiskRawMax#3505L, bytesSpilledToDiskRawMedian#3506L, resultSerializationTimeTotal#3507L, resultSerializationTimeMin#3508L, resultSerializationTimeMax#3509L, resultSerializationTimeMedian#3510L, resultSizeToDriverTotal#3511L, resultSizeToDriverMin#3512L, resultSizeToDriverMax#3513L, resultSizeToDriverMedian#3514L, taskPeakExecutionMemoryMin#3515L, taskPeakExecutionMemoryMax#3516L, taskPeakExecutionMemoryMedian#3517L, persistencyBytesReadTotal#3518L, persistencyBytesReadMin#3519L, persistencyBytesReadMax#3520L, persistencyBytesReadMedian#3521L, persistencyRecordsReadTotal#3522L, persistencyRecordsReadMin#3523L, persistencyRecordsReadMax#3524L, persistencyRecordsReadMedian#3525L, persistencyBytesWrittenTotal#3526L, persistencyBytesWrittenMin#3527L, persistencyBytesWrittenMax#3528L, persistencyBytesWrittenMedian#3529L, persistencyRecordsWrittenTotal#3530L, persistencyRecordsWrittenMin#3531L, persistencyRecordsWrittenMax#3532L, persistencyRecordsWrittenMedian#3533L, shuffleConsumeRecordsReadTotal#3534L, shuffleConsumeRemoteBlocksFetchedTotal#3535L, shuffleConsumeLocalBlocksFetchedTotal#3536L, shuffleConsumeTotalBlocksFetchedTotal#3537L, shuffleConsumeRemoteBytesReadTotal#3538L, shuffleConsumeLocalBytesReadTotal#3539L, shuffleConsumeTotalBytesReadTotal#3540L, shuffleConsumeRemoteBytesReadToDiskTotal#3541L, shuffleConsumeFetchWaitTimeTotal#3542L, shuffleProduceBytesWrittenTotal#3543L, shuffleProduceRecordsWrittenTotal#3544L, shuffleProduceWriteTimeTotal#3545L, peakExecutionMemory#3547L, peakExecutionMemoryCliqueDuration#3548L, peakExecutionMemoryCliqueSize#3549L, jobId#3550, rddStorageDiskSizeTotal#3551L, rddStorageMemSizeTotal#3552L, rddNumCachedPartitionsTotal#3553, rddNumPartitionsTotal#3554, numberOfExecutors#3555]
(37) Sort
Input [92]: [jobId#3557, stageCount#3474L, totalTaskCount#3475L, minTaskCountPerStage#3476L, maxTaskCountPerStage#3477L, medianTaskCountPerStage#3478L, bytesSpilledToDiskSerializedTotal#3479L, bytesSpilledToDiskSerializedMin#3480L, bytesSpilledToDiskSerializedMax#3481L, bytesSpilledToDiskSerializedMedian#3482L, taskCpuTimeTotal#3483L, taskCpuTimeMin#3484L, taskCpuTimeMax#3485L, taskCpuTimeMedian#3486L, taskDeserializeCpuTimeTotal#3487L, taskDeserializeCpuTimeMin#3488L, taskDeserializeCpuTimeMax#3489L, taskDeserializeCpuTimeMedian#3490L, taskDeserializeTimeTotal#3491L, taskDeserializeTimeMin#3492L, taskDeserializeTimeMax#3493L, taskDeserializeTimeMedian#3494L, taskRunTimeTotal#3495L, taskRunTimeMin#3496L, taskRunTimeMax#3497L, taskRunTimeMedian#3498L, jvmGcTimeTotal#3499L, jvmGcTimeMin#3500L, jvmGcTimeMax#3501L, jvmGcTimeMedian#3502L, bytesSpilledToDiskRawTotal#3503L, bytesSpilledToDiskRawMin#3504L, bytesSpilledToDiskRawMax#3505L, bytesSpilledToDiskRawMedian#3506L, resultSerializationTimeTotal#3507L, resultSerializationTimeMin#3508L, resultSerializationTimeMax#3509L, resultSerializationTimeMedian#3510L, resultSizeToDriverTotal#3511L, resultSizeToDriverMin#3512L, resultSizeToDriverMax#3513L, resultSizeToDriverMedian#3514L, taskPeakExecutionMemoryMin#3515L, taskPeakExecutionMemoryMax#3516L, taskPeakExecutionMemoryMedian#3517L, persistencyBytesReadTotal#3518L, persistencyBytesReadMin#3519L, persistencyBytesReadMax#3520L, persistencyBytesReadMedian#3521L, persistencyRecordsReadTotal#3522L, persistencyRecordsReadMin#3523L, persistencyRecordsReadMax#3524L, persistencyRecordsReadMedian#3525L, persistencyBytesWrittenTotal#3526L, persistencyBytesWrittenMin#3527L, persistencyBytesWrittenMax#3528L, persistencyBytesWrittenMedian#3529L, persistencyRecordsWrittenTotal#3530L, persistencyRecordsWrittenMin#3531L, persistencyRecordsWrittenMax#3532L, persistencyRecordsWrittenMedian#3533L, shuffleConsumeRecordsReadTotal#3534L, shuffleConsumeRemoteBlocksFetchedTotal#3535L, shuffleConsumeLocalBlocksFetchedTotal#3536L, shuffleConsumeTotalBlocksFetchedTotal#3537L, shuffleConsumeRemoteBytesReadTotal#3538L, shuffleConsumeLocalBytesReadTotal#3539L, shuffleConsumeTotalBytesReadTotal#3540L, shuffleConsumeRemoteBytesReadToDiskTotal#3541L, shuffleConsumeFetchWaitTimeTotal#3542L, shuffleProduceBytesWrittenTotal#3543L, shuffleProduceRecordsWrittenTotal#3544L, shuffleProduceWriteTimeTotal#3545L, peakExecutionMemory#3547L, peakExecutionMemoryCliqueDuration#3548L, peakExecutionMemoryCliqueSize#3549L, rddStorageDiskSizeTotal#3551L, rddStorageMemSizeTotal#3552L, rddNumCachedPartitionsTotal#3553, rddNumPartitionsTotal#3554, numberOfExecutors#3555, replenishmentRunId#3558L, tenantId#3559, cornerstoneTenantId#3560L, marketUnit#3561, scenario#3562, activityId#3563, activityType#3564, workflowType#3565, workflowId#3566, activityAttempt#3567, gitCommitId#3569]
Arguments: [activityType#3564 ASC NULLS FIRST], false, 0
(38) WriteFiles
Input [92]: [jobId#3557, stageCount#3474L, totalTaskCount#3475L, minTaskCountPerStage#3476L, maxTaskCountPerStage#3477L, medianTaskCountPerStage#3478L, bytesSpilledToDiskSerializedTotal#3479L, bytesSpilledToDiskSerializedMin#3480L, bytesSpilledToDiskSerializedMax#3481L, bytesSpilledToDiskSerializedMedian#3482L, taskCpuTimeTotal#3483L, taskCpuTimeMin#3484L, taskCpuTimeMax#3485L, taskCpuTimeMedian#3486L, taskDeserializeCpuTimeTotal#3487L, taskDeserializeCpuTimeMin#3488L, taskDeserializeCpuTimeMax#3489L, taskDeserializeCpuTimeMedian#3490L, taskDeserializeTimeTotal#3491L, taskDeserializeTimeMin#3492L, taskDeserializeTimeMax#3493L, taskDeserializeTimeMedian#3494L, taskRunTimeTotal#3495L, taskRunTimeMin#3496L, taskRunTimeMax#3497L, taskRunTimeMedian#3498L, jvmGcTimeTotal#3499L, jvmGcTimeMin#3500L, jvmGcTimeMax#3501L, jvmGcTimeMedian#3502L, bytesSpilledToDiskRawTotal#3503L, bytesSpilledToDiskRawMin#3504L, bytesSpilledToDiskRawMax#3505L, bytesSpilledToDiskRawMedian#3506L, resultSerializationTimeTotal#3507L, resultSerializationTimeMin#3508L, resultSerializationTimeMax#3509L, resultSerializationTimeMedian#3510L, resultSizeToDriverTotal#3511L, resultSizeToDriverMin#3512L, resultSizeToDriverMax#3513L, resultSizeToDriverMedian#3514L, taskPeakExecutionMemoryMin#3515L, taskPeakExecutionMemoryMax#3516L, taskPeakExecutionMemoryMedian#3517L, persistencyBytesReadTotal#3518L, persistencyBytesReadMin#3519L, persistencyBytesReadMax#3520L, persistencyBytesReadMedian#3521L, persistencyRecordsReadTotal#3522L, persistencyRecordsReadMin#3523L, persistencyRecordsReadMax#3524L, persistencyRecordsReadMedian#3525L, persistencyBytesWrittenTotal#3526L, persistencyBytesWrittenMin#3527L, persistencyBytesWrittenMax#3528L, persistencyBytesWrittenMedian#3529L, persistencyRecordsWrittenTotal#3530L, persistencyRecordsWrittenMin#3531L, persistencyRecordsWrittenMax#3532L, persistencyRecordsWrittenMedian#3533L, shuffleConsumeRecordsReadTotal#3534L, shuffleConsumeRemoteBlocksFetchedTotal#3535L, shuffleConsumeLocalBlocksFetchedTotal#3536L, shuffleConsumeTotalBlocksFetchedTotal#3537L, shuffleConsumeRemoteBytesReadTotal#3538L, shuffleConsumeLocalBytesReadTotal#3539L, shuffleConsumeTotalBytesReadTotal#3540L, shuffleConsumeRemoteBytesReadToDiskTotal#3541L, shuffleConsumeFetchWaitTimeTotal#3542L, shuffleProduceBytesWrittenTotal#3543L, shuffleProduceRecordsWrittenTotal#3544L, shuffleProduceWriteTimeTotal#3545L, peakExecutionMemory#3547L, peakExecutionMemoryCliqueDuration#3548L, peakExecutionMemoryCliqueSize#3549L, rddStorageDiskSizeTotal#3551L, rddStorageMemSizeTotal#3552L, rddNumCachedPartitionsTotal#3553, rddNumPartitionsTotal#3554, numberOfExecutors#3555, replenishmentRunId#3558L, tenantId#3559, cornerstoneTenantId#3560L, marketUnit#3561, scenario#3562, activityId#3563, activityType#3564, workflowType#3565, workflowId#3566, activityAttempt#3567, gitCommitId#3569]
(39) Execute InsertIntoHadoopFsRelationCommand
Input: []
Arguments: hdlfs://065c2b6f-41bb-4a20-b7a2-eb965f9cb071.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-workload-determination-service/in/performance-metrics/10000000003, false, [activityType#3564], Parquet, [__partition_columns=["activityType"], path=hdlfs://065c2b6f-41bb-4a20-b7a2-eb965f9cb071.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-workload-determination-service/in/performance-metrics/10000000003/], Append, [jobId, stageCount, totalTaskCount, minTaskCountPerStage, maxTaskCountPerStage, medianTaskCountPerStage, bytesSpilledToDiskSerializedTotal, bytesSpilledToDiskSerializedMin, bytesSpilledToDiskSerializedMax, bytesSpilledToDiskSerializedMedian, taskCpuTimeTotal, taskCpuTimeMin, taskCpuTimeMax, taskCpuTimeMedian, taskDeserializeCpuTimeTotal, taskDeserializeCpuTimeMin, taskDeserializeCpuTimeMax, taskDeserializeCpuTimeMedian, taskDeserializeTimeTotal, taskDeserializeTimeMin, taskDeserializeTimeMax, taskDeserializeTimeMedian, taskRunTimeTotal, taskRunTimeMin, taskRunTimeMax, ... 67 more fields]
(40) AdaptiveSparkPlan
Output: []
Arguments: isFinalPlan=true