== 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#3716, stageCount#3717L, totalTaskCount#3718L, minTaskCountPerStage#3719L, maxTaskCountPerStage#3720L, medianTaskCountPerStage#3721L, bytesSpilledToDiskSerializedTotal#3722L, bytesSpilledToDiskSerializedMin#3723L, bytesSpilledToDiskSerializedMax#3724L, bytesSpilledToDiskSerializedMedian#3725L, taskCpuTimeTotal#3726L, taskCpuTimeMin#3727L, taskCpuTimeMax#3728L, taskCpuTimeMedian#3729L, taskDeserializeCpuTimeTotal#3730L, taskDeserializeCpuTimeMin#3731L, taskDeserializeCpuTimeMax#3732L, taskDeserializeCpuTimeMedian#3733L, taskDeserializeTimeTotal#3734L, taskDeserializeTimeMin#3735L, taskDeserializeTimeMax#3736L, taskDeserializeTimeMedian#3737L, taskRunTimeTotal#3738L, taskRunTimeMin#3739L, taskRunTimeMax#3740L, taskRunTimeMedian#3741L, jvmGcTimeTotal#3742L, jvmGcTimeMin#3743L, jvmGcTimeMax#3744L, jvmGcTimeMedian#3745L, bytesSpilledToDiskRawTotal#3746L, bytesSpilledToDiskRawMin#3747L, bytesSpilledToDiskRawMax#3748L, bytesSpilledToDiskRawMedian#3749L, resultSerializationTimeTotal#3750L, resultSerializationTimeMin#3751L, resultSerializationTimeMax#3752L, resultSerializationTimeMedian#3753L, resultSizeToDriverTotal#3754L, resultSizeToDriverMin#3755L, resultSizeToDriverMax#3756L, resultSizeToDriverMedian#3757L, taskPeakExecutionMemoryMin#3758L, taskPeakExecutionMemoryMax#3759L, taskPeakExecutionMemoryMedian#3760L, persistencyBytesReadTotal#3761L, persistencyBytesReadMin#3762L, persistencyBytesReadMax#3763L, persistencyBytesReadMedian#3764L, persistencyRecordsReadTotal#3765L, persistencyRecordsReadMin#3766L, persistencyRecordsReadMax#3767L, persistencyRecordsReadMedian#3768L, persistencyBytesWrittenTotal#3769L, persistencyBytesWrittenMin#3770L, persistencyBytesWrittenMax#3771L, persistencyBytesWrittenMedian#3772L, persistencyRecordsWrittenTotal#3773L, persistencyRecordsWrittenMin#3774L, persistencyRecordsWrittenMax#3775L, persistencyRecordsWrittenMedian#3776L, shuffleConsumeRecordsReadTotal#3777L, shuffleConsumeRemoteBlocksFetchedTotal#3778L, shuffleConsumeLocalBlocksFetchedTotal#3779L, shuffleConsumeTotalBlocksFetchedTotal#3780L, shuffleConsumeRemoteBytesReadTotal#3781L, shuffleConsumeLocalBytesReadTotal#3782L, shuffleConsumeTotalBytesReadTotal#3783L, shuffleConsumeRemoteBytesReadToDiskTotal#3784L, shuffleConsumeFetchWaitTimeTotal#3785L, shuffleProduceBytesWrittenTotal#3786L, shuffleProduceRecordsWrittenTotal#3787L, shuffleProduceWriteTimeTotal#3788L]
Arguments: [jobId#3716, stageCount#3717L, totalTaskCount#3718L, minTaskCountPerStage#3719L, maxTaskCountPerStage#3720L, medianTaskCountPerStage#3721L, bytesSpilledToDiskSerializedTotal#3722L, bytesSpilledToDiskSerializedMin#3723L, bytesSpilledToDiskSerializedMax#3724L, bytesSpilledToDiskSerializedMedian#3725L, taskCpuTimeTotal#3726L, taskCpuTimeMin#3727L, taskCpuTimeMax#3728L, taskCpuTimeMedian#3729L, taskDeserializeCpuTimeTotal#3730L, taskDeserializeCpuTimeMin#3731L, taskDeserializeCpuTimeMax#3732L, taskDeserializeCpuTimeMedian#3733L, taskDeserializeTimeTotal#3734L, taskDeserializeTimeMin#3735L, taskDeserializeTimeMax#3736L, taskDeserializeTimeMedian#3737L, taskRunTimeTotal#3738L, taskRunTimeMin#3739L, taskRunTimeMax#3740L, ... 48 more fields]
(2) Exchange
Input [73]: [jobId#3716, stageCount#3717L, totalTaskCount#3718L, minTaskCountPerStage#3719L, maxTaskCountPerStage#3720L, medianTaskCountPerStage#3721L, bytesSpilledToDiskSerializedTotal#3722L, bytesSpilledToDiskSerializedMin#3723L, bytesSpilledToDiskSerializedMax#3724L, bytesSpilledToDiskSerializedMedian#3725L, taskCpuTimeTotal#3726L, taskCpuTimeMin#3727L, taskCpuTimeMax#3728L, taskCpuTimeMedian#3729L, taskDeserializeCpuTimeTotal#3730L, taskDeserializeCpuTimeMin#3731L, taskDeserializeCpuTimeMax#3732L, taskDeserializeCpuTimeMedian#3733L, taskDeserializeTimeTotal#3734L, taskDeserializeTimeMin#3735L, taskDeserializeTimeMax#3736L, taskDeserializeTimeMedian#3737L, taskRunTimeTotal#3738L, taskRunTimeMin#3739L, taskRunTimeMax#3740L, taskRunTimeMedian#3741L, jvmGcTimeTotal#3742L, jvmGcTimeMin#3743L, jvmGcTimeMax#3744L, jvmGcTimeMedian#3745L, bytesSpilledToDiskRawTotal#3746L, bytesSpilledToDiskRawMin#3747L, bytesSpilledToDiskRawMax#3748L, bytesSpilledToDiskRawMedian#3749L, resultSerializationTimeTotal#3750L, resultSerializationTimeMin#3751L, resultSerializationTimeMax#3752L, resultSerializationTimeMedian#3753L, resultSizeToDriverTotal#3754L, resultSizeToDriverMin#3755L, resultSizeToDriverMax#3756L, resultSizeToDriverMedian#3757L, taskPeakExecutionMemoryMin#3758L, taskPeakExecutionMemoryMax#3759L, taskPeakExecutionMemoryMedian#3760L, persistencyBytesReadTotal#3761L, persistencyBytesReadMin#3762L, persistencyBytesReadMax#3763L, persistencyBytesReadMedian#3764L, persistencyRecordsReadTotal#3765L, persistencyRecordsReadMin#3766L, persistencyRecordsReadMax#3767L, persistencyRecordsReadMedian#3768L, persistencyBytesWrittenTotal#3769L, persistencyBytesWrittenMin#3770L, persistencyBytesWrittenMax#3771L, persistencyBytesWrittenMedian#3772L, persistencyRecordsWrittenTotal#3773L, persistencyRecordsWrittenMin#3774L, persistencyRecordsWrittenMax#3775L, persistencyRecordsWrittenMedian#3776L, shuffleConsumeRecordsReadTotal#3777L, shuffleConsumeRemoteBlocksFetchedTotal#3778L, shuffleConsumeLocalBlocksFetchedTotal#3779L, shuffleConsumeTotalBlocksFetchedTotal#3780L, shuffleConsumeRemoteBytesReadTotal#3781L, shuffleConsumeLocalBytesReadTotal#3782L, shuffleConsumeTotalBytesReadTotal#3783L, shuffleConsumeRemoteBytesReadToDiskTotal#3784L, shuffleConsumeFetchWaitTimeTotal#3785L, shuffleProduceBytesWrittenTotal#3786L, shuffleProduceRecordsWrittenTotal#3787L, shuffleProduceWriteTimeTotal#3788L]
Arguments: hashpartitioning(jobId#3716, 200), ENSURE_REQUIREMENTS, [plan_id=4822]
(3) ShuffleQueryStage
Output [73]: [jobId#3716, stageCount#3717L, totalTaskCount#3718L, minTaskCountPerStage#3719L, maxTaskCountPerStage#3720L, medianTaskCountPerStage#3721L, bytesSpilledToDiskSerializedTotal#3722L, bytesSpilledToDiskSerializedMin#3723L, bytesSpilledToDiskSerializedMax#3724L, bytesSpilledToDiskSerializedMedian#3725L, taskCpuTimeTotal#3726L, taskCpuTimeMin#3727L, taskCpuTimeMax#3728L, taskCpuTimeMedian#3729L, taskDeserializeCpuTimeTotal#3730L, taskDeserializeCpuTimeMin#3731L, taskDeserializeCpuTimeMax#3732L, taskDeserializeCpuTimeMedian#3733L, taskDeserializeTimeTotal#3734L, taskDeserializeTimeMin#3735L, taskDeserializeTimeMax#3736L, taskDeserializeTimeMedian#3737L, taskRunTimeTotal#3738L, taskRunTimeMin#3739L, taskRunTimeMax#3740L, taskRunTimeMedian#3741L, jvmGcTimeTotal#3742L, jvmGcTimeMin#3743L, jvmGcTimeMax#3744L, jvmGcTimeMedian#3745L, bytesSpilledToDiskRawTotal#3746L, bytesSpilledToDiskRawMin#3747L, bytesSpilledToDiskRawMax#3748L, bytesSpilledToDiskRawMedian#3749L, resultSerializationTimeTotal#3750L, resultSerializationTimeMin#3751L, resultSerializationTimeMax#3752L, resultSerializationTimeMedian#3753L, resultSizeToDriverTotal#3754L, resultSizeToDriverMin#3755L, resultSizeToDriverMax#3756L, resultSizeToDriverMedian#3757L, taskPeakExecutionMemoryMin#3758L, taskPeakExecutionMemoryMax#3759L, taskPeakExecutionMemoryMedian#3760L, persistencyBytesReadTotal#3761L, persistencyBytesReadMin#3762L, persistencyBytesReadMax#3763L, persistencyBytesReadMedian#3764L, persistencyRecordsReadTotal#3765L, persistencyRecordsReadMin#3766L, persistencyRecordsReadMax#3767L, persistencyRecordsReadMedian#3768L, persistencyBytesWrittenTotal#3769L, persistencyBytesWrittenMin#3770L, persistencyBytesWrittenMax#3771L, persistencyBytesWrittenMedian#3772L, persistencyRecordsWrittenTotal#3773L, persistencyRecordsWrittenMin#3774L, persistencyRecordsWrittenMax#3775L, persistencyRecordsWrittenMedian#3776L, shuffleConsumeRecordsReadTotal#3777L, shuffleConsumeRemoteBlocksFetchedTotal#3778L, shuffleConsumeLocalBlocksFetchedTotal#3779L, shuffleConsumeTotalBlocksFetchedTotal#3780L, shuffleConsumeRemoteBytesReadTotal#3781L, shuffleConsumeLocalBytesReadTotal#3782L, shuffleConsumeTotalBytesReadTotal#3783L, shuffleConsumeRemoteBytesReadToDiskTotal#3784L, shuffleConsumeFetchWaitTimeTotal#3785L, shuffleProduceBytesWrittenTotal#3786L, shuffleProduceRecordsWrittenTotal#3787L, shuffleProduceWriteTimeTotal#3788L]
Arguments: 0
(4) AQEShuffleRead
Input [73]: [jobId#3716, stageCount#3717L, totalTaskCount#3718L, minTaskCountPerStage#3719L, maxTaskCountPerStage#3720L, medianTaskCountPerStage#3721L, bytesSpilledToDiskSerializedTotal#3722L, bytesSpilledToDiskSerializedMin#3723L, bytesSpilledToDiskSerializedMax#3724L, bytesSpilledToDiskSerializedMedian#3725L, taskCpuTimeTotal#3726L, taskCpuTimeMin#3727L, taskCpuTimeMax#3728L, taskCpuTimeMedian#3729L, taskDeserializeCpuTimeTotal#3730L, taskDeserializeCpuTimeMin#3731L, taskDeserializeCpuTimeMax#3732L, taskDeserializeCpuTimeMedian#3733L, taskDeserializeTimeTotal#3734L, taskDeserializeTimeMin#3735L, taskDeserializeTimeMax#3736L, taskDeserializeTimeMedian#3737L, taskRunTimeTotal#3738L, taskRunTimeMin#3739L, taskRunTimeMax#3740L, taskRunTimeMedian#3741L, jvmGcTimeTotal#3742L, jvmGcTimeMin#3743L, jvmGcTimeMax#3744L, jvmGcTimeMedian#3745L, bytesSpilledToDiskRawTotal#3746L, bytesSpilledToDiskRawMin#3747L, bytesSpilledToDiskRawMax#3748L, bytesSpilledToDiskRawMedian#3749L, resultSerializationTimeTotal#3750L, resultSerializationTimeMin#3751L, resultSerializationTimeMax#3752L, resultSerializationTimeMedian#3753L, resultSizeToDriverTotal#3754L, resultSizeToDriverMin#3755L, resultSizeToDriverMax#3756L, resultSizeToDriverMedian#3757L, taskPeakExecutionMemoryMin#3758L, taskPeakExecutionMemoryMax#3759L, taskPeakExecutionMemoryMedian#3760L, persistencyBytesReadTotal#3761L, persistencyBytesReadMin#3762L, persistencyBytesReadMax#3763L, persistencyBytesReadMedian#3764L, persistencyRecordsReadTotal#3765L, persistencyRecordsReadMin#3766L, persistencyRecordsReadMax#3767L, persistencyRecordsReadMedian#3768L, persistencyBytesWrittenTotal#3769L, persistencyBytesWrittenMin#3770L, persistencyBytesWrittenMax#3771L, persistencyBytesWrittenMedian#3772L, persistencyRecordsWrittenTotal#3773L, persistencyRecordsWrittenMin#3774L, persistencyRecordsWrittenMax#3775L, persistencyRecordsWrittenMedian#3776L, shuffleConsumeRecordsReadTotal#3777L, shuffleConsumeRemoteBlocksFetchedTotal#3778L, shuffleConsumeLocalBlocksFetchedTotal#3779L, shuffleConsumeTotalBlocksFetchedTotal#3780L, shuffleConsumeRemoteBytesReadTotal#3781L, shuffleConsumeLocalBytesReadTotal#3782L, shuffleConsumeTotalBytesReadTotal#3783L, shuffleConsumeRemoteBytesReadToDiskTotal#3784L, shuffleConsumeFetchWaitTimeTotal#3785L, shuffleProduceBytesWrittenTotal#3786L, shuffleProduceRecordsWrittenTotal#3787L, shuffleProduceWriteTimeTotal#3788L]
Arguments: coalesced
(5) Sort [codegen id : 1]
Input [73]: [jobId#3716, stageCount#3717L, totalTaskCount#3718L, minTaskCountPerStage#3719L, maxTaskCountPerStage#3720L, medianTaskCountPerStage#3721L, bytesSpilledToDiskSerializedTotal#3722L, bytesSpilledToDiskSerializedMin#3723L, bytesSpilledToDiskSerializedMax#3724L, bytesSpilledToDiskSerializedMedian#3725L, taskCpuTimeTotal#3726L, taskCpuTimeMin#3727L, taskCpuTimeMax#3728L, taskCpuTimeMedian#3729L, taskDeserializeCpuTimeTotal#3730L, taskDeserializeCpuTimeMin#3731L, taskDeserializeCpuTimeMax#3732L, taskDeserializeCpuTimeMedian#3733L, taskDeserializeTimeTotal#3734L, taskDeserializeTimeMin#3735L, taskDeserializeTimeMax#3736L, taskDeserializeTimeMedian#3737L, taskRunTimeTotal#3738L, taskRunTimeMin#3739L, taskRunTimeMax#3740L, taskRunTimeMedian#3741L, jvmGcTimeTotal#3742L, jvmGcTimeMin#3743L, jvmGcTimeMax#3744L, jvmGcTimeMedian#3745L, bytesSpilledToDiskRawTotal#3746L, bytesSpilledToDiskRawMin#3747L, bytesSpilledToDiskRawMax#3748L, bytesSpilledToDiskRawMedian#3749L, resultSerializationTimeTotal#3750L, resultSerializationTimeMin#3751L, resultSerializationTimeMax#3752L, resultSerializationTimeMedian#3753L, resultSizeToDriverTotal#3754L, resultSizeToDriverMin#3755L, resultSizeToDriverMax#3756L, resultSizeToDriverMedian#3757L, taskPeakExecutionMemoryMin#3758L, taskPeakExecutionMemoryMax#3759L, taskPeakExecutionMemoryMedian#3760L, persistencyBytesReadTotal#3761L, persistencyBytesReadMin#3762L, persistencyBytesReadMax#3763L, persistencyBytesReadMedian#3764L, persistencyRecordsReadTotal#3765L, persistencyRecordsReadMin#3766L, persistencyRecordsReadMax#3767L, persistencyRecordsReadMedian#3768L, persistencyBytesWrittenTotal#3769L, persistencyBytesWrittenMin#3770L, persistencyBytesWrittenMax#3771L, persistencyBytesWrittenMedian#3772L, persistencyRecordsWrittenTotal#3773L, persistencyRecordsWrittenMin#3774L, persistencyRecordsWrittenMax#3775L, persistencyRecordsWrittenMedian#3776L, shuffleConsumeRecordsReadTotal#3777L, shuffleConsumeRemoteBlocksFetchedTotal#3778L, shuffleConsumeLocalBlocksFetchedTotal#3779L, shuffleConsumeTotalBlocksFetchedTotal#3780L, shuffleConsumeRemoteBytesReadTotal#3781L, shuffleConsumeLocalBytesReadTotal#3782L, shuffleConsumeTotalBytesReadTotal#3783L, shuffleConsumeRemoteBytesReadToDiskTotal#3784L, shuffleConsumeFetchWaitTimeTotal#3785L, shuffleProduceBytesWrittenTotal#3786L, shuffleProduceRecordsWrittenTotal#3787L, shuffleProduceWriteTimeTotal#3788L]
Arguments: [jobId#3716 ASC NULLS FIRST], false, 0
(6) LocalTableScan
Output [4]: [jobId#3789, peakExecutionMemory#3790L, peakExecutionMemoryCliqueDuration#3791L, peakExecutionMemoryCliqueSize#3792L]
Arguments: [jobId#3789, peakExecutionMemory#3790L, peakExecutionMemoryCliqueDuration#3791L, peakExecutionMemoryCliqueSize#3792L]
(7) Exchange
Input [4]: [jobId#3789, peakExecutionMemory#3790L, peakExecutionMemoryCliqueDuration#3791L, peakExecutionMemoryCliqueSize#3792L]
Arguments: hashpartitioning(jobId#3789, 200), ENSURE_REQUIREMENTS, [plan_id=4823]
(8) ShuffleQueryStage
Output [4]: [jobId#3789, peakExecutionMemory#3790L, peakExecutionMemoryCliqueDuration#3791L, peakExecutionMemoryCliqueSize#3792L]
Arguments: 1
(9) AQEShuffleRead
Input [4]: [jobId#3789, peakExecutionMemory#3790L, peakExecutionMemoryCliqueDuration#3791L, peakExecutionMemoryCliqueSize#3792L]
Arguments: coalesced
(10) Sort [codegen id : 2]
Input [4]: [jobId#3789, peakExecutionMemory#3790L, peakExecutionMemoryCliqueDuration#3791L, peakExecutionMemoryCliqueSize#3792L]
Arguments: [jobId#3789 ASC NULLS FIRST], false, 0
(11) SortMergeJoin [codegen id : 3]
Left keys [1]: [jobId#3716]
Right keys [1]: [jobId#3789]
Join type: FullOuter
Join condition: None
(12) Project [codegen id : 3]
Output [76]: [coalesce(jobId#3716, jobId#3789) AS jobId#3799, stageCount#3717L, totalTaskCount#3718L, minTaskCountPerStage#3719L, maxTaskCountPerStage#3720L, medianTaskCountPerStage#3721L, bytesSpilledToDiskSerializedTotal#3722L, bytesSpilledToDiskSerializedMin#3723L, bytesSpilledToDiskSerializedMax#3724L, bytesSpilledToDiskSerializedMedian#3725L, taskCpuTimeTotal#3726L, taskCpuTimeMin#3727L, taskCpuTimeMax#3728L, taskCpuTimeMedian#3729L, taskDeserializeCpuTimeTotal#3730L, taskDeserializeCpuTimeMin#3731L, taskDeserializeCpuTimeMax#3732L, taskDeserializeCpuTimeMedian#3733L, taskDeserializeTimeTotal#3734L, taskDeserializeTimeMin#3735L, taskDeserializeTimeMax#3736L, taskDeserializeTimeMedian#3737L, taskRunTimeTotal#3738L, taskRunTimeMin#3739L, taskRunTimeMax#3740L, taskRunTimeMedian#3741L, jvmGcTimeTotal#3742L, jvmGcTimeMin#3743L, jvmGcTimeMax#3744L, jvmGcTimeMedian#3745L, bytesSpilledToDiskRawTotal#3746L, bytesSpilledToDiskRawMin#3747L, bytesSpilledToDiskRawMax#3748L, bytesSpilledToDiskRawMedian#3749L, resultSerializationTimeTotal#3750L, resultSerializationTimeMin#3751L, resultSerializationTimeMax#3752L, resultSerializationTimeMedian#3753L, resultSizeToDriverTotal#3754L, resultSizeToDriverMin#3755L, resultSizeToDriverMax#3756L, resultSizeToDriverMedian#3757L, taskPeakExecutionMemoryMin#3758L, taskPeakExecutionMemoryMax#3759L, taskPeakExecutionMemoryMedian#3760L, persistencyBytesReadTotal#3761L, persistencyBytesReadMin#3762L, persistencyBytesReadMax#3763L, persistencyBytesReadMedian#3764L, persistencyRecordsReadTotal#3765L, persistencyRecordsReadMin#3766L, persistencyRecordsReadMax#3767L, persistencyRecordsReadMedian#3768L, persistencyBytesWrittenTotal#3769L, persistencyBytesWrittenMin#3770L, persistencyBytesWrittenMax#3771L, persistencyBytesWrittenMedian#3772L, persistencyRecordsWrittenTotal#3773L, persistencyRecordsWrittenMin#3774L, persistencyRecordsWrittenMax#3775L, persistencyRecordsWrittenMedian#3776L, shuffleConsumeRecordsReadTotal#3777L, shuffleConsumeRemoteBlocksFetchedTotal#3778L, shuffleConsumeLocalBlocksFetchedTotal#3779L, shuffleConsumeTotalBlocksFetchedTotal#3780L, shuffleConsumeRemoteBytesReadTotal#3781L, shuffleConsumeLocalBytesReadTotal#3782L, shuffleConsumeTotalBytesReadTotal#3783L, shuffleConsumeRemoteBytesReadToDiskTotal#3784L, shuffleConsumeFetchWaitTimeTotal#3785L, shuffleProduceBytesWrittenTotal#3786L, shuffleProduceRecordsWrittenTotal#3787L, shuffleProduceWriteTimeTotal#3788L, peakExecutionMemory#3790L, peakExecutionMemoryCliqueDuration#3791L, peakExecutionMemoryCliqueSize#3792L]
Input [77]: [jobId#3716, stageCount#3717L, totalTaskCount#3718L, minTaskCountPerStage#3719L, maxTaskCountPerStage#3720L, medianTaskCountPerStage#3721L, bytesSpilledToDiskSerializedTotal#3722L, bytesSpilledToDiskSerializedMin#3723L, bytesSpilledToDiskSerializedMax#3724L, bytesSpilledToDiskSerializedMedian#3725L, taskCpuTimeTotal#3726L, taskCpuTimeMin#3727L, taskCpuTimeMax#3728L, taskCpuTimeMedian#3729L, taskDeserializeCpuTimeTotal#3730L, taskDeserializeCpuTimeMin#3731L, taskDeserializeCpuTimeMax#3732L, taskDeserializeCpuTimeMedian#3733L, taskDeserializeTimeTotal#3734L, taskDeserializeTimeMin#3735L, taskDeserializeTimeMax#3736L, taskDeserializeTimeMedian#3737L, taskRunTimeTotal#3738L, taskRunTimeMin#3739L, taskRunTimeMax#3740L, taskRunTimeMedian#3741L, jvmGcTimeTotal#3742L, jvmGcTimeMin#3743L, jvmGcTimeMax#3744L, jvmGcTimeMedian#3745L, bytesSpilledToDiskRawTotal#3746L, bytesSpilledToDiskRawMin#3747L, bytesSpilledToDiskRawMax#3748L, bytesSpilledToDiskRawMedian#3749L, resultSerializationTimeTotal#3750L, resultSerializationTimeMin#3751L, resultSerializationTimeMax#3752L, resultSerializationTimeMedian#3753L, resultSizeToDriverTotal#3754L, resultSizeToDriverMin#3755L, resultSizeToDriverMax#3756L, resultSizeToDriverMedian#3757L, taskPeakExecutionMemoryMin#3758L, taskPeakExecutionMemoryMax#3759L, taskPeakExecutionMemoryMedian#3760L, persistencyBytesReadTotal#3761L, persistencyBytesReadMin#3762L, persistencyBytesReadMax#3763L, persistencyBytesReadMedian#3764L, persistencyRecordsReadTotal#3765L, persistencyRecordsReadMin#3766L, persistencyRecordsReadMax#3767L, persistencyRecordsReadMedian#3768L, persistencyBytesWrittenTotal#3769L, persistencyBytesWrittenMin#3770L, persistencyBytesWrittenMax#3771L, persistencyBytesWrittenMedian#3772L, persistencyRecordsWrittenTotal#3773L, persistencyRecordsWrittenMin#3774L, persistencyRecordsWrittenMax#3775L, persistencyRecordsWrittenMedian#3776L, shuffleConsumeRecordsReadTotal#3777L, shuffleConsumeRemoteBlocksFetchedTotal#3778L, shuffleConsumeLocalBlocksFetchedTotal#3779L, shuffleConsumeTotalBlocksFetchedTotal#3780L, shuffleConsumeRemoteBytesReadTotal#3781L, shuffleConsumeLocalBytesReadTotal#3782L, shuffleConsumeTotalBytesReadTotal#3783L, shuffleConsumeRemoteBytesReadToDiskTotal#3784L, shuffleConsumeFetchWaitTimeTotal#3785L, shuffleProduceBytesWrittenTotal#3786L, shuffleProduceRecordsWrittenTotal#3787L, shuffleProduceWriteTimeTotal#3788L, jobId#3789, peakExecutionMemory#3790L, peakExecutionMemoryCliqueDuration#3791L, peakExecutionMemoryCliqueSize#3792L]
(13) Exchange
Input [76]: [jobId#3799, stageCount#3717L, totalTaskCount#3718L, minTaskCountPerStage#3719L, maxTaskCountPerStage#3720L, medianTaskCountPerStage#3721L, bytesSpilledToDiskSerializedTotal#3722L, bytesSpilledToDiskSerializedMin#3723L, bytesSpilledToDiskSerializedMax#3724L, bytesSpilledToDiskSerializedMedian#3725L, taskCpuTimeTotal#3726L, taskCpuTimeMin#3727L, taskCpuTimeMax#3728L, taskCpuTimeMedian#3729L, taskDeserializeCpuTimeTotal#3730L, taskDeserializeCpuTimeMin#3731L, taskDeserializeCpuTimeMax#3732L, taskDeserializeCpuTimeMedian#3733L, taskDeserializeTimeTotal#3734L, taskDeserializeTimeMin#3735L, taskDeserializeTimeMax#3736L, taskDeserializeTimeMedian#3737L, taskRunTimeTotal#3738L, taskRunTimeMin#3739L, taskRunTimeMax#3740L, taskRunTimeMedian#3741L, jvmGcTimeTotal#3742L, jvmGcTimeMin#3743L, jvmGcTimeMax#3744L, jvmGcTimeMedian#3745L, bytesSpilledToDiskRawTotal#3746L, bytesSpilledToDiskRawMin#3747L, bytesSpilledToDiskRawMax#3748L, bytesSpilledToDiskRawMedian#3749L, resultSerializationTimeTotal#3750L, resultSerializationTimeMin#3751L, resultSerializationTimeMax#3752L, resultSerializationTimeMedian#3753L, resultSizeToDriverTotal#3754L, resultSizeToDriverMin#3755L, resultSizeToDriverMax#3756L, resultSizeToDriverMedian#3757L, taskPeakExecutionMemoryMin#3758L, taskPeakExecutionMemoryMax#3759L, taskPeakExecutionMemoryMedian#3760L, persistencyBytesReadTotal#3761L, persistencyBytesReadMin#3762L, persistencyBytesReadMax#3763L, persistencyBytesReadMedian#3764L, persistencyRecordsReadTotal#3765L, persistencyRecordsReadMin#3766L, persistencyRecordsReadMax#3767L, persistencyRecordsReadMedian#3768L, persistencyBytesWrittenTotal#3769L, persistencyBytesWrittenMin#3770L, persistencyBytesWrittenMax#3771L, persistencyBytesWrittenMedian#3772L, persistencyRecordsWrittenTotal#3773L, persistencyRecordsWrittenMin#3774L, persistencyRecordsWrittenMax#3775L, persistencyRecordsWrittenMedian#3776L, shuffleConsumeRecordsReadTotal#3777L, shuffleConsumeRemoteBlocksFetchedTotal#3778L, shuffleConsumeLocalBlocksFetchedTotal#3779L, shuffleConsumeTotalBlocksFetchedTotal#3780L, shuffleConsumeRemoteBytesReadTotal#3781L, shuffleConsumeLocalBytesReadTotal#3782L, shuffleConsumeTotalBytesReadTotal#3783L, shuffleConsumeRemoteBytesReadToDiskTotal#3784L, shuffleConsumeFetchWaitTimeTotal#3785L, shuffleProduceBytesWrittenTotal#3786L, shuffleProduceRecordsWrittenTotal#3787L, shuffleProduceWriteTimeTotal#3788L, peakExecutionMemory#3790L, peakExecutionMemoryCliqueDuration#3791L, peakExecutionMemoryCliqueSize#3792L]
Arguments: hashpartitioning(jobId#3799, 200), ENSURE_REQUIREMENTS, [plan_id=5027]
(14) ShuffleQueryStage
Output [76]: [jobId#3799, stageCount#3717L, totalTaskCount#3718L, minTaskCountPerStage#3719L, maxTaskCountPerStage#3720L, medianTaskCountPerStage#3721L, bytesSpilledToDiskSerializedTotal#3722L, bytesSpilledToDiskSerializedMin#3723L, bytesSpilledToDiskSerializedMax#3724L, bytesSpilledToDiskSerializedMedian#3725L, taskCpuTimeTotal#3726L, taskCpuTimeMin#3727L, taskCpuTimeMax#3728L, taskCpuTimeMedian#3729L, taskDeserializeCpuTimeTotal#3730L, taskDeserializeCpuTimeMin#3731L, taskDeserializeCpuTimeMax#3732L, taskDeserializeCpuTimeMedian#3733L, taskDeserializeTimeTotal#3734L, taskDeserializeTimeMin#3735L, taskDeserializeTimeMax#3736L, taskDeserializeTimeMedian#3737L, taskRunTimeTotal#3738L, taskRunTimeMin#3739L, taskRunTimeMax#3740L, taskRunTimeMedian#3741L, jvmGcTimeTotal#3742L, jvmGcTimeMin#3743L, jvmGcTimeMax#3744L, jvmGcTimeMedian#3745L, bytesSpilledToDiskRawTotal#3746L, bytesSpilledToDiskRawMin#3747L, bytesSpilledToDiskRawMax#3748L, bytesSpilledToDiskRawMedian#3749L, resultSerializationTimeTotal#3750L, resultSerializationTimeMin#3751L, resultSerializationTimeMax#3752L, resultSerializationTimeMedian#3753L, resultSizeToDriverTotal#3754L, resultSizeToDriverMin#3755L, resultSizeToDriverMax#3756L, resultSizeToDriverMedian#3757L, taskPeakExecutionMemoryMin#3758L, taskPeakExecutionMemoryMax#3759L, taskPeakExecutionMemoryMedian#3760L, persistencyBytesReadTotal#3761L, persistencyBytesReadMin#3762L, persistencyBytesReadMax#3763L, persistencyBytesReadMedian#3764L, persistencyRecordsReadTotal#3765L, persistencyRecordsReadMin#3766L, persistencyRecordsReadMax#3767L, persistencyRecordsReadMedian#3768L, persistencyBytesWrittenTotal#3769L, persistencyBytesWrittenMin#3770L, persistencyBytesWrittenMax#3771L, persistencyBytesWrittenMedian#3772L, persistencyRecordsWrittenTotal#3773L, persistencyRecordsWrittenMin#3774L, persistencyRecordsWrittenMax#3775L, persistencyRecordsWrittenMedian#3776L, shuffleConsumeRecordsReadTotal#3777L, shuffleConsumeRemoteBlocksFetchedTotal#3778L, shuffleConsumeLocalBlocksFetchedTotal#3779L, shuffleConsumeTotalBlocksFetchedTotal#3780L, shuffleConsumeRemoteBytesReadTotal#3781L, shuffleConsumeLocalBytesReadTotal#3782L, shuffleConsumeTotalBytesReadTotal#3783L, shuffleConsumeRemoteBytesReadToDiskTotal#3784L, shuffleConsumeFetchWaitTimeTotal#3785L, shuffleProduceBytesWrittenTotal#3786L, shuffleProduceRecordsWrittenTotal#3787L, shuffleProduceWriteTimeTotal#3788L, peakExecutionMemory#3790L, peakExecutionMemoryCliqueDuration#3791L, peakExecutionMemoryCliqueSize#3792L]
Arguments: 3
(15) AQEShuffleRead
Input [76]: [jobId#3799, stageCount#3717L, totalTaskCount#3718L, minTaskCountPerStage#3719L, maxTaskCountPerStage#3720L, medianTaskCountPerStage#3721L, bytesSpilledToDiskSerializedTotal#3722L, bytesSpilledToDiskSerializedMin#3723L, bytesSpilledToDiskSerializedMax#3724L, bytesSpilledToDiskSerializedMedian#3725L, taskCpuTimeTotal#3726L, taskCpuTimeMin#3727L, taskCpuTimeMax#3728L, taskCpuTimeMedian#3729L, taskDeserializeCpuTimeTotal#3730L, taskDeserializeCpuTimeMin#3731L, taskDeserializeCpuTimeMax#3732L, taskDeserializeCpuTimeMedian#3733L, taskDeserializeTimeTotal#3734L, taskDeserializeTimeMin#3735L, taskDeserializeTimeMax#3736L, taskDeserializeTimeMedian#3737L, taskRunTimeTotal#3738L, taskRunTimeMin#3739L, taskRunTimeMax#3740L, taskRunTimeMedian#3741L, jvmGcTimeTotal#3742L, jvmGcTimeMin#3743L, jvmGcTimeMax#3744L, jvmGcTimeMedian#3745L, bytesSpilledToDiskRawTotal#3746L, bytesSpilledToDiskRawMin#3747L, bytesSpilledToDiskRawMax#3748L, bytesSpilledToDiskRawMedian#3749L, resultSerializationTimeTotal#3750L, resultSerializationTimeMin#3751L, resultSerializationTimeMax#3752L, resultSerializationTimeMedian#3753L, resultSizeToDriverTotal#3754L, resultSizeToDriverMin#3755L, resultSizeToDriverMax#3756L, resultSizeToDriverMedian#3757L, taskPeakExecutionMemoryMin#3758L, taskPeakExecutionMemoryMax#3759L, taskPeakExecutionMemoryMedian#3760L, persistencyBytesReadTotal#3761L, persistencyBytesReadMin#3762L, persistencyBytesReadMax#3763L, persistencyBytesReadMedian#3764L, persistencyRecordsReadTotal#3765L, persistencyRecordsReadMin#3766L, persistencyRecordsReadMax#3767L, persistencyRecordsReadMedian#3768L, persistencyBytesWrittenTotal#3769L, persistencyBytesWrittenMin#3770L, persistencyBytesWrittenMax#3771L, persistencyBytesWrittenMedian#3772L, persistencyRecordsWrittenTotal#3773L, persistencyRecordsWrittenMin#3774L, persistencyRecordsWrittenMax#3775L, persistencyRecordsWrittenMedian#3776L, shuffleConsumeRecordsReadTotal#3777L, shuffleConsumeRemoteBlocksFetchedTotal#3778L, shuffleConsumeLocalBlocksFetchedTotal#3779L, shuffleConsumeTotalBlocksFetchedTotal#3780L, shuffleConsumeRemoteBytesReadTotal#3781L, shuffleConsumeLocalBytesReadTotal#3782L, shuffleConsumeTotalBytesReadTotal#3783L, shuffleConsumeRemoteBytesReadToDiskTotal#3784L, shuffleConsumeFetchWaitTimeTotal#3785L, shuffleProduceBytesWrittenTotal#3786L, shuffleProduceRecordsWrittenTotal#3787L, shuffleProduceWriteTimeTotal#3788L, peakExecutionMemory#3790L, peakExecutionMemoryCliqueDuration#3791L, peakExecutionMemoryCliqueSize#3792L]
Arguments: coalesced
(16) Sort [codegen id : 4]
Input [76]: [jobId#3799, stageCount#3717L, totalTaskCount#3718L, minTaskCountPerStage#3719L, maxTaskCountPerStage#3720L, medianTaskCountPerStage#3721L, bytesSpilledToDiskSerializedTotal#3722L, bytesSpilledToDiskSerializedMin#3723L, bytesSpilledToDiskSerializedMax#3724L, bytesSpilledToDiskSerializedMedian#3725L, taskCpuTimeTotal#3726L, taskCpuTimeMin#3727L, taskCpuTimeMax#3728L, taskCpuTimeMedian#3729L, taskDeserializeCpuTimeTotal#3730L, taskDeserializeCpuTimeMin#3731L, taskDeserializeCpuTimeMax#3732L, taskDeserializeCpuTimeMedian#3733L, taskDeserializeTimeTotal#3734L, taskDeserializeTimeMin#3735L, taskDeserializeTimeMax#3736L, taskDeserializeTimeMedian#3737L, taskRunTimeTotal#3738L, taskRunTimeMin#3739L, taskRunTimeMax#3740L, taskRunTimeMedian#3741L, jvmGcTimeTotal#3742L, jvmGcTimeMin#3743L, jvmGcTimeMax#3744L, jvmGcTimeMedian#3745L, bytesSpilledToDiskRawTotal#3746L, bytesSpilledToDiskRawMin#3747L, bytesSpilledToDiskRawMax#3748L, bytesSpilledToDiskRawMedian#3749L, resultSerializationTimeTotal#3750L, resultSerializationTimeMin#3751L, resultSerializationTimeMax#3752L, resultSerializationTimeMedian#3753L, resultSizeToDriverTotal#3754L, resultSizeToDriverMin#3755L, resultSizeToDriverMax#3756L, resultSizeToDriverMedian#3757L, taskPeakExecutionMemoryMin#3758L, taskPeakExecutionMemoryMax#3759L, taskPeakExecutionMemoryMedian#3760L, persistencyBytesReadTotal#3761L, persistencyBytesReadMin#3762L, persistencyBytesReadMax#3763L, persistencyBytesReadMedian#3764L, persistencyRecordsReadTotal#3765L, persistencyRecordsReadMin#3766L, persistencyRecordsReadMax#3767L, persistencyRecordsReadMedian#3768L, persistencyBytesWrittenTotal#3769L, persistencyBytesWrittenMin#3770L, persistencyBytesWrittenMax#3771L, persistencyBytesWrittenMedian#3772L, persistencyRecordsWrittenTotal#3773L, persistencyRecordsWrittenMin#3774L, persistencyRecordsWrittenMax#3775L, persistencyRecordsWrittenMedian#3776L, shuffleConsumeRecordsReadTotal#3777L, shuffleConsumeRemoteBlocksFetchedTotal#3778L, shuffleConsumeLocalBlocksFetchedTotal#3779L, shuffleConsumeTotalBlocksFetchedTotal#3780L, shuffleConsumeRemoteBytesReadTotal#3781L, shuffleConsumeLocalBytesReadTotal#3782L, shuffleConsumeTotalBytesReadTotal#3783L, shuffleConsumeRemoteBytesReadToDiskTotal#3784L, shuffleConsumeFetchWaitTimeTotal#3785L, shuffleProduceBytesWrittenTotal#3786L, shuffleProduceRecordsWrittenTotal#3787L, shuffleProduceWriteTimeTotal#3788L, peakExecutionMemory#3790L, peakExecutionMemoryCliqueDuration#3791L, peakExecutionMemoryCliqueSize#3792L]
Arguments: [jobId#3799 ASC NULLS FIRST], false, 0
(17) LocalTableScan
Output [6]: [jobId#3793, rddStorageDiskSizeTotal#3794L, rddStorageMemSizeTotal#3795L, rddNumCachedPartitionsTotal#3796, rddNumPartitionsTotal#3797, numberOfExecutors#3798]
Arguments: [jobId#3793, rddStorageDiskSizeTotal#3794L, rddStorageMemSizeTotal#3795L, rddNumCachedPartitionsTotal#3796, rddNumPartitionsTotal#3797, numberOfExecutors#3798]
(18) Exchange
Input [6]: [jobId#3793, rddStorageDiskSizeTotal#3794L, rddStorageMemSizeTotal#3795L, rddNumCachedPartitionsTotal#3796, rddNumPartitionsTotal#3797, numberOfExecutors#3798]
Arguments: hashpartitioning(jobId#3793, 200), ENSURE_REQUIREMENTS, [plan_id=4831]
(19) ShuffleQueryStage
Output [6]: [jobId#3793, rddStorageDiskSizeTotal#3794L, rddStorageMemSizeTotal#3795L, rddNumCachedPartitionsTotal#3796, rddNumPartitionsTotal#3797, numberOfExecutors#3798]
Arguments: 2
(20) AQEShuffleRead
Input [6]: [jobId#3793, rddStorageDiskSizeTotal#3794L, rddStorageMemSizeTotal#3795L, rddNumCachedPartitionsTotal#3796, rddNumPartitionsTotal#3797, numberOfExecutors#3798]
Arguments: coalesced
(21) Sort [codegen id : 5]
Input [6]: [jobId#3793, rddStorageDiskSizeTotal#3794L, rddStorageMemSizeTotal#3795L, rddNumCachedPartitionsTotal#3796, rddNumPartitionsTotal#3797, numberOfExecutors#3798]
Arguments: [jobId#3793 ASC NULLS FIRST], false, 0
(22) SortMergeJoin [codegen id : 6]
Left keys [1]: [jobId#3799]
Right keys [1]: [jobId#3793]
Join type: FullOuter
Join condition: None
(23) Project [codegen id : 6]
Output [92]: [coalesce(jobId#3799, jobId#3793) AS jobId#3800, stageCount#3717L, totalTaskCount#3718L, minTaskCountPerStage#3719L, maxTaskCountPerStage#3720L, medianTaskCountPerStage#3721L, bytesSpilledToDiskSerializedTotal#3722L, bytesSpilledToDiskSerializedMin#3723L, bytesSpilledToDiskSerializedMax#3724L, bytesSpilledToDiskSerializedMedian#3725L, taskCpuTimeTotal#3726L, taskCpuTimeMin#3727L, taskCpuTimeMax#3728L, taskCpuTimeMedian#3729L, taskDeserializeCpuTimeTotal#3730L, taskDeserializeCpuTimeMin#3731L, taskDeserializeCpuTimeMax#3732L, taskDeserializeCpuTimeMedian#3733L, taskDeserializeTimeTotal#3734L, taskDeserializeTimeMin#3735L, taskDeserializeTimeMax#3736L, taskDeserializeTimeMedian#3737L, taskRunTimeTotal#3738L, taskRunTimeMin#3739L, taskRunTimeMax#3740L, taskRunTimeMedian#3741L, jvmGcTimeTotal#3742L, jvmGcTimeMin#3743L, jvmGcTimeMax#3744L, jvmGcTimeMedian#3745L, bytesSpilledToDiskRawTotal#3746L, bytesSpilledToDiskRawMin#3747L, bytesSpilledToDiskRawMax#3748L, bytesSpilledToDiskRawMedian#3749L, resultSerializationTimeTotal#3750L, resultSerializationTimeMin#3751L, resultSerializationTimeMax#3752L, resultSerializationTimeMedian#3753L, resultSizeToDriverTotal#3754L, resultSizeToDriverMin#3755L, resultSizeToDriverMax#3756L, resultSizeToDriverMedian#3757L, taskPeakExecutionMemoryMin#3758L, taskPeakExecutionMemoryMax#3759L, taskPeakExecutionMemoryMedian#3760L, persistencyBytesReadTotal#3761L, persistencyBytesReadMin#3762L, persistencyBytesReadMax#3763L, persistencyBytesReadMedian#3764L, persistencyRecordsReadTotal#3765L, persistencyRecordsReadMin#3766L, persistencyRecordsReadMax#3767L, persistencyRecordsReadMedian#3768L, persistencyBytesWrittenTotal#3769L, persistencyBytesWrittenMin#3770L, persistencyBytesWrittenMax#3771L, persistencyBytesWrittenMedian#3772L, persistencyRecordsWrittenTotal#3773L, persistencyRecordsWrittenMin#3774L, persistencyRecordsWrittenMax#3775L, persistencyRecordsWrittenMedian#3776L, shuffleConsumeRecordsReadTotal#3777L, shuffleConsumeRemoteBlocksFetchedTotal#3778L, shuffleConsumeLocalBlocksFetchedTotal#3779L, shuffleConsumeTotalBlocksFetchedTotal#3780L, shuffleConsumeRemoteBytesReadTotal#3781L, shuffleConsumeLocalBytesReadTotal#3782L, shuffleConsumeTotalBytesReadTotal#3783L, shuffleConsumeRemoteBytesReadToDiskTotal#3784L, shuffleConsumeFetchWaitTimeTotal#3785L, shuffleProduceBytesWrittenTotal#3786L, shuffleProduceRecordsWrittenTotal#3787L, shuffleProduceWriteTimeTotal#3788L, peakExecutionMemory#3790L, peakExecutionMemoryCliqueDuration#3791L, peakExecutionMemoryCliqueSize#3792L, rddStorageDiskSizeTotal#3794L, rddStorageMemSizeTotal#3795L, rddNumCachedPartitionsTotal#3796, rddNumPartitionsTotal#3797, numberOfExecutors#3798, 10000000003 AS replenishmentRunId#3801L, 5330363489248697092 AS tenantId#3802, 8495 AS cornerstoneTenantId#3803L, MU_PPP_1 AS marketUnit#3804, STANDARD AS scenario#3805, 88c42b3e-f7b7-3812-8b16-7aa86f5ce414 AS activityId#3806, DetermineWorkLoad AS activityType#3807, ReplenishmentRunWorkflow AS workflowType#3808, RP_SCH_5330363489248697092_5 AS workflowId#3809, 5 AS activityAttempt#3810, unknown GIT COMMIT AS gitCommitId#3812]
Input [82]: [jobId#3799, stageCount#3717L, totalTaskCount#3718L, minTaskCountPerStage#3719L, maxTaskCountPerStage#3720L, medianTaskCountPerStage#3721L, bytesSpilledToDiskSerializedTotal#3722L, bytesSpilledToDiskSerializedMin#3723L, bytesSpilledToDiskSerializedMax#3724L, bytesSpilledToDiskSerializedMedian#3725L, taskCpuTimeTotal#3726L, taskCpuTimeMin#3727L, taskCpuTimeMax#3728L, taskCpuTimeMedian#3729L, taskDeserializeCpuTimeTotal#3730L, taskDeserializeCpuTimeMin#3731L, taskDeserializeCpuTimeMax#3732L, taskDeserializeCpuTimeMedian#3733L, taskDeserializeTimeTotal#3734L, taskDeserializeTimeMin#3735L, taskDeserializeTimeMax#3736L, taskDeserializeTimeMedian#3737L, taskRunTimeTotal#3738L, taskRunTimeMin#3739L, taskRunTimeMax#3740L, taskRunTimeMedian#3741L, jvmGcTimeTotal#3742L, jvmGcTimeMin#3743L, jvmGcTimeMax#3744L, jvmGcTimeMedian#3745L, bytesSpilledToDiskRawTotal#3746L, bytesSpilledToDiskRawMin#3747L, bytesSpilledToDiskRawMax#3748L, bytesSpilledToDiskRawMedian#3749L, resultSerializationTimeTotal#3750L, resultSerializationTimeMin#3751L, resultSerializationTimeMax#3752L, resultSerializationTimeMedian#3753L, resultSizeToDriverTotal#3754L, resultSizeToDriverMin#3755L, resultSizeToDriverMax#3756L, resultSizeToDriverMedian#3757L, taskPeakExecutionMemoryMin#3758L, taskPeakExecutionMemoryMax#3759L, taskPeakExecutionMemoryMedian#3760L, persistencyBytesReadTotal#3761L, persistencyBytesReadMin#3762L, persistencyBytesReadMax#3763L, persistencyBytesReadMedian#3764L, persistencyRecordsReadTotal#3765L, persistencyRecordsReadMin#3766L, persistencyRecordsReadMax#3767L, persistencyRecordsReadMedian#3768L, persistencyBytesWrittenTotal#3769L, persistencyBytesWrittenMin#3770L, persistencyBytesWrittenMax#3771L, persistencyBytesWrittenMedian#3772L, persistencyRecordsWrittenTotal#3773L, persistencyRecordsWrittenMin#3774L, persistencyRecordsWrittenMax#3775L, persistencyRecordsWrittenMedian#3776L, shuffleConsumeRecordsReadTotal#3777L, shuffleConsumeRemoteBlocksFetchedTotal#3778L, shuffleConsumeLocalBlocksFetchedTotal#3779L, shuffleConsumeTotalBlocksFetchedTotal#3780L, shuffleConsumeRemoteBytesReadTotal#3781L, shuffleConsumeLocalBytesReadTotal#3782L, shuffleConsumeTotalBytesReadTotal#3783L, shuffleConsumeRemoteBytesReadToDiskTotal#3784L, shuffleConsumeFetchWaitTimeTotal#3785L, shuffleProduceBytesWrittenTotal#3786L, shuffleProduceRecordsWrittenTotal#3787L, shuffleProduceWriteTimeTotal#3788L, peakExecutionMemory#3790L, peakExecutionMemoryCliqueDuration#3791L, peakExecutionMemoryCliqueSize#3792L, jobId#3793, rddStorageDiskSizeTotal#3794L, rddStorageMemSizeTotal#3795L, rddNumCachedPartitionsTotal#3796, rddNumPartitionsTotal#3797, numberOfExecutors#3798]
(24) Sort [codegen id : 6]
Input [92]: [jobId#3800, stageCount#3717L, totalTaskCount#3718L, minTaskCountPerStage#3719L, maxTaskCountPerStage#3720L, medianTaskCountPerStage#3721L, bytesSpilledToDiskSerializedTotal#3722L, bytesSpilledToDiskSerializedMin#3723L, bytesSpilledToDiskSerializedMax#3724L, bytesSpilledToDiskSerializedMedian#3725L, taskCpuTimeTotal#3726L, taskCpuTimeMin#3727L, taskCpuTimeMax#3728L, taskCpuTimeMedian#3729L, taskDeserializeCpuTimeTotal#3730L, taskDeserializeCpuTimeMin#3731L, taskDeserializeCpuTimeMax#3732L, taskDeserializeCpuTimeMedian#3733L, taskDeserializeTimeTotal#3734L, taskDeserializeTimeMin#3735L, taskDeserializeTimeMax#3736L, taskDeserializeTimeMedian#3737L, taskRunTimeTotal#3738L, taskRunTimeMin#3739L, taskRunTimeMax#3740L, taskRunTimeMedian#3741L, jvmGcTimeTotal#3742L, jvmGcTimeMin#3743L, jvmGcTimeMax#3744L, jvmGcTimeMedian#3745L, bytesSpilledToDiskRawTotal#3746L, bytesSpilledToDiskRawMin#3747L, bytesSpilledToDiskRawMax#3748L, bytesSpilledToDiskRawMedian#3749L, resultSerializationTimeTotal#3750L, resultSerializationTimeMin#3751L, resultSerializationTimeMax#3752L, resultSerializationTimeMedian#3753L, resultSizeToDriverTotal#3754L, resultSizeToDriverMin#3755L, resultSizeToDriverMax#3756L, resultSizeToDriverMedian#3757L, taskPeakExecutionMemoryMin#3758L, taskPeakExecutionMemoryMax#3759L, taskPeakExecutionMemoryMedian#3760L, persistencyBytesReadTotal#3761L, persistencyBytesReadMin#3762L, persistencyBytesReadMax#3763L, persistencyBytesReadMedian#3764L, persistencyRecordsReadTotal#3765L, persistencyRecordsReadMin#3766L, persistencyRecordsReadMax#3767L, persistencyRecordsReadMedian#3768L, persistencyBytesWrittenTotal#3769L, persistencyBytesWrittenMin#3770L, persistencyBytesWrittenMax#3771L, persistencyBytesWrittenMedian#3772L, persistencyRecordsWrittenTotal#3773L, persistencyRecordsWrittenMin#3774L, persistencyRecordsWrittenMax#3775L, persistencyRecordsWrittenMedian#3776L, shuffleConsumeRecordsReadTotal#3777L, shuffleConsumeRemoteBlocksFetchedTotal#3778L, shuffleConsumeLocalBlocksFetchedTotal#3779L, shuffleConsumeTotalBlocksFetchedTotal#3780L, shuffleConsumeRemoteBytesReadTotal#3781L, shuffleConsumeLocalBytesReadTotal#3782L, shuffleConsumeTotalBytesReadTotal#3783L, shuffleConsumeRemoteBytesReadToDiskTotal#3784L, shuffleConsumeFetchWaitTimeTotal#3785L, shuffleProduceBytesWrittenTotal#3786L, shuffleProduceRecordsWrittenTotal#3787L, shuffleProduceWriteTimeTotal#3788L, peakExecutionMemory#3790L, peakExecutionMemoryCliqueDuration#3791L, peakExecutionMemoryCliqueSize#3792L, rddStorageDiskSizeTotal#3794L, rddStorageMemSizeTotal#3795L, rddNumCachedPartitionsTotal#3796, rddNumPartitionsTotal#3797, numberOfExecutors#3798, replenishmentRunId#3801L, tenantId#3802, cornerstoneTenantId#3803L, marketUnit#3804, scenario#3805, activityId#3806, activityType#3807, workflowType#3808, workflowId#3809, activityAttempt#3810, gitCommitId#3812]
Arguments: [activityType#3807 ASC NULLS FIRST], false, 0
(25) WriteFiles
Input [92]: [jobId#3800, stageCount#3717L, totalTaskCount#3718L, minTaskCountPerStage#3719L, maxTaskCountPerStage#3720L, medianTaskCountPerStage#3721L, bytesSpilledToDiskSerializedTotal#3722L, bytesSpilledToDiskSerializedMin#3723L, bytesSpilledToDiskSerializedMax#3724L, bytesSpilledToDiskSerializedMedian#3725L, taskCpuTimeTotal#3726L, taskCpuTimeMin#3727L, taskCpuTimeMax#3728L, taskCpuTimeMedian#3729L, taskDeserializeCpuTimeTotal#3730L, taskDeserializeCpuTimeMin#3731L, taskDeserializeCpuTimeMax#3732L, taskDeserializeCpuTimeMedian#3733L, taskDeserializeTimeTotal#3734L, taskDeserializeTimeMin#3735L, taskDeserializeTimeMax#3736L, taskDeserializeTimeMedian#3737L, taskRunTimeTotal#3738L, taskRunTimeMin#3739L, taskRunTimeMax#3740L, taskRunTimeMedian#3741L, jvmGcTimeTotal#3742L, jvmGcTimeMin#3743L, jvmGcTimeMax#3744L, jvmGcTimeMedian#3745L, bytesSpilledToDiskRawTotal#3746L, bytesSpilledToDiskRawMin#3747L, bytesSpilledToDiskRawMax#3748L, bytesSpilledToDiskRawMedian#3749L, resultSerializationTimeTotal#3750L, resultSerializationTimeMin#3751L, resultSerializationTimeMax#3752L, resultSerializationTimeMedian#3753L, resultSizeToDriverTotal#3754L, resultSizeToDriverMin#3755L, resultSizeToDriverMax#3756L, resultSizeToDriverMedian#3757L, taskPeakExecutionMemoryMin#3758L, taskPeakExecutionMemoryMax#3759L, taskPeakExecutionMemoryMedian#3760L, persistencyBytesReadTotal#3761L, persistencyBytesReadMin#3762L, persistencyBytesReadMax#3763L, persistencyBytesReadMedian#3764L, persistencyRecordsReadTotal#3765L, persistencyRecordsReadMin#3766L, persistencyRecordsReadMax#3767L, persistencyRecordsReadMedian#3768L, persistencyBytesWrittenTotal#3769L, persistencyBytesWrittenMin#3770L, persistencyBytesWrittenMax#3771L, persistencyBytesWrittenMedian#3772L, persistencyRecordsWrittenTotal#3773L, persistencyRecordsWrittenMin#3774L, persistencyRecordsWrittenMax#3775L, persistencyRecordsWrittenMedian#3776L, shuffleConsumeRecordsReadTotal#3777L, shuffleConsumeRemoteBlocksFetchedTotal#3778L, shuffleConsumeLocalBlocksFetchedTotal#3779L, shuffleConsumeTotalBlocksFetchedTotal#3780L, shuffleConsumeRemoteBytesReadTotal#3781L, shuffleConsumeLocalBytesReadTotal#3782L, shuffleConsumeTotalBytesReadTotal#3783L, shuffleConsumeRemoteBytesReadToDiskTotal#3784L, shuffleConsumeFetchWaitTimeTotal#3785L, shuffleProduceBytesWrittenTotal#3786L, shuffleProduceRecordsWrittenTotal#3787L, shuffleProduceWriteTimeTotal#3788L, peakExecutionMemory#3790L, peakExecutionMemoryCliqueDuration#3791L, peakExecutionMemoryCliqueSize#3792L, rddStorageDiskSizeTotal#3794L, rddStorageMemSizeTotal#3795L, rddNumCachedPartitionsTotal#3796, rddNumPartitionsTotal#3797, numberOfExecutors#3798, replenishmentRunId#3801L, tenantId#3802, cornerstoneTenantId#3803L, marketUnit#3804, scenario#3805, activityId#3806, activityType#3807, workflowType#3808, workflowId#3809, activityAttempt#3810, gitCommitId#3812]
(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#3807], 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#3716, stageCount#3717L, totalTaskCount#3718L, minTaskCountPerStage#3719L, maxTaskCountPerStage#3720L, medianTaskCountPerStage#3721L, bytesSpilledToDiskSerializedTotal#3722L, bytesSpilledToDiskSerializedMin#3723L, bytesSpilledToDiskSerializedMax#3724L, bytesSpilledToDiskSerializedMedian#3725L, taskCpuTimeTotal#3726L, taskCpuTimeMin#3727L, taskCpuTimeMax#3728L, taskCpuTimeMedian#3729L, taskDeserializeCpuTimeTotal#3730L, taskDeserializeCpuTimeMin#3731L, taskDeserializeCpuTimeMax#3732L, taskDeserializeCpuTimeMedian#3733L, taskDeserializeTimeTotal#3734L, taskDeserializeTimeMin#3735L, taskDeserializeTimeMax#3736L, taskDeserializeTimeMedian#3737L, taskRunTimeTotal#3738L, taskRunTimeMin#3739L, taskRunTimeMax#3740L, taskRunTimeMedian#3741L, jvmGcTimeTotal#3742L, jvmGcTimeMin#3743L, jvmGcTimeMax#3744L, jvmGcTimeMedian#3745L, bytesSpilledToDiskRawTotal#3746L, bytesSpilledToDiskRawMin#3747L, bytesSpilledToDiskRawMax#3748L, bytesSpilledToDiskRawMedian#3749L, resultSerializationTimeTotal#3750L, resultSerializationTimeMin#3751L, resultSerializationTimeMax#3752L, resultSerializationTimeMedian#3753L, resultSizeToDriverTotal#3754L, resultSizeToDriverMin#3755L, resultSizeToDriverMax#3756L, resultSizeToDriverMedian#3757L, taskPeakExecutionMemoryMin#3758L, taskPeakExecutionMemoryMax#3759L, taskPeakExecutionMemoryMedian#3760L, persistencyBytesReadTotal#3761L, persistencyBytesReadMin#3762L, persistencyBytesReadMax#3763L, persistencyBytesReadMedian#3764L, persistencyRecordsReadTotal#3765L, persistencyRecordsReadMin#3766L, persistencyRecordsReadMax#3767L, persistencyRecordsReadMedian#3768L, persistencyBytesWrittenTotal#3769L, persistencyBytesWrittenMin#3770L, persistencyBytesWrittenMax#3771L, persistencyBytesWrittenMedian#3772L, persistencyRecordsWrittenTotal#3773L, persistencyRecordsWrittenMin#3774L, persistencyRecordsWrittenMax#3775L, persistencyRecordsWrittenMedian#3776L, shuffleConsumeRecordsReadTotal#3777L, shuffleConsumeRemoteBlocksFetchedTotal#3778L, shuffleConsumeLocalBlocksFetchedTotal#3779L, shuffleConsumeTotalBlocksFetchedTotal#3780L, shuffleConsumeRemoteBytesReadTotal#3781L, shuffleConsumeLocalBytesReadTotal#3782L, shuffleConsumeTotalBytesReadTotal#3783L, shuffleConsumeRemoteBytesReadToDiskTotal#3784L, shuffleConsumeFetchWaitTimeTotal#3785L, shuffleProduceBytesWrittenTotal#3786L, shuffleProduceRecordsWrittenTotal#3787L, shuffleProduceWriteTimeTotal#3788L]
Arguments: [jobId#3716 ASC NULLS FIRST], false, 0
(29) Sort
Input [4]: [jobId#3789, peakExecutionMemory#3790L, peakExecutionMemoryCliqueDuration#3791L, peakExecutionMemoryCliqueSize#3792L]
Arguments: [jobId#3789 ASC NULLS FIRST], false, 0
(30) SortMergeJoin
Left keys [1]: [jobId#3716]
Right keys [1]: [jobId#3789]
Join type: FullOuter
Join condition: None
(31) Project
Output [76]: [coalesce(jobId#3716, jobId#3789) AS jobId#3799, stageCount#3717L, totalTaskCount#3718L, minTaskCountPerStage#3719L, maxTaskCountPerStage#3720L, medianTaskCountPerStage#3721L, bytesSpilledToDiskSerializedTotal#3722L, bytesSpilledToDiskSerializedMin#3723L, bytesSpilledToDiskSerializedMax#3724L, bytesSpilledToDiskSerializedMedian#3725L, taskCpuTimeTotal#3726L, taskCpuTimeMin#3727L, taskCpuTimeMax#3728L, taskCpuTimeMedian#3729L, taskDeserializeCpuTimeTotal#3730L, taskDeserializeCpuTimeMin#3731L, taskDeserializeCpuTimeMax#3732L, taskDeserializeCpuTimeMedian#3733L, taskDeserializeTimeTotal#3734L, taskDeserializeTimeMin#3735L, taskDeserializeTimeMax#3736L, taskDeserializeTimeMedian#3737L, taskRunTimeTotal#3738L, taskRunTimeMin#3739L, taskRunTimeMax#3740L, taskRunTimeMedian#3741L, jvmGcTimeTotal#3742L, jvmGcTimeMin#3743L, jvmGcTimeMax#3744L, jvmGcTimeMedian#3745L, bytesSpilledToDiskRawTotal#3746L, bytesSpilledToDiskRawMin#3747L, bytesSpilledToDiskRawMax#3748L, bytesSpilledToDiskRawMedian#3749L, resultSerializationTimeTotal#3750L, resultSerializationTimeMin#3751L, resultSerializationTimeMax#3752L, resultSerializationTimeMedian#3753L, resultSizeToDriverTotal#3754L, resultSizeToDriverMin#3755L, resultSizeToDriverMax#3756L, resultSizeToDriverMedian#3757L, taskPeakExecutionMemoryMin#3758L, taskPeakExecutionMemoryMax#3759L, taskPeakExecutionMemoryMedian#3760L, persistencyBytesReadTotal#3761L, persistencyBytesReadMin#3762L, persistencyBytesReadMax#3763L, persistencyBytesReadMedian#3764L, persistencyRecordsReadTotal#3765L, persistencyRecordsReadMin#3766L, persistencyRecordsReadMax#3767L, persistencyRecordsReadMedian#3768L, persistencyBytesWrittenTotal#3769L, persistencyBytesWrittenMin#3770L, persistencyBytesWrittenMax#3771L, persistencyBytesWrittenMedian#3772L, persistencyRecordsWrittenTotal#3773L, persistencyRecordsWrittenMin#3774L, persistencyRecordsWrittenMax#3775L, persistencyRecordsWrittenMedian#3776L, shuffleConsumeRecordsReadTotal#3777L, shuffleConsumeRemoteBlocksFetchedTotal#3778L, shuffleConsumeLocalBlocksFetchedTotal#3779L, shuffleConsumeTotalBlocksFetchedTotal#3780L, shuffleConsumeRemoteBytesReadTotal#3781L, shuffleConsumeLocalBytesReadTotal#3782L, shuffleConsumeTotalBytesReadTotal#3783L, shuffleConsumeRemoteBytesReadToDiskTotal#3784L, shuffleConsumeFetchWaitTimeTotal#3785L, shuffleProduceBytesWrittenTotal#3786L, shuffleProduceRecordsWrittenTotal#3787L, shuffleProduceWriteTimeTotal#3788L, peakExecutionMemory#3790L, peakExecutionMemoryCliqueDuration#3791L, peakExecutionMemoryCliqueSize#3792L]
Input [77]: [jobId#3716, stageCount#3717L, totalTaskCount#3718L, minTaskCountPerStage#3719L, maxTaskCountPerStage#3720L, medianTaskCountPerStage#3721L, bytesSpilledToDiskSerializedTotal#3722L, bytesSpilledToDiskSerializedMin#3723L, bytesSpilledToDiskSerializedMax#3724L, bytesSpilledToDiskSerializedMedian#3725L, taskCpuTimeTotal#3726L, taskCpuTimeMin#3727L, taskCpuTimeMax#3728L, taskCpuTimeMedian#3729L, taskDeserializeCpuTimeTotal#3730L, taskDeserializeCpuTimeMin#3731L, taskDeserializeCpuTimeMax#3732L, taskDeserializeCpuTimeMedian#3733L, taskDeserializeTimeTotal#3734L, taskDeserializeTimeMin#3735L, taskDeserializeTimeMax#3736L, taskDeserializeTimeMedian#3737L, taskRunTimeTotal#3738L, taskRunTimeMin#3739L, taskRunTimeMax#3740L, taskRunTimeMedian#3741L, jvmGcTimeTotal#3742L, jvmGcTimeMin#3743L, jvmGcTimeMax#3744L, jvmGcTimeMedian#3745L, bytesSpilledToDiskRawTotal#3746L, bytesSpilledToDiskRawMin#3747L, bytesSpilledToDiskRawMax#3748L, bytesSpilledToDiskRawMedian#3749L, resultSerializationTimeTotal#3750L, resultSerializationTimeMin#3751L, resultSerializationTimeMax#3752L, resultSerializationTimeMedian#3753L, resultSizeToDriverTotal#3754L, resultSizeToDriverMin#3755L, resultSizeToDriverMax#3756L, resultSizeToDriverMedian#3757L, taskPeakExecutionMemoryMin#3758L, taskPeakExecutionMemoryMax#3759L, taskPeakExecutionMemoryMedian#3760L, persistencyBytesReadTotal#3761L, persistencyBytesReadMin#3762L, persistencyBytesReadMax#3763L, persistencyBytesReadMedian#3764L, persistencyRecordsReadTotal#3765L, persistencyRecordsReadMin#3766L, persistencyRecordsReadMax#3767L, persistencyRecordsReadMedian#3768L, persistencyBytesWrittenTotal#3769L, persistencyBytesWrittenMin#3770L, persistencyBytesWrittenMax#3771L, persistencyBytesWrittenMedian#3772L, persistencyRecordsWrittenTotal#3773L, persistencyRecordsWrittenMin#3774L, persistencyRecordsWrittenMax#3775L, persistencyRecordsWrittenMedian#3776L, shuffleConsumeRecordsReadTotal#3777L, shuffleConsumeRemoteBlocksFetchedTotal#3778L, shuffleConsumeLocalBlocksFetchedTotal#3779L, shuffleConsumeTotalBlocksFetchedTotal#3780L, shuffleConsumeRemoteBytesReadTotal#3781L, shuffleConsumeLocalBytesReadTotal#3782L, shuffleConsumeTotalBytesReadTotal#3783L, shuffleConsumeRemoteBytesReadToDiskTotal#3784L, shuffleConsumeFetchWaitTimeTotal#3785L, shuffleProduceBytesWrittenTotal#3786L, shuffleProduceRecordsWrittenTotal#3787L, shuffleProduceWriteTimeTotal#3788L, jobId#3789, peakExecutionMemory#3790L, peakExecutionMemoryCliqueDuration#3791L, peakExecutionMemoryCliqueSize#3792L]
(32) Exchange
Input [76]: [jobId#3799, stageCount#3717L, totalTaskCount#3718L, minTaskCountPerStage#3719L, maxTaskCountPerStage#3720L, medianTaskCountPerStage#3721L, bytesSpilledToDiskSerializedTotal#3722L, bytesSpilledToDiskSerializedMin#3723L, bytesSpilledToDiskSerializedMax#3724L, bytesSpilledToDiskSerializedMedian#3725L, taskCpuTimeTotal#3726L, taskCpuTimeMin#3727L, taskCpuTimeMax#3728L, taskCpuTimeMedian#3729L, taskDeserializeCpuTimeTotal#3730L, taskDeserializeCpuTimeMin#3731L, taskDeserializeCpuTimeMax#3732L, taskDeserializeCpuTimeMedian#3733L, taskDeserializeTimeTotal#3734L, taskDeserializeTimeMin#3735L, taskDeserializeTimeMax#3736L, taskDeserializeTimeMedian#3737L, taskRunTimeTotal#3738L, taskRunTimeMin#3739L, taskRunTimeMax#3740L, taskRunTimeMedian#3741L, jvmGcTimeTotal#3742L, jvmGcTimeMin#3743L, jvmGcTimeMax#3744L, jvmGcTimeMedian#3745L, bytesSpilledToDiskRawTotal#3746L, bytesSpilledToDiskRawMin#3747L, bytesSpilledToDiskRawMax#3748L, bytesSpilledToDiskRawMedian#3749L, resultSerializationTimeTotal#3750L, resultSerializationTimeMin#3751L, resultSerializationTimeMax#3752L, resultSerializationTimeMedian#3753L, resultSizeToDriverTotal#3754L, resultSizeToDriverMin#3755L, resultSizeToDriverMax#3756L, resultSizeToDriverMedian#3757L, taskPeakExecutionMemoryMin#3758L, taskPeakExecutionMemoryMax#3759L, taskPeakExecutionMemoryMedian#3760L, persistencyBytesReadTotal#3761L, persistencyBytesReadMin#3762L, persistencyBytesReadMax#3763L, persistencyBytesReadMedian#3764L, persistencyRecordsReadTotal#3765L, persistencyRecordsReadMin#3766L, persistencyRecordsReadMax#3767L, persistencyRecordsReadMedian#3768L, persistencyBytesWrittenTotal#3769L, persistencyBytesWrittenMin#3770L, persistencyBytesWrittenMax#3771L, persistencyBytesWrittenMedian#3772L, persistencyRecordsWrittenTotal#3773L, persistencyRecordsWrittenMin#3774L, persistencyRecordsWrittenMax#3775L, persistencyRecordsWrittenMedian#3776L, shuffleConsumeRecordsReadTotal#3777L, shuffleConsumeRemoteBlocksFetchedTotal#3778L, shuffleConsumeLocalBlocksFetchedTotal#3779L, shuffleConsumeTotalBlocksFetchedTotal#3780L, shuffleConsumeRemoteBytesReadTotal#3781L, shuffleConsumeLocalBytesReadTotal#3782L, shuffleConsumeTotalBytesReadTotal#3783L, shuffleConsumeRemoteBytesReadToDiskTotal#3784L, shuffleConsumeFetchWaitTimeTotal#3785L, shuffleProduceBytesWrittenTotal#3786L, shuffleProduceRecordsWrittenTotal#3787L, shuffleProduceWriteTimeTotal#3788L, peakExecutionMemory#3790L, peakExecutionMemoryCliqueDuration#3791L, peakExecutionMemoryCliqueSize#3792L]
Arguments: hashpartitioning(jobId#3799, 200), ENSURE_REQUIREMENTS, [plan_id=4830]
(33) Sort
Input [76]: [jobId#3799, stageCount#3717L, totalTaskCount#3718L, minTaskCountPerStage#3719L, maxTaskCountPerStage#3720L, medianTaskCountPerStage#3721L, bytesSpilledToDiskSerializedTotal#3722L, bytesSpilledToDiskSerializedMin#3723L, bytesSpilledToDiskSerializedMax#3724L, bytesSpilledToDiskSerializedMedian#3725L, taskCpuTimeTotal#3726L, taskCpuTimeMin#3727L, taskCpuTimeMax#3728L, taskCpuTimeMedian#3729L, taskDeserializeCpuTimeTotal#3730L, taskDeserializeCpuTimeMin#3731L, taskDeserializeCpuTimeMax#3732L, taskDeserializeCpuTimeMedian#3733L, taskDeserializeTimeTotal#3734L, taskDeserializeTimeMin#3735L, taskDeserializeTimeMax#3736L, taskDeserializeTimeMedian#3737L, taskRunTimeTotal#3738L, taskRunTimeMin#3739L, taskRunTimeMax#3740L, taskRunTimeMedian#3741L, jvmGcTimeTotal#3742L, jvmGcTimeMin#3743L, jvmGcTimeMax#3744L, jvmGcTimeMedian#3745L, bytesSpilledToDiskRawTotal#3746L, bytesSpilledToDiskRawMin#3747L, bytesSpilledToDiskRawMax#3748L, bytesSpilledToDiskRawMedian#3749L, resultSerializationTimeTotal#3750L, resultSerializationTimeMin#3751L, resultSerializationTimeMax#3752L, resultSerializationTimeMedian#3753L, resultSizeToDriverTotal#3754L, resultSizeToDriverMin#3755L, resultSizeToDriverMax#3756L, resultSizeToDriverMedian#3757L, taskPeakExecutionMemoryMin#3758L, taskPeakExecutionMemoryMax#3759L, taskPeakExecutionMemoryMedian#3760L, persistencyBytesReadTotal#3761L, persistencyBytesReadMin#3762L, persistencyBytesReadMax#3763L, persistencyBytesReadMedian#3764L, persistencyRecordsReadTotal#3765L, persistencyRecordsReadMin#3766L, persistencyRecordsReadMax#3767L, persistencyRecordsReadMedian#3768L, persistencyBytesWrittenTotal#3769L, persistencyBytesWrittenMin#3770L, persistencyBytesWrittenMax#3771L, persistencyBytesWrittenMedian#3772L, persistencyRecordsWrittenTotal#3773L, persistencyRecordsWrittenMin#3774L, persistencyRecordsWrittenMax#3775L, persistencyRecordsWrittenMedian#3776L, shuffleConsumeRecordsReadTotal#3777L, shuffleConsumeRemoteBlocksFetchedTotal#3778L, shuffleConsumeLocalBlocksFetchedTotal#3779L, shuffleConsumeTotalBlocksFetchedTotal#3780L, shuffleConsumeRemoteBytesReadTotal#3781L, shuffleConsumeLocalBytesReadTotal#3782L, shuffleConsumeTotalBytesReadTotal#3783L, shuffleConsumeRemoteBytesReadToDiskTotal#3784L, shuffleConsumeFetchWaitTimeTotal#3785L, shuffleProduceBytesWrittenTotal#3786L, shuffleProduceRecordsWrittenTotal#3787L, shuffleProduceWriteTimeTotal#3788L, peakExecutionMemory#3790L, peakExecutionMemoryCliqueDuration#3791L, peakExecutionMemoryCliqueSize#3792L]
Arguments: [jobId#3799 ASC NULLS FIRST], false, 0
(34) Sort
Input [6]: [jobId#3793, rddStorageDiskSizeTotal#3794L, rddStorageMemSizeTotal#3795L, rddNumCachedPartitionsTotal#3796, rddNumPartitionsTotal#3797, numberOfExecutors#3798]
Arguments: [jobId#3793 ASC NULLS FIRST], false, 0
(35) SortMergeJoin
Left keys [1]: [jobId#3799]
Right keys [1]: [jobId#3793]
Join type: FullOuter
Join condition: None
(36) Project
Output [92]: [coalesce(jobId#3799, jobId#3793) AS jobId#3800, stageCount#3717L, totalTaskCount#3718L, minTaskCountPerStage#3719L, maxTaskCountPerStage#3720L, medianTaskCountPerStage#3721L, bytesSpilledToDiskSerializedTotal#3722L, bytesSpilledToDiskSerializedMin#3723L, bytesSpilledToDiskSerializedMax#3724L, bytesSpilledToDiskSerializedMedian#3725L, taskCpuTimeTotal#3726L, taskCpuTimeMin#3727L, taskCpuTimeMax#3728L, taskCpuTimeMedian#3729L, taskDeserializeCpuTimeTotal#3730L, taskDeserializeCpuTimeMin#3731L, taskDeserializeCpuTimeMax#3732L, taskDeserializeCpuTimeMedian#3733L, taskDeserializeTimeTotal#3734L, taskDeserializeTimeMin#3735L, taskDeserializeTimeMax#3736L, taskDeserializeTimeMedian#3737L, taskRunTimeTotal#3738L, taskRunTimeMin#3739L, taskRunTimeMax#3740L, taskRunTimeMedian#3741L, jvmGcTimeTotal#3742L, jvmGcTimeMin#3743L, jvmGcTimeMax#3744L, jvmGcTimeMedian#3745L, bytesSpilledToDiskRawTotal#3746L, bytesSpilledToDiskRawMin#3747L, bytesSpilledToDiskRawMax#3748L, bytesSpilledToDiskRawMedian#3749L, resultSerializationTimeTotal#3750L, resultSerializationTimeMin#3751L, resultSerializationTimeMax#3752L, resultSerializationTimeMedian#3753L, resultSizeToDriverTotal#3754L, resultSizeToDriverMin#3755L, resultSizeToDriverMax#3756L, resultSizeToDriverMedian#3757L, taskPeakExecutionMemoryMin#3758L, taskPeakExecutionMemoryMax#3759L, taskPeakExecutionMemoryMedian#3760L, persistencyBytesReadTotal#3761L, persistencyBytesReadMin#3762L, persistencyBytesReadMax#3763L, persistencyBytesReadMedian#3764L, persistencyRecordsReadTotal#3765L, persistencyRecordsReadMin#3766L, persistencyRecordsReadMax#3767L, persistencyRecordsReadMedian#3768L, persistencyBytesWrittenTotal#3769L, persistencyBytesWrittenMin#3770L, persistencyBytesWrittenMax#3771L, persistencyBytesWrittenMedian#3772L, persistencyRecordsWrittenTotal#3773L, persistencyRecordsWrittenMin#3774L, persistencyRecordsWrittenMax#3775L, persistencyRecordsWrittenMedian#3776L, shuffleConsumeRecordsReadTotal#3777L, shuffleConsumeRemoteBlocksFetchedTotal#3778L, shuffleConsumeLocalBlocksFetchedTotal#3779L, shuffleConsumeTotalBlocksFetchedTotal#3780L, shuffleConsumeRemoteBytesReadTotal#3781L, shuffleConsumeLocalBytesReadTotal#3782L, shuffleConsumeTotalBytesReadTotal#3783L, shuffleConsumeRemoteBytesReadToDiskTotal#3784L, shuffleConsumeFetchWaitTimeTotal#3785L, shuffleProduceBytesWrittenTotal#3786L, shuffleProduceRecordsWrittenTotal#3787L, shuffleProduceWriteTimeTotal#3788L, peakExecutionMemory#3790L, peakExecutionMemoryCliqueDuration#3791L, peakExecutionMemoryCliqueSize#3792L, rddStorageDiskSizeTotal#3794L, rddStorageMemSizeTotal#3795L, rddNumCachedPartitionsTotal#3796, rddNumPartitionsTotal#3797, numberOfExecutors#3798, 10000000003 AS replenishmentRunId#3801L, 5330363489248697092 AS tenantId#3802, 8495 AS cornerstoneTenantId#3803L, MU_PPP_1 AS marketUnit#3804, STANDARD AS scenario#3805, 88c42b3e-f7b7-3812-8b16-7aa86f5ce414 AS activityId#3806, DetermineWorkLoad AS activityType#3807, ReplenishmentRunWorkflow AS workflowType#3808, RP_SCH_5330363489248697092_5 AS workflowId#3809, 5 AS activityAttempt#3810, unknown GIT COMMIT AS gitCommitId#3812]
Input [82]: [jobId#3799, stageCount#3717L, totalTaskCount#3718L, minTaskCountPerStage#3719L, maxTaskCountPerStage#3720L, medianTaskCountPerStage#3721L, bytesSpilledToDiskSerializedTotal#3722L, bytesSpilledToDiskSerializedMin#3723L, bytesSpilledToDiskSerializedMax#3724L, bytesSpilledToDiskSerializedMedian#3725L, taskCpuTimeTotal#3726L, taskCpuTimeMin#3727L, taskCpuTimeMax#3728L, taskCpuTimeMedian#3729L, taskDeserializeCpuTimeTotal#3730L, taskDeserializeCpuTimeMin#3731L, taskDeserializeCpuTimeMax#3732L, taskDeserializeCpuTimeMedian#3733L, taskDeserializeTimeTotal#3734L, taskDeserializeTimeMin#3735L, taskDeserializeTimeMax#3736L, taskDeserializeTimeMedian#3737L, taskRunTimeTotal#3738L, taskRunTimeMin#3739L, taskRunTimeMax#3740L, taskRunTimeMedian#3741L, jvmGcTimeTotal#3742L, jvmGcTimeMin#3743L, jvmGcTimeMax#3744L, jvmGcTimeMedian#3745L, bytesSpilledToDiskRawTotal#3746L, bytesSpilledToDiskRawMin#3747L, bytesSpilledToDiskRawMax#3748L, bytesSpilledToDiskRawMedian#3749L, resultSerializationTimeTotal#3750L, resultSerializationTimeMin#3751L, resultSerializationTimeMax#3752L, resultSerializationTimeMedian#3753L, resultSizeToDriverTotal#3754L, resultSizeToDriverMin#3755L, resultSizeToDriverMax#3756L, resultSizeToDriverMedian#3757L, taskPeakExecutionMemoryMin#3758L, taskPeakExecutionMemoryMax#3759L, taskPeakExecutionMemoryMedian#3760L, persistencyBytesReadTotal#3761L, persistencyBytesReadMin#3762L, persistencyBytesReadMax#3763L, persistencyBytesReadMedian#3764L, persistencyRecordsReadTotal#3765L, persistencyRecordsReadMin#3766L, persistencyRecordsReadMax#3767L, persistencyRecordsReadMedian#3768L, persistencyBytesWrittenTotal#3769L, persistencyBytesWrittenMin#3770L, persistencyBytesWrittenMax#3771L, persistencyBytesWrittenMedian#3772L, persistencyRecordsWrittenTotal#3773L, persistencyRecordsWrittenMin#3774L, persistencyRecordsWrittenMax#3775L, persistencyRecordsWrittenMedian#3776L, shuffleConsumeRecordsReadTotal#3777L, shuffleConsumeRemoteBlocksFetchedTotal#3778L, shuffleConsumeLocalBlocksFetchedTotal#3779L, shuffleConsumeTotalBlocksFetchedTotal#3780L, shuffleConsumeRemoteBytesReadTotal#3781L, shuffleConsumeLocalBytesReadTotal#3782L, shuffleConsumeTotalBytesReadTotal#3783L, shuffleConsumeRemoteBytesReadToDiskTotal#3784L, shuffleConsumeFetchWaitTimeTotal#3785L, shuffleProduceBytesWrittenTotal#3786L, shuffleProduceRecordsWrittenTotal#3787L, shuffleProduceWriteTimeTotal#3788L, peakExecutionMemory#3790L, peakExecutionMemoryCliqueDuration#3791L, peakExecutionMemoryCliqueSize#3792L, jobId#3793, rddStorageDiskSizeTotal#3794L, rddStorageMemSizeTotal#3795L, rddNumCachedPartitionsTotal#3796, rddNumPartitionsTotal#3797, numberOfExecutors#3798]
(37) Sort
Input [92]: [jobId#3800, stageCount#3717L, totalTaskCount#3718L, minTaskCountPerStage#3719L, maxTaskCountPerStage#3720L, medianTaskCountPerStage#3721L, bytesSpilledToDiskSerializedTotal#3722L, bytesSpilledToDiskSerializedMin#3723L, bytesSpilledToDiskSerializedMax#3724L, bytesSpilledToDiskSerializedMedian#3725L, taskCpuTimeTotal#3726L, taskCpuTimeMin#3727L, taskCpuTimeMax#3728L, taskCpuTimeMedian#3729L, taskDeserializeCpuTimeTotal#3730L, taskDeserializeCpuTimeMin#3731L, taskDeserializeCpuTimeMax#3732L, taskDeserializeCpuTimeMedian#3733L, taskDeserializeTimeTotal#3734L, taskDeserializeTimeMin#3735L, taskDeserializeTimeMax#3736L, taskDeserializeTimeMedian#3737L, taskRunTimeTotal#3738L, taskRunTimeMin#3739L, taskRunTimeMax#3740L, taskRunTimeMedian#3741L, jvmGcTimeTotal#3742L, jvmGcTimeMin#3743L, jvmGcTimeMax#3744L, jvmGcTimeMedian#3745L, bytesSpilledToDiskRawTotal#3746L, bytesSpilledToDiskRawMin#3747L, bytesSpilledToDiskRawMax#3748L, bytesSpilledToDiskRawMedian#3749L, resultSerializationTimeTotal#3750L, resultSerializationTimeMin#3751L, resultSerializationTimeMax#3752L, resultSerializationTimeMedian#3753L, resultSizeToDriverTotal#3754L, resultSizeToDriverMin#3755L, resultSizeToDriverMax#3756L, resultSizeToDriverMedian#3757L, taskPeakExecutionMemoryMin#3758L, taskPeakExecutionMemoryMax#3759L, taskPeakExecutionMemoryMedian#3760L, persistencyBytesReadTotal#3761L, persistencyBytesReadMin#3762L, persistencyBytesReadMax#3763L, persistencyBytesReadMedian#3764L, persistencyRecordsReadTotal#3765L, persistencyRecordsReadMin#3766L, persistencyRecordsReadMax#3767L, persistencyRecordsReadMedian#3768L, persistencyBytesWrittenTotal#3769L, persistencyBytesWrittenMin#3770L, persistencyBytesWrittenMax#3771L, persistencyBytesWrittenMedian#3772L, persistencyRecordsWrittenTotal#3773L, persistencyRecordsWrittenMin#3774L, persistencyRecordsWrittenMax#3775L, persistencyRecordsWrittenMedian#3776L, shuffleConsumeRecordsReadTotal#3777L, shuffleConsumeRemoteBlocksFetchedTotal#3778L, shuffleConsumeLocalBlocksFetchedTotal#3779L, shuffleConsumeTotalBlocksFetchedTotal#3780L, shuffleConsumeRemoteBytesReadTotal#3781L, shuffleConsumeLocalBytesReadTotal#3782L, shuffleConsumeTotalBytesReadTotal#3783L, shuffleConsumeRemoteBytesReadToDiskTotal#3784L, shuffleConsumeFetchWaitTimeTotal#3785L, shuffleProduceBytesWrittenTotal#3786L, shuffleProduceRecordsWrittenTotal#3787L, shuffleProduceWriteTimeTotal#3788L, peakExecutionMemory#3790L, peakExecutionMemoryCliqueDuration#3791L, peakExecutionMemoryCliqueSize#3792L, rddStorageDiskSizeTotal#3794L, rddStorageMemSizeTotal#3795L, rddNumCachedPartitionsTotal#3796, rddNumPartitionsTotal#3797, numberOfExecutors#3798, replenishmentRunId#3801L, tenantId#3802, cornerstoneTenantId#3803L, marketUnit#3804, scenario#3805, activityId#3806, activityType#3807, workflowType#3808, workflowId#3809, activityAttempt#3810, gitCommitId#3812]
Arguments: [activityType#3807 ASC NULLS FIRST], false, 0
(38) WriteFiles
Input [92]: [jobId#3800, stageCount#3717L, totalTaskCount#3718L, minTaskCountPerStage#3719L, maxTaskCountPerStage#3720L, medianTaskCountPerStage#3721L, bytesSpilledToDiskSerializedTotal#3722L, bytesSpilledToDiskSerializedMin#3723L, bytesSpilledToDiskSerializedMax#3724L, bytesSpilledToDiskSerializedMedian#3725L, taskCpuTimeTotal#3726L, taskCpuTimeMin#3727L, taskCpuTimeMax#3728L, taskCpuTimeMedian#3729L, taskDeserializeCpuTimeTotal#3730L, taskDeserializeCpuTimeMin#3731L, taskDeserializeCpuTimeMax#3732L, taskDeserializeCpuTimeMedian#3733L, taskDeserializeTimeTotal#3734L, taskDeserializeTimeMin#3735L, taskDeserializeTimeMax#3736L, taskDeserializeTimeMedian#3737L, taskRunTimeTotal#3738L, taskRunTimeMin#3739L, taskRunTimeMax#3740L, taskRunTimeMedian#3741L, jvmGcTimeTotal#3742L, jvmGcTimeMin#3743L, jvmGcTimeMax#3744L, jvmGcTimeMedian#3745L, bytesSpilledToDiskRawTotal#3746L, bytesSpilledToDiskRawMin#3747L, bytesSpilledToDiskRawMax#3748L, bytesSpilledToDiskRawMedian#3749L, resultSerializationTimeTotal#3750L, resultSerializationTimeMin#3751L, resultSerializationTimeMax#3752L, resultSerializationTimeMedian#3753L, resultSizeToDriverTotal#3754L, resultSizeToDriverMin#3755L, resultSizeToDriverMax#3756L, resultSizeToDriverMedian#3757L, taskPeakExecutionMemoryMin#3758L, taskPeakExecutionMemoryMax#3759L, taskPeakExecutionMemoryMedian#3760L, persistencyBytesReadTotal#3761L, persistencyBytesReadMin#3762L, persistencyBytesReadMax#3763L, persistencyBytesReadMedian#3764L, persistencyRecordsReadTotal#3765L, persistencyRecordsReadMin#3766L, persistencyRecordsReadMax#3767L, persistencyRecordsReadMedian#3768L, persistencyBytesWrittenTotal#3769L, persistencyBytesWrittenMin#3770L, persistencyBytesWrittenMax#3771L, persistencyBytesWrittenMedian#3772L, persistencyRecordsWrittenTotal#3773L, persistencyRecordsWrittenMin#3774L, persistencyRecordsWrittenMax#3775L, persistencyRecordsWrittenMedian#3776L, shuffleConsumeRecordsReadTotal#3777L, shuffleConsumeRemoteBlocksFetchedTotal#3778L, shuffleConsumeLocalBlocksFetchedTotal#3779L, shuffleConsumeTotalBlocksFetchedTotal#3780L, shuffleConsumeRemoteBytesReadTotal#3781L, shuffleConsumeLocalBytesReadTotal#3782L, shuffleConsumeTotalBytesReadTotal#3783L, shuffleConsumeRemoteBytesReadToDiskTotal#3784L, shuffleConsumeFetchWaitTimeTotal#3785L, shuffleProduceBytesWrittenTotal#3786L, shuffleProduceRecordsWrittenTotal#3787L, shuffleProduceWriteTimeTotal#3788L, peakExecutionMemory#3790L, peakExecutionMemoryCliqueDuration#3791L, peakExecutionMemoryCliqueSize#3792L, rddStorageDiskSizeTotal#3794L, rddStorageMemSizeTotal#3795L, rddNumCachedPartitionsTotal#3796, rddNumPartitionsTotal#3797, numberOfExecutors#3798, replenishmentRunId#3801L, tenantId#3802, cornerstoneTenantId#3803L, marketUnit#3804, scenario#3805, activityId#3806, activityType#3807, workflowType#3808, workflowId#3809, activityAttempt#3810, gitCommitId#3812]
(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#3807], 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