== 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=15.4 KiB, rowCount=25)
: +- Exchange (13)
: +- * Project (12)
: +- * SortMergeJoin FullOuter (11)
: :- * Sort (5)
: : +- AQEShuffleRead (4)
: : +- ShuffleQueryStage (3), Statistics(sizeInBytes=14.8 KiB, rowCount=25)
: : +- Exchange (2)
: : +- LocalTableScan (1)
: +- * Sort (10)
: +- AQEShuffleRead (9)
: +- ShuffleQueryStage (8), Statistics(sizeInBytes=1200.0 B, rowCount=25)
: +- Exchange (7)
: +- LocalTableScan (6)
+- * Sort (21)
+- AQEShuffleRead (20)
+- ShuffleQueryStage (19), Statistics(sizeInBytes=1600.0 B, rowCount=25)
+- 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#12194, stageCount#12195L, totalTaskCount#12196L, minTaskCountPerStage#12197L, maxTaskCountPerStage#12198L, medianTaskCountPerStage#12199L, bytesSpilledToDiskSerializedTotal#12200L, bytesSpilledToDiskSerializedMin#12201L, bytesSpilledToDiskSerializedMax#12202L, bytesSpilledToDiskSerializedMedian#12203L, taskCpuTimeTotal#12204L, taskCpuTimeMin#12205L, taskCpuTimeMax#12206L, taskCpuTimeMedian#12207L, taskDeserializeCpuTimeTotal#12208L, taskDeserializeCpuTimeMin#12209L, taskDeserializeCpuTimeMax#12210L, taskDeserializeCpuTimeMedian#12211L, taskDeserializeTimeTotal#12212L, taskDeserializeTimeMin#12213L, taskDeserializeTimeMax#12214L, taskDeserializeTimeMedian#12215L, taskRunTimeTotal#12216L, taskRunTimeMin#12217L, taskRunTimeMax#12218L, taskRunTimeMedian#12219L, jvmGcTimeTotal#12220L, jvmGcTimeMin#12221L, jvmGcTimeMax#12222L, jvmGcTimeMedian#12223L, bytesSpilledToDiskRawTotal#12224L, bytesSpilledToDiskRawMin#12225L, bytesSpilledToDiskRawMax#12226L, bytesSpilledToDiskRawMedian#12227L, resultSerializationTimeTotal#12228L, resultSerializationTimeMin#12229L, resultSerializationTimeMax#12230L, resultSerializationTimeMedian#12231L, resultSizeToDriverTotal#12232L, resultSizeToDriverMin#12233L, resultSizeToDriverMax#12234L, resultSizeToDriverMedian#12235L, taskPeakExecutionMemoryMin#12236L, taskPeakExecutionMemoryMax#12237L, taskPeakExecutionMemoryMedian#12238L, persistencyBytesReadTotal#12239L, persistencyBytesReadMin#12240L, persistencyBytesReadMax#12241L, persistencyBytesReadMedian#12242L, persistencyRecordsReadTotal#12243L, persistencyRecordsReadMin#12244L, persistencyRecordsReadMax#12245L, persistencyRecordsReadMedian#12246L, persistencyBytesWrittenTotal#12247L, persistencyBytesWrittenMin#12248L, persistencyBytesWrittenMax#12249L, persistencyBytesWrittenMedian#12250L, persistencyRecordsWrittenTotal#12251L, persistencyRecordsWrittenMin#12252L, persistencyRecordsWrittenMax#12253L, persistencyRecordsWrittenMedian#12254L, shuffleConsumeRecordsReadTotal#12255L, shuffleConsumeRemoteBlocksFetchedTotal#12256L, shuffleConsumeLocalBlocksFetchedTotal#12257L, shuffleConsumeTotalBlocksFetchedTotal#12258L, shuffleConsumeRemoteBytesReadTotal#12259L, shuffleConsumeLocalBytesReadTotal#12260L, shuffleConsumeTotalBytesReadTotal#12261L, shuffleConsumeRemoteBytesReadToDiskTotal#12262L, shuffleConsumeFetchWaitTimeTotal#12263L, shuffleProduceBytesWrittenTotal#12264L, shuffleProduceRecordsWrittenTotal#12265L, shuffleProduceWriteTimeTotal#12266L]
Arguments: [jobId#12194, stageCount#12195L, totalTaskCount#12196L, minTaskCountPerStage#12197L, maxTaskCountPerStage#12198L, medianTaskCountPerStage#12199L, bytesSpilledToDiskSerializedTotal#12200L, bytesSpilledToDiskSerializedMin#12201L, bytesSpilledToDiskSerializedMax#12202L, bytesSpilledToDiskSerializedMedian#12203L, taskCpuTimeTotal#12204L, taskCpuTimeMin#12205L, taskCpuTimeMax#12206L, taskCpuTimeMedian#12207L, taskDeserializeCpuTimeTotal#12208L, taskDeserializeCpuTimeMin#12209L, taskDeserializeCpuTimeMax#12210L, taskDeserializeCpuTimeMedian#12211L, taskDeserializeTimeTotal#12212L, taskDeserializeTimeMin#12213L, taskDeserializeTimeMax#12214L, taskDeserializeTimeMedian#12215L, taskRunTimeTotal#12216L, taskRunTimeMin#12217L, taskRunTimeMax#12218L, ... 48 more fields]
(2) Exchange
Input [73]: [jobId#12194, stageCount#12195L, totalTaskCount#12196L, minTaskCountPerStage#12197L, maxTaskCountPerStage#12198L, medianTaskCountPerStage#12199L, bytesSpilledToDiskSerializedTotal#12200L, bytesSpilledToDiskSerializedMin#12201L, bytesSpilledToDiskSerializedMax#12202L, bytesSpilledToDiskSerializedMedian#12203L, taskCpuTimeTotal#12204L, taskCpuTimeMin#12205L, taskCpuTimeMax#12206L, taskCpuTimeMedian#12207L, taskDeserializeCpuTimeTotal#12208L, taskDeserializeCpuTimeMin#12209L, taskDeserializeCpuTimeMax#12210L, taskDeserializeCpuTimeMedian#12211L, taskDeserializeTimeTotal#12212L, taskDeserializeTimeMin#12213L, taskDeserializeTimeMax#12214L, taskDeserializeTimeMedian#12215L, taskRunTimeTotal#12216L, taskRunTimeMin#12217L, taskRunTimeMax#12218L, taskRunTimeMedian#12219L, jvmGcTimeTotal#12220L, jvmGcTimeMin#12221L, jvmGcTimeMax#12222L, jvmGcTimeMedian#12223L, bytesSpilledToDiskRawTotal#12224L, bytesSpilledToDiskRawMin#12225L, bytesSpilledToDiskRawMax#12226L, bytesSpilledToDiskRawMedian#12227L, resultSerializationTimeTotal#12228L, resultSerializationTimeMin#12229L, resultSerializationTimeMax#12230L, resultSerializationTimeMedian#12231L, resultSizeToDriverTotal#12232L, resultSizeToDriverMin#12233L, resultSizeToDriverMax#12234L, resultSizeToDriverMedian#12235L, taskPeakExecutionMemoryMin#12236L, taskPeakExecutionMemoryMax#12237L, taskPeakExecutionMemoryMedian#12238L, persistencyBytesReadTotal#12239L, persistencyBytesReadMin#12240L, persistencyBytesReadMax#12241L, persistencyBytesReadMedian#12242L, persistencyRecordsReadTotal#12243L, persistencyRecordsReadMin#12244L, persistencyRecordsReadMax#12245L, persistencyRecordsReadMedian#12246L, persistencyBytesWrittenTotal#12247L, persistencyBytesWrittenMin#12248L, persistencyBytesWrittenMax#12249L, persistencyBytesWrittenMedian#12250L, persistencyRecordsWrittenTotal#12251L, persistencyRecordsWrittenMin#12252L, persistencyRecordsWrittenMax#12253L, persistencyRecordsWrittenMedian#12254L, shuffleConsumeRecordsReadTotal#12255L, shuffleConsumeRemoteBlocksFetchedTotal#12256L, shuffleConsumeLocalBlocksFetchedTotal#12257L, shuffleConsumeTotalBlocksFetchedTotal#12258L, shuffleConsumeRemoteBytesReadTotal#12259L, shuffleConsumeLocalBytesReadTotal#12260L, shuffleConsumeTotalBytesReadTotal#12261L, shuffleConsumeRemoteBytesReadToDiskTotal#12262L, shuffleConsumeFetchWaitTimeTotal#12263L, shuffleProduceBytesWrittenTotal#12264L, shuffleProduceRecordsWrittenTotal#12265L, shuffleProduceWriteTimeTotal#12266L]
Arguments: hashpartitioning(jobId#12194, 20), ENSURE_REQUIREMENTS, [plan_id=4453]
(3) ShuffleQueryStage
Output [73]: [jobId#12194, stageCount#12195L, totalTaskCount#12196L, minTaskCountPerStage#12197L, maxTaskCountPerStage#12198L, medianTaskCountPerStage#12199L, bytesSpilledToDiskSerializedTotal#12200L, bytesSpilledToDiskSerializedMin#12201L, bytesSpilledToDiskSerializedMax#12202L, bytesSpilledToDiskSerializedMedian#12203L, taskCpuTimeTotal#12204L, taskCpuTimeMin#12205L, taskCpuTimeMax#12206L, taskCpuTimeMedian#12207L, taskDeserializeCpuTimeTotal#12208L, taskDeserializeCpuTimeMin#12209L, taskDeserializeCpuTimeMax#12210L, taskDeserializeCpuTimeMedian#12211L, taskDeserializeTimeTotal#12212L, taskDeserializeTimeMin#12213L, taskDeserializeTimeMax#12214L, taskDeserializeTimeMedian#12215L, taskRunTimeTotal#12216L, taskRunTimeMin#12217L, taskRunTimeMax#12218L, taskRunTimeMedian#12219L, jvmGcTimeTotal#12220L, jvmGcTimeMin#12221L, jvmGcTimeMax#12222L, jvmGcTimeMedian#12223L, bytesSpilledToDiskRawTotal#12224L, bytesSpilledToDiskRawMin#12225L, bytesSpilledToDiskRawMax#12226L, bytesSpilledToDiskRawMedian#12227L, resultSerializationTimeTotal#12228L, resultSerializationTimeMin#12229L, resultSerializationTimeMax#12230L, resultSerializationTimeMedian#12231L, resultSizeToDriverTotal#12232L, resultSizeToDriverMin#12233L, resultSizeToDriverMax#12234L, resultSizeToDriverMedian#12235L, taskPeakExecutionMemoryMin#12236L, taskPeakExecutionMemoryMax#12237L, taskPeakExecutionMemoryMedian#12238L, persistencyBytesReadTotal#12239L, persistencyBytesReadMin#12240L, persistencyBytesReadMax#12241L, persistencyBytesReadMedian#12242L, persistencyRecordsReadTotal#12243L, persistencyRecordsReadMin#12244L, persistencyRecordsReadMax#12245L, persistencyRecordsReadMedian#12246L, persistencyBytesWrittenTotal#12247L, persistencyBytesWrittenMin#12248L, persistencyBytesWrittenMax#12249L, persistencyBytesWrittenMedian#12250L, persistencyRecordsWrittenTotal#12251L, persistencyRecordsWrittenMin#12252L, persistencyRecordsWrittenMax#12253L, persistencyRecordsWrittenMedian#12254L, shuffleConsumeRecordsReadTotal#12255L, shuffleConsumeRemoteBlocksFetchedTotal#12256L, shuffleConsumeLocalBlocksFetchedTotal#12257L, shuffleConsumeTotalBlocksFetchedTotal#12258L, shuffleConsumeRemoteBytesReadTotal#12259L, shuffleConsumeLocalBytesReadTotal#12260L, shuffleConsumeTotalBytesReadTotal#12261L, shuffleConsumeRemoteBytesReadToDiskTotal#12262L, shuffleConsumeFetchWaitTimeTotal#12263L, shuffleProduceBytesWrittenTotal#12264L, shuffleProduceRecordsWrittenTotal#12265L, shuffleProduceWriteTimeTotal#12266L]
Arguments: 0
(4) AQEShuffleRead
Input [73]: [jobId#12194, stageCount#12195L, totalTaskCount#12196L, minTaskCountPerStage#12197L, maxTaskCountPerStage#12198L, medianTaskCountPerStage#12199L, bytesSpilledToDiskSerializedTotal#12200L, bytesSpilledToDiskSerializedMin#12201L, bytesSpilledToDiskSerializedMax#12202L, bytesSpilledToDiskSerializedMedian#12203L, taskCpuTimeTotal#12204L, taskCpuTimeMin#12205L, taskCpuTimeMax#12206L, taskCpuTimeMedian#12207L, taskDeserializeCpuTimeTotal#12208L, taskDeserializeCpuTimeMin#12209L, taskDeserializeCpuTimeMax#12210L, taskDeserializeCpuTimeMedian#12211L, taskDeserializeTimeTotal#12212L, taskDeserializeTimeMin#12213L, taskDeserializeTimeMax#12214L, taskDeserializeTimeMedian#12215L, taskRunTimeTotal#12216L, taskRunTimeMin#12217L, taskRunTimeMax#12218L, taskRunTimeMedian#12219L, jvmGcTimeTotal#12220L, jvmGcTimeMin#12221L, jvmGcTimeMax#12222L, jvmGcTimeMedian#12223L, bytesSpilledToDiskRawTotal#12224L, bytesSpilledToDiskRawMin#12225L, bytesSpilledToDiskRawMax#12226L, bytesSpilledToDiskRawMedian#12227L, resultSerializationTimeTotal#12228L, resultSerializationTimeMin#12229L, resultSerializationTimeMax#12230L, resultSerializationTimeMedian#12231L, resultSizeToDriverTotal#12232L, resultSizeToDriverMin#12233L, resultSizeToDriverMax#12234L, resultSizeToDriverMedian#12235L, taskPeakExecutionMemoryMin#12236L, taskPeakExecutionMemoryMax#12237L, taskPeakExecutionMemoryMedian#12238L, persistencyBytesReadTotal#12239L, persistencyBytesReadMin#12240L, persistencyBytesReadMax#12241L, persistencyBytesReadMedian#12242L, persistencyRecordsReadTotal#12243L, persistencyRecordsReadMin#12244L, persistencyRecordsReadMax#12245L, persistencyRecordsReadMedian#12246L, persistencyBytesWrittenTotal#12247L, persistencyBytesWrittenMin#12248L, persistencyBytesWrittenMax#12249L, persistencyBytesWrittenMedian#12250L, persistencyRecordsWrittenTotal#12251L, persistencyRecordsWrittenMin#12252L, persistencyRecordsWrittenMax#12253L, persistencyRecordsWrittenMedian#12254L, shuffleConsumeRecordsReadTotal#12255L, shuffleConsumeRemoteBlocksFetchedTotal#12256L, shuffleConsumeLocalBlocksFetchedTotal#12257L, shuffleConsumeTotalBlocksFetchedTotal#12258L, shuffleConsumeRemoteBytesReadTotal#12259L, shuffleConsumeLocalBytesReadTotal#12260L, shuffleConsumeTotalBytesReadTotal#12261L, shuffleConsumeRemoteBytesReadToDiskTotal#12262L, shuffleConsumeFetchWaitTimeTotal#12263L, shuffleProduceBytesWrittenTotal#12264L, shuffleProduceRecordsWrittenTotal#12265L, shuffleProduceWriteTimeTotal#12266L]
Arguments: coalesced
(5) Sort [codegen id : 1]
Input [73]: [jobId#12194, stageCount#12195L, totalTaskCount#12196L, minTaskCountPerStage#12197L, maxTaskCountPerStage#12198L, medianTaskCountPerStage#12199L, bytesSpilledToDiskSerializedTotal#12200L, bytesSpilledToDiskSerializedMin#12201L, bytesSpilledToDiskSerializedMax#12202L, bytesSpilledToDiskSerializedMedian#12203L, taskCpuTimeTotal#12204L, taskCpuTimeMin#12205L, taskCpuTimeMax#12206L, taskCpuTimeMedian#12207L, taskDeserializeCpuTimeTotal#12208L, taskDeserializeCpuTimeMin#12209L, taskDeserializeCpuTimeMax#12210L, taskDeserializeCpuTimeMedian#12211L, taskDeserializeTimeTotal#12212L, taskDeserializeTimeMin#12213L, taskDeserializeTimeMax#12214L, taskDeserializeTimeMedian#12215L, taskRunTimeTotal#12216L, taskRunTimeMin#12217L, taskRunTimeMax#12218L, taskRunTimeMedian#12219L, jvmGcTimeTotal#12220L, jvmGcTimeMin#12221L, jvmGcTimeMax#12222L, jvmGcTimeMedian#12223L, bytesSpilledToDiskRawTotal#12224L, bytesSpilledToDiskRawMin#12225L, bytesSpilledToDiskRawMax#12226L, bytesSpilledToDiskRawMedian#12227L, resultSerializationTimeTotal#12228L, resultSerializationTimeMin#12229L, resultSerializationTimeMax#12230L, resultSerializationTimeMedian#12231L, resultSizeToDriverTotal#12232L, resultSizeToDriverMin#12233L, resultSizeToDriverMax#12234L, resultSizeToDriverMedian#12235L, taskPeakExecutionMemoryMin#12236L, taskPeakExecutionMemoryMax#12237L, taskPeakExecutionMemoryMedian#12238L, persistencyBytesReadTotal#12239L, persistencyBytesReadMin#12240L, persistencyBytesReadMax#12241L, persistencyBytesReadMedian#12242L, persistencyRecordsReadTotal#12243L, persistencyRecordsReadMin#12244L, persistencyRecordsReadMax#12245L, persistencyRecordsReadMedian#12246L, persistencyBytesWrittenTotal#12247L, persistencyBytesWrittenMin#12248L, persistencyBytesWrittenMax#12249L, persistencyBytesWrittenMedian#12250L, persistencyRecordsWrittenTotal#12251L, persistencyRecordsWrittenMin#12252L, persistencyRecordsWrittenMax#12253L, persistencyRecordsWrittenMedian#12254L, shuffleConsumeRecordsReadTotal#12255L, shuffleConsumeRemoteBlocksFetchedTotal#12256L, shuffleConsumeLocalBlocksFetchedTotal#12257L, shuffleConsumeTotalBlocksFetchedTotal#12258L, shuffleConsumeRemoteBytesReadTotal#12259L, shuffleConsumeLocalBytesReadTotal#12260L, shuffleConsumeTotalBytesReadTotal#12261L, shuffleConsumeRemoteBytesReadToDiskTotal#12262L, shuffleConsumeFetchWaitTimeTotal#12263L, shuffleProduceBytesWrittenTotal#12264L, shuffleProduceRecordsWrittenTotal#12265L, shuffleProduceWriteTimeTotal#12266L]
Arguments: [jobId#12194 ASC NULLS FIRST], false, 0
(6) LocalTableScan
Output [4]: [jobId#12267, peakExecutionMemory#12268L, peakExecutionMemoryCliqueDuration#12269L, peakExecutionMemoryCliqueSize#12270L]
Arguments: [jobId#12267, peakExecutionMemory#12268L, peakExecutionMemoryCliqueDuration#12269L, peakExecutionMemoryCliqueSize#12270L]
(7) Exchange
Input [4]: [jobId#12267, peakExecutionMemory#12268L, peakExecutionMemoryCliqueDuration#12269L, peakExecutionMemoryCliqueSize#12270L]
Arguments: hashpartitioning(jobId#12267, 20), ENSURE_REQUIREMENTS, [plan_id=4454]
(8) ShuffleQueryStage
Output [4]: [jobId#12267, peakExecutionMemory#12268L, peakExecutionMemoryCliqueDuration#12269L, peakExecutionMemoryCliqueSize#12270L]
Arguments: 1
(9) AQEShuffleRead
Input [4]: [jobId#12267, peakExecutionMemory#12268L, peakExecutionMemoryCliqueDuration#12269L, peakExecutionMemoryCliqueSize#12270L]
Arguments: coalesced
(10) Sort [codegen id : 2]
Input [4]: [jobId#12267, peakExecutionMemory#12268L, peakExecutionMemoryCliqueDuration#12269L, peakExecutionMemoryCliqueSize#12270L]
Arguments: [jobId#12267 ASC NULLS FIRST], false, 0
(11) SortMergeJoin [codegen id : 3]
Left keys [1]: [jobId#12194]
Right keys [1]: [jobId#12267]
Join type: FullOuter
Join condition: None
(12) Project [codegen id : 3]
Output [76]: [coalesce(jobId#12194, jobId#12267) AS jobId#12277, stageCount#12195L, totalTaskCount#12196L, minTaskCountPerStage#12197L, maxTaskCountPerStage#12198L, medianTaskCountPerStage#12199L, bytesSpilledToDiskSerializedTotal#12200L, bytesSpilledToDiskSerializedMin#12201L, bytesSpilledToDiskSerializedMax#12202L, bytesSpilledToDiskSerializedMedian#12203L, taskCpuTimeTotal#12204L, taskCpuTimeMin#12205L, taskCpuTimeMax#12206L, taskCpuTimeMedian#12207L, taskDeserializeCpuTimeTotal#12208L, taskDeserializeCpuTimeMin#12209L, taskDeserializeCpuTimeMax#12210L, taskDeserializeCpuTimeMedian#12211L, taskDeserializeTimeTotal#12212L, taskDeserializeTimeMin#12213L, taskDeserializeTimeMax#12214L, taskDeserializeTimeMedian#12215L, taskRunTimeTotal#12216L, taskRunTimeMin#12217L, taskRunTimeMax#12218L, taskRunTimeMedian#12219L, jvmGcTimeTotal#12220L, jvmGcTimeMin#12221L, jvmGcTimeMax#12222L, jvmGcTimeMedian#12223L, bytesSpilledToDiskRawTotal#12224L, bytesSpilledToDiskRawMin#12225L, bytesSpilledToDiskRawMax#12226L, bytesSpilledToDiskRawMedian#12227L, resultSerializationTimeTotal#12228L, resultSerializationTimeMin#12229L, resultSerializationTimeMax#12230L, resultSerializationTimeMedian#12231L, resultSizeToDriverTotal#12232L, resultSizeToDriverMin#12233L, resultSizeToDriverMax#12234L, resultSizeToDriverMedian#12235L, taskPeakExecutionMemoryMin#12236L, taskPeakExecutionMemoryMax#12237L, taskPeakExecutionMemoryMedian#12238L, persistencyBytesReadTotal#12239L, persistencyBytesReadMin#12240L, persistencyBytesReadMax#12241L, persistencyBytesReadMedian#12242L, persistencyRecordsReadTotal#12243L, persistencyRecordsReadMin#12244L, persistencyRecordsReadMax#12245L, persistencyRecordsReadMedian#12246L, persistencyBytesWrittenTotal#12247L, persistencyBytesWrittenMin#12248L, persistencyBytesWrittenMax#12249L, persistencyBytesWrittenMedian#12250L, persistencyRecordsWrittenTotal#12251L, persistencyRecordsWrittenMin#12252L, persistencyRecordsWrittenMax#12253L, persistencyRecordsWrittenMedian#12254L, shuffleConsumeRecordsReadTotal#12255L, shuffleConsumeRemoteBlocksFetchedTotal#12256L, shuffleConsumeLocalBlocksFetchedTotal#12257L, shuffleConsumeTotalBlocksFetchedTotal#12258L, shuffleConsumeRemoteBytesReadTotal#12259L, shuffleConsumeLocalBytesReadTotal#12260L, shuffleConsumeTotalBytesReadTotal#12261L, shuffleConsumeRemoteBytesReadToDiskTotal#12262L, shuffleConsumeFetchWaitTimeTotal#12263L, shuffleProduceBytesWrittenTotal#12264L, shuffleProduceRecordsWrittenTotal#12265L, shuffleProduceWriteTimeTotal#12266L, peakExecutionMemory#12268L, peakExecutionMemoryCliqueDuration#12269L, peakExecutionMemoryCliqueSize#12270L]
Input [77]: [jobId#12194, stageCount#12195L, totalTaskCount#12196L, minTaskCountPerStage#12197L, maxTaskCountPerStage#12198L, medianTaskCountPerStage#12199L, bytesSpilledToDiskSerializedTotal#12200L, bytesSpilledToDiskSerializedMin#12201L, bytesSpilledToDiskSerializedMax#12202L, bytesSpilledToDiskSerializedMedian#12203L, taskCpuTimeTotal#12204L, taskCpuTimeMin#12205L, taskCpuTimeMax#12206L, taskCpuTimeMedian#12207L, taskDeserializeCpuTimeTotal#12208L, taskDeserializeCpuTimeMin#12209L, taskDeserializeCpuTimeMax#12210L, taskDeserializeCpuTimeMedian#12211L, taskDeserializeTimeTotal#12212L, taskDeserializeTimeMin#12213L, taskDeserializeTimeMax#12214L, taskDeserializeTimeMedian#12215L, taskRunTimeTotal#12216L, taskRunTimeMin#12217L, taskRunTimeMax#12218L, taskRunTimeMedian#12219L, jvmGcTimeTotal#12220L, jvmGcTimeMin#12221L, jvmGcTimeMax#12222L, jvmGcTimeMedian#12223L, bytesSpilledToDiskRawTotal#12224L, bytesSpilledToDiskRawMin#12225L, bytesSpilledToDiskRawMax#12226L, bytesSpilledToDiskRawMedian#12227L, resultSerializationTimeTotal#12228L, resultSerializationTimeMin#12229L, resultSerializationTimeMax#12230L, resultSerializationTimeMedian#12231L, resultSizeToDriverTotal#12232L, resultSizeToDriverMin#12233L, resultSizeToDriverMax#12234L, resultSizeToDriverMedian#12235L, taskPeakExecutionMemoryMin#12236L, taskPeakExecutionMemoryMax#12237L, taskPeakExecutionMemoryMedian#12238L, persistencyBytesReadTotal#12239L, persistencyBytesReadMin#12240L, persistencyBytesReadMax#12241L, persistencyBytesReadMedian#12242L, persistencyRecordsReadTotal#12243L, persistencyRecordsReadMin#12244L, persistencyRecordsReadMax#12245L, persistencyRecordsReadMedian#12246L, persistencyBytesWrittenTotal#12247L, persistencyBytesWrittenMin#12248L, persistencyBytesWrittenMax#12249L, persistencyBytesWrittenMedian#12250L, persistencyRecordsWrittenTotal#12251L, persistencyRecordsWrittenMin#12252L, persistencyRecordsWrittenMax#12253L, persistencyRecordsWrittenMedian#12254L, shuffleConsumeRecordsReadTotal#12255L, shuffleConsumeRemoteBlocksFetchedTotal#12256L, shuffleConsumeLocalBlocksFetchedTotal#12257L, shuffleConsumeTotalBlocksFetchedTotal#12258L, shuffleConsumeRemoteBytesReadTotal#12259L, shuffleConsumeLocalBytesReadTotal#12260L, shuffleConsumeTotalBytesReadTotal#12261L, shuffleConsumeRemoteBytesReadToDiskTotal#12262L, shuffleConsumeFetchWaitTimeTotal#12263L, shuffleProduceBytesWrittenTotal#12264L, shuffleProduceRecordsWrittenTotal#12265L, shuffleProduceWriteTimeTotal#12266L, jobId#12267, peakExecutionMemory#12268L, peakExecutionMemoryCliqueDuration#12269L, peakExecutionMemoryCliqueSize#12270L]
(13) Exchange
Input [76]: [jobId#12277, stageCount#12195L, totalTaskCount#12196L, minTaskCountPerStage#12197L, maxTaskCountPerStage#12198L, medianTaskCountPerStage#12199L, bytesSpilledToDiskSerializedTotal#12200L, bytesSpilledToDiskSerializedMin#12201L, bytesSpilledToDiskSerializedMax#12202L, bytesSpilledToDiskSerializedMedian#12203L, taskCpuTimeTotal#12204L, taskCpuTimeMin#12205L, taskCpuTimeMax#12206L, taskCpuTimeMedian#12207L, taskDeserializeCpuTimeTotal#12208L, taskDeserializeCpuTimeMin#12209L, taskDeserializeCpuTimeMax#12210L, taskDeserializeCpuTimeMedian#12211L, taskDeserializeTimeTotal#12212L, taskDeserializeTimeMin#12213L, taskDeserializeTimeMax#12214L, taskDeserializeTimeMedian#12215L, taskRunTimeTotal#12216L, taskRunTimeMin#12217L, taskRunTimeMax#12218L, taskRunTimeMedian#12219L, jvmGcTimeTotal#12220L, jvmGcTimeMin#12221L, jvmGcTimeMax#12222L, jvmGcTimeMedian#12223L, bytesSpilledToDiskRawTotal#12224L, bytesSpilledToDiskRawMin#12225L, bytesSpilledToDiskRawMax#12226L, bytesSpilledToDiskRawMedian#12227L, resultSerializationTimeTotal#12228L, resultSerializationTimeMin#12229L, resultSerializationTimeMax#12230L, resultSerializationTimeMedian#12231L, resultSizeToDriverTotal#12232L, resultSizeToDriverMin#12233L, resultSizeToDriverMax#12234L, resultSizeToDriverMedian#12235L, taskPeakExecutionMemoryMin#12236L, taskPeakExecutionMemoryMax#12237L, taskPeakExecutionMemoryMedian#12238L, persistencyBytesReadTotal#12239L, persistencyBytesReadMin#12240L, persistencyBytesReadMax#12241L, persistencyBytesReadMedian#12242L, persistencyRecordsReadTotal#12243L, persistencyRecordsReadMin#12244L, persistencyRecordsReadMax#12245L, persistencyRecordsReadMedian#12246L, persistencyBytesWrittenTotal#12247L, persistencyBytesWrittenMin#12248L, persistencyBytesWrittenMax#12249L, persistencyBytesWrittenMedian#12250L, persistencyRecordsWrittenTotal#12251L, persistencyRecordsWrittenMin#12252L, persistencyRecordsWrittenMax#12253L, persistencyRecordsWrittenMedian#12254L, shuffleConsumeRecordsReadTotal#12255L, shuffleConsumeRemoteBlocksFetchedTotal#12256L, shuffleConsumeLocalBlocksFetchedTotal#12257L, shuffleConsumeTotalBlocksFetchedTotal#12258L, shuffleConsumeRemoteBytesReadTotal#12259L, shuffleConsumeLocalBytesReadTotal#12260L, shuffleConsumeTotalBytesReadTotal#12261L, shuffleConsumeRemoteBytesReadToDiskTotal#12262L, shuffleConsumeFetchWaitTimeTotal#12263L, shuffleProduceBytesWrittenTotal#12264L, shuffleProduceRecordsWrittenTotal#12265L, shuffleProduceWriteTimeTotal#12266L, peakExecutionMemory#12268L, peakExecutionMemoryCliqueDuration#12269L, peakExecutionMemoryCliqueSize#12270L]
Arguments: hashpartitioning(jobId#12277, 20), ENSURE_REQUIREMENTS, [plan_id=4617]
(14) ShuffleQueryStage
Output [76]: [jobId#12277, stageCount#12195L, totalTaskCount#12196L, minTaskCountPerStage#12197L, maxTaskCountPerStage#12198L, medianTaskCountPerStage#12199L, bytesSpilledToDiskSerializedTotal#12200L, bytesSpilledToDiskSerializedMin#12201L, bytesSpilledToDiskSerializedMax#12202L, bytesSpilledToDiskSerializedMedian#12203L, taskCpuTimeTotal#12204L, taskCpuTimeMin#12205L, taskCpuTimeMax#12206L, taskCpuTimeMedian#12207L, taskDeserializeCpuTimeTotal#12208L, taskDeserializeCpuTimeMin#12209L, taskDeserializeCpuTimeMax#12210L, taskDeserializeCpuTimeMedian#12211L, taskDeserializeTimeTotal#12212L, taskDeserializeTimeMin#12213L, taskDeserializeTimeMax#12214L, taskDeserializeTimeMedian#12215L, taskRunTimeTotal#12216L, taskRunTimeMin#12217L, taskRunTimeMax#12218L, taskRunTimeMedian#12219L, jvmGcTimeTotal#12220L, jvmGcTimeMin#12221L, jvmGcTimeMax#12222L, jvmGcTimeMedian#12223L, bytesSpilledToDiskRawTotal#12224L, bytesSpilledToDiskRawMin#12225L, bytesSpilledToDiskRawMax#12226L, bytesSpilledToDiskRawMedian#12227L, resultSerializationTimeTotal#12228L, resultSerializationTimeMin#12229L, resultSerializationTimeMax#12230L, resultSerializationTimeMedian#12231L, resultSizeToDriverTotal#12232L, resultSizeToDriverMin#12233L, resultSizeToDriverMax#12234L, resultSizeToDriverMedian#12235L, taskPeakExecutionMemoryMin#12236L, taskPeakExecutionMemoryMax#12237L, taskPeakExecutionMemoryMedian#12238L, persistencyBytesReadTotal#12239L, persistencyBytesReadMin#12240L, persistencyBytesReadMax#12241L, persistencyBytesReadMedian#12242L, persistencyRecordsReadTotal#12243L, persistencyRecordsReadMin#12244L, persistencyRecordsReadMax#12245L, persistencyRecordsReadMedian#12246L, persistencyBytesWrittenTotal#12247L, persistencyBytesWrittenMin#12248L, persistencyBytesWrittenMax#12249L, persistencyBytesWrittenMedian#12250L, persistencyRecordsWrittenTotal#12251L, persistencyRecordsWrittenMin#12252L, persistencyRecordsWrittenMax#12253L, persistencyRecordsWrittenMedian#12254L, shuffleConsumeRecordsReadTotal#12255L, shuffleConsumeRemoteBlocksFetchedTotal#12256L, shuffleConsumeLocalBlocksFetchedTotal#12257L, shuffleConsumeTotalBlocksFetchedTotal#12258L, shuffleConsumeRemoteBytesReadTotal#12259L, shuffleConsumeLocalBytesReadTotal#12260L, shuffleConsumeTotalBytesReadTotal#12261L, shuffleConsumeRemoteBytesReadToDiskTotal#12262L, shuffleConsumeFetchWaitTimeTotal#12263L, shuffleProduceBytesWrittenTotal#12264L, shuffleProduceRecordsWrittenTotal#12265L, shuffleProduceWriteTimeTotal#12266L, peakExecutionMemory#12268L, peakExecutionMemoryCliqueDuration#12269L, peakExecutionMemoryCliqueSize#12270L]
Arguments: 3
(15) AQEShuffleRead
Input [76]: [jobId#12277, stageCount#12195L, totalTaskCount#12196L, minTaskCountPerStage#12197L, maxTaskCountPerStage#12198L, medianTaskCountPerStage#12199L, bytesSpilledToDiskSerializedTotal#12200L, bytesSpilledToDiskSerializedMin#12201L, bytesSpilledToDiskSerializedMax#12202L, bytesSpilledToDiskSerializedMedian#12203L, taskCpuTimeTotal#12204L, taskCpuTimeMin#12205L, taskCpuTimeMax#12206L, taskCpuTimeMedian#12207L, taskDeserializeCpuTimeTotal#12208L, taskDeserializeCpuTimeMin#12209L, taskDeserializeCpuTimeMax#12210L, taskDeserializeCpuTimeMedian#12211L, taskDeserializeTimeTotal#12212L, taskDeserializeTimeMin#12213L, taskDeserializeTimeMax#12214L, taskDeserializeTimeMedian#12215L, taskRunTimeTotal#12216L, taskRunTimeMin#12217L, taskRunTimeMax#12218L, taskRunTimeMedian#12219L, jvmGcTimeTotal#12220L, jvmGcTimeMin#12221L, jvmGcTimeMax#12222L, jvmGcTimeMedian#12223L, bytesSpilledToDiskRawTotal#12224L, bytesSpilledToDiskRawMin#12225L, bytesSpilledToDiskRawMax#12226L, bytesSpilledToDiskRawMedian#12227L, resultSerializationTimeTotal#12228L, resultSerializationTimeMin#12229L, resultSerializationTimeMax#12230L, resultSerializationTimeMedian#12231L, resultSizeToDriverTotal#12232L, resultSizeToDriverMin#12233L, resultSizeToDriverMax#12234L, resultSizeToDriverMedian#12235L, taskPeakExecutionMemoryMin#12236L, taskPeakExecutionMemoryMax#12237L, taskPeakExecutionMemoryMedian#12238L, persistencyBytesReadTotal#12239L, persistencyBytesReadMin#12240L, persistencyBytesReadMax#12241L, persistencyBytesReadMedian#12242L, persistencyRecordsReadTotal#12243L, persistencyRecordsReadMin#12244L, persistencyRecordsReadMax#12245L, persistencyRecordsReadMedian#12246L, persistencyBytesWrittenTotal#12247L, persistencyBytesWrittenMin#12248L, persistencyBytesWrittenMax#12249L, persistencyBytesWrittenMedian#12250L, persistencyRecordsWrittenTotal#12251L, persistencyRecordsWrittenMin#12252L, persistencyRecordsWrittenMax#12253L, persistencyRecordsWrittenMedian#12254L, shuffleConsumeRecordsReadTotal#12255L, shuffleConsumeRemoteBlocksFetchedTotal#12256L, shuffleConsumeLocalBlocksFetchedTotal#12257L, shuffleConsumeTotalBlocksFetchedTotal#12258L, shuffleConsumeRemoteBytesReadTotal#12259L, shuffleConsumeLocalBytesReadTotal#12260L, shuffleConsumeTotalBytesReadTotal#12261L, shuffleConsumeRemoteBytesReadToDiskTotal#12262L, shuffleConsumeFetchWaitTimeTotal#12263L, shuffleProduceBytesWrittenTotal#12264L, shuffleProduceRecordsWrittenTotal#12265L, shuffleProduceWriteTimeTotal#12266L, peakExecutionMemory#12268L, peakExecutionMemoryCliqueDuration#12269L, peakExecutionMemoryCliqueSize#12270L]
Arguments: coalesced
(16) Sort [codegen id : 4]
Input [76]: [jobId#12277, stageCount#12195L, totalTaskCount#12196L, minTaskCountPerStage#12197L, maxTaskCountPerStage#12198L, medianTaskCountPerStage#12199L, bytesSpilledToDiskSerializedTotal#12200L, bytesSpilledToDiskSerializedMin#12201L, bytesSpilledToDiskSerializedMax#12202L, bytesSpilledToDiskSerializedMedian#12203L, taskCpuTimeTotal#12204L, taskCpuTimeMin#12205L, taskCpuTimeMax#12206L, taskCpuTimeMedian#12207L, taskDeserializeCpuTimeTotal#12208L, taskDeserializeCpuTimeMin#12209L, taskDeserializeCpuTimeMax#12210L, taskDeserializeCpuTimeMedian#12211L, taskDeserializeTimeTotal#12212L, taskDeserializeTimeMin#12213L, taskDeserializeTimeMax#12214L, taskDeserializeTimeMedian#12215L, taskRunTimeTotal#12216L, taskRunTimeMin#12217L, taskRunTimeMax#12218L, taskRunTimeMedian#12219L, jvmGcTimeTotal#12220L, jvmGcTimeMin#12221L, jvmGcTimeMax#12222L, jvmGcTimeMedian#12223L, bytesSpilledToDiskRawTotal#12224L, bytesSpilledToDiskRawMin#12225L, bytesSpilledToDiskRawMax#12226L, bytesSpilledToDiskRawMedian#12227L, resultSerializationTimeTotal#12228L, resultSerializationTimeMin#12229L, resultSerializationTimeMax#12230L, resultSerializationTimeMedian#12231L, resultSizeToDriverTotal#12232L, resultSizeToDriverMin#12233L, resultSizeToDriverMax#12234L, resultSizeToDriverMedian#12235L, taskPeakExecutionMemoryMin#12236L, taskPeakExecutionMemoryMax#12237L, taskPeakExecutionMemoryMedian#12238L, persistencyBytesReadTotal#12239L, persistencyBytesReadMin#12240L, persistencyBytesReadMax#12241L, persistencyBytesReadMedian#12242L, persistencyRecordsReadTotal#12243L, persistencyRecordsReadMin#12244L, persistencyRecordsReadMax#12245L, persistencyRecordsReadMedian#12246L, persistencyBytesWrittenTotal#12247L, persistencyBytesWrittenMin#12248L, persistencyBytesWrittenMax#12249L, persistencyBytesWrittenMedian#12250L, persistencyRecordsWrittenTotal#12251L, persistencyRecordsWrittenMin#12252L, persistencyRecordsWrittenMax#12253L, persistencyRecordsWrittenMedian#12254L, shuffleConsumeRecordsReadTotal#12255L, shuffleConsumeRemoteBlocksFetchedTotal#12256L, shuffleConsumeLocalBlocksFetchedTotal#12257L, shuffleConsumeTotalBlocksFetchedTotal#12258L, shuffleConsumeRemoteBytesReadTotal#12259L, shuffleConsumeLocalBytesReadTotal#12260L, shuffleConsumeTotalBytesReadTotal#12261L, shuffleConsumeRemoteBytesReadToDiskTotal#12262L, shuffleConsumeFetchWaitTimeTotal#12263L, shuffleProduceBytesWrittenTotal#12264L, shuffleProduceRecordsWrittenTotal#12265L, shuffleProduceWriteTimeTotal#12266L, peakExecutionMemory#12268L, peakExecutionMemoryCliqueDuration#12269L, peakExecutionMemoryCliqueSize#12270L]
Arguments: [jobId#12277 ASC NULLS FIRST], false, 0
(17) LocalTableScan
Output [6]: [jobId#12271, rddStorageDiskSizeTotal#12272L, rddStorageMemSizeTotal#12273L, rddNumCachedPartitionsTotal#12274, rddNumPartitionsTotal#12275, numberOfExecutors#12276]
Arguments: [jobId#12271, rddStorageDiskSizeTotal#12272L, rddStorageMemSizeTotal#12273L, rddNumCachedPartitionsTotal#12274, rddNumPartitionsTotal#12275, numberOfExecutors#12276]
(18) Exchange
Input [6]: [jobId#12271, rddStorageDiskSizeTotal#12272L, rddStorageMemSizeTotal#12273L, rddNumCachedPartitionsTotal#12274, rddNumPartitionsTotal#12275, numberOfExecutors#12276]
Arguments: hashpartitioning(jobId#12271, 20), ENSURE_REQUIREMENTS, [plan_id=4462]
(19) ShuffleQueryStage
Output [6]: [jobId#12271, rddStorageDiskSizeTotal#12272L, rddStorageMemSizeTotal#12273L, rddNumCachedPartitionsTotal#12274, rddNumPartitionsTotal#12275, numberOfExecutors#12276]
Arguments: 2
(20) AQEShuffleRead
Input [6]: [jobId#12271, rddStorageDiskSizeTotal#12272L, rddStorageMemSizeTotal#12273L, rddNumCachedPartitionsTotal#12274, rddNumPartitionsTotal#12275, numberOfExecutors#12276]
Arguments: coalesced
(21) Sort [codegen id : 5]
Input [6]: [jobId#12271, rddStorageDiskSizeTotal#12272L, rddStorageMemSizeTotal#12273L, rddNumCachedPartitionsTotal#12274, rddNumPartitionsTotal#12275, numberOfExecutors#12276]
Arguments: [jobId#12271 ASC NULLS FIRST], false, 0
(22) SortMergeJoin [codegen id : 6]
Left keys [1]: [jobId#12277]
Right keys [1]: [jobId#12271]
Join type: FullOuter
Join condition: None
(23) Project [codegen id : 6]
Output [92]: [coalesce(jobId#12277, jobId#12271) AS jobId#12278, stageCount#12195L, totalTaskCount#12196L, minTaskCountPerStage#12197L, maxTaskCountPerStage#12198L, medianTaskCountPerStage#12199L, bytesSpilledToDiskSerializedTotal#12200L, bytesSpilledToDiskSerializedMin#12201L, bytesSpilledToDiskSerializedMax#12202L, bytesSpilledToDiskSerializedMedian#12203L, taskCpuTimeTotal#12204L, taskCpuTimeMin#12205L, taskCpuTimeMax#12206L, taskCpuTimeMedian#12207L, taskDeserializeCpuTimeTotal#12208L, taskDeserializeCpuTimeMin#12209L, taskDeserializeCpuTimeMax#12210L, taskDeserializeCpuTimeMedian#12211L, taskDeserializeTimeTotal#12212L, taskDeserializeTimeMin#12213L, taskDeserializeTimeMax#12214L, taskDeserializeTimeMedian#12215L, taskRunTimeTotal#12216L, taskRunTimeMin#12217L, taskRunTimeMax#12218L, taskRunTimeMedian#12219L, jvmGcTimeTotal#12220L, jvmGcTimeMin#12221L, jvmGcTimeMax#12222L, jvmGcTimeMedian#12223L, bytesSpilledToDiskRawTotal#12224L, bytesSpilledToDiskRawMin#12225L, bytesSpilledToDiskRawMax#12226L, bytesSpilledToDiskRawMedian#12227L, resultSerializationTimeTotal#12228L, resultSerializationTimeMin#12229L, resultSerializationTimeMax#12230L, resultSerializationTimeMedian#12231L, resultSizeToDriverTotal#12232L, resultSizeToDriverMin#12233L, resultSizeToDriverMax#12234L, resultSizeToDriverMedian#12235L, taskPeakExecutionMemoryMin#12236L, taskPeakExecutionMemoryMax#12237L, taskPeakExecutionMemoryMedian#12238L, persistencyBytesReadTotal#12239L, persistencyBytesReadMin#12240L, persistencyBytesReadMax#12241L, persistencyBytesReadMedian#12242L, persistencyRecordsReadTotal#12243L, persistencyRecordsReadMin#12244L, persistencyRecordsReadMax#12245L, persistencyRecordsReadMedian#12246L, persistencyBytesWrittenTotal#12247L, persistencyBytesWrittenMin#12248L, persistencyBytesWrittenMax#12249L, persistencyBytesWrittenMedian#12250L, persistencyRecordsWrittenTotal#12251L, persistencyRecordsWrittenMin#12252L, persistencyRecordsWrittenMax#12253L, persistencyRecordsWrittenMedian#12254L, shuffleConsumeRecordsReadTotal#12255L, shuffleConsumeRemoteBlocksFetchedTotal#12256L, shuffleConsumeLocalBlocksFetchedTotal#12257L, shuffleConsumeTotalBlocksFetchedTotal#12258L, shuffleConsumeRemoteBytesReadTotal#12259L, shuffleConsumeLocalBytesReadTotal#12260L, shuffleConsumeTotalBytesReadTotal#12261L, shuffleConsumeRemoteBytesReadToDiskTotal#12262L, shuffleConsumeFetchWaitTimeTotal#12263L, shuffleProduceBytesWrittenTotal#12264L, shuffleProduceRecordsWrittenTotal#12265L, shuffleProduceWriteTimeTotal#12266L, peakExecutionMemory#12268L, peakExecutionMemoryCliqueDuration#12269L, peakExecutionMemoryCliqueSize#12270L, rddStorageDiskSizeTotal#12272L, rddStorageMemSizeTotal#12273L, rddNumCachedPartitionsTotal#12274, rddNumPartitionsTotal#12275, numberOfExecutors#12276, 10000002105 AS replenishmentRunId#12279L, 6944346648028224943 AS tenantId#12280, 8378 AS cornerstoneTenantId#12281L, Daily_grocery AS marketUnit#12282, STANDARD AS scenario#12283, 3961f109-b13f-3cf7-ae84-59fa48c4a71b AS activityId#12284, RunStreamWithId AS activityType#12285, CalculateOrderProposalsWorkflow AS workflowType#12286, 79900f79-a3ad-3739-934c-f6e932e71ecc AS workflowId#12287, 3 AS activityAttempt#12288, AS gitCommitId#12290]
Input [82]: [jobId#12277, stageCount#12195L, totalTaskCount#12196L, minTaskCountPerStage#12197L, maxTaskCountPerStage#12198L, medianTaskCountPerStage#12199L, bytesSpilledToDiskSerializedTotal#12200L, bytesSpilledToDiskSerializedMin#12201L, bytesSpilledToDiskSerializedMax#12202L, bytesSpilledToDiskSerializedMedian#12203L, taskCpuTimeTotal#12204L, taskCpuTimeMin#12205L, taskCpuTimeMax#12206L, taskCpuTimeMedian#12207L, taskDeserializeCpuTimeTotal#12208L, taskDeserializeCpuTimeMin#12209L, taskDeserializeCpuTimeMax#12210L, taskDeserializeCpuTimeMedian#12211L, taskDeserializeTimeTotal#12212L, taskDeserializeTimeMin#12213L, taskDeserializeTimeMax#12214L, taskDeserializeTimeMedian#12215L, taskRunTimeTotal#12216L, taskRunTimeMin#12217L, taskRunTimeMax#12218L, taskRunTimeMedian#12219L, jvmGcTimeTotal#12220L, jvmGcTimeMin#12221L, jvmGcTimeMax#12222L, jvmGcTimeMedian#12223L, bytesSpilledToDiskRawTotal#12224L, bytesSpilledToDiskRawMin#12225L, bytesSpilledToDiskRawMax#12226L, bytesSpilledToDiskRawMedian#12227L, resultSerializationTimeTotal#12228L, resultSerializationTimeMin#12229L, resultSerializationTimeMax#12230L, resultSerializationTimeMedian#12231L, resultSizeToDriverTotal#12232L, resultSizeToDriverMin#12233L, resultSizeToDriverMax#12234L, resultSizeToDriverMedian#12235L, taskPeakExecutionMemoryMin#12236L, taskPeakExecutionMemoryMax#12237L, taskPeakExecutionMemoryMedian#12238L, persistencyBytesReadTotal#12239L, persistencyBytesReadMin#12240L, persistencyBytesReadMax#12241L, persistencyBytesReadMedian#12242L, persistencyRecordsReadTotal#12243L, persistencyRecordsReadMin#12244L, persistencyRecordsReadMax#12245L, persistencyRecordsReadMedian#12246L, persistencyBytesWrittenTotal#12247L, persistencyBytesWrittenMin#12248L, persistencyBytesWrittenMax#12249L, persistencyBytesWrittenMedian#12250L, persistencyRecordsWrittenTotal#12251L, persistencyRecordsWrittenMin#12252L, persistencyRecordsWrittenMax#12253L, persistencyRecordsWrittenMedian#12254L, shuffleConsumeRecordsReadTotal#12255L, shuffleConsumeRemoteBlocksFetchedTotal#12256L, shuffleConsumeLocalBlocksFetchedTotal#12257L, shuffleConsumeTotalBlocksFetchedTotal#12258L, shuffleConsumeRemoteBytesReadTotal#12259L, shuffleConsumeLocalBytesReadTotal#12260L, shuffleConsumeTotalBytesReadTotal#12261L, shuffleConsumeRemoteBytesReadToDiskTotal#12262L, shuffleConsumeFetchWaitTimeTotal#12263L, shuffleProduceBytesWrittenTotal#12264L, shuffleProduceRecordsWrittenTotal#12265L, shuffleProduceWriteTimeTotal#12266L, peakExecutionMemory#12268L, peakExecutionMemoryCliqueDuration#12269L, peakExecutionMemoryCliqueSize#12270L, jobId#12271, rddStorageDiskSizeTotal#12272L, rddStorageMemSizeTotal#12273L, rddNumCachedPartitionsTotal#12274, rddNumPartitionsTotal#12275, numberOfExecutors#12276]
(24) Sort [codegen id : 6]
Input [92]: [jobId#12278, stageCount#12195L, totalTaskCount#12196L, minTaskCountPerStage#12197L, maxTaskCountPerStage#12198L, medianTaskCountPerStage#12199L, bytesSpilledToDiskSerializedTotal#12200L, bytesSpilledToDiskSerializedMin#12201L, bytesSpilledToDiskSerializedMax#12202L, bytesSpilledToDiskSerializedMedian#12203L, taskCpuTimeTotal#12204L, taskCpuTimeMin#12205L, taskCpuTimeMax#12206L, taskCpuTimeMedian#12207L, taskDeserializeCpuTimeTotal#12208L, taskDeserializeCpuTimeMin#12209L, taskDeserializeCpuTimeMax#12210L, taskDeserializeCpuTimeMedian#12211L, taskDeserializeTimeTotal#12212L, taskDeserializeTimeMin#12213L, taskDeserializeTimeMax#12214L, taskDeserializeTimeMedian#12215L, taskRunTimeTotal#12216L, taskRunTimeMin#12217L, taskRunTimeMax#12218L, taskRunTimeMedian#12219L, jvmGcTimeTotal#12220L, jvmGcTimeMin#12221L, jvmGcTimeMax#12222L, jvmGcTimeMedian#12223L, bytesSpilledToDiskRawTotal#12224L, bytesSpilledToDiskRawMin#12225L, bytesSpilledToDiskRawMax#12226L, bytesSpilledToDiskRawMedian#12227L, resultSerializationTimeTotal#12228L, resultSerializationTimeMin#12229L, resultSerializationTimeMax#12230L, resultSerializationTimeMedian#12231L, resultSizeToDriverTotal#12232L, resultSizeToDriverMin#12233L, resultSizeToDriverMax#12234L, resultSizeToDriverMedian#12235L, taskPeakExecutionMemoryMin#12236L, taskPeakExecutionMemoryMax#12237L, taskPeakExecutionMemoryMedian#12238L, persistencyBytesReadTotal#12239L, persistencyBytesReadMin#12240L, persistencyBytesReadMax#12241L, persistencyBytesReadMedian#12242L, persistencyRecordsReadTotal#12243L, persistencyRecordsReadMin#12244L, persistencyRecordsReadMax#12245L, persistencyRecordsReadMedian#12246L, persistencyBytesWrittenTotal#12247L, persistencyBytesWrittenMin#12248L, persistencyBytesWrittenMax#12249L, persistencyBytesWrittenMedian#12250L, persistencyRecordsWrittenTotal#12251L, persistencyRecordsWrittenMin#12252L, persistencyRecordsWrittenMax#12253L, persistencyRecordsWrittenMedian#12254L, shuffleConsumeRecordsReadTotal#12255L, shuffleConsumeRemoteBlocksFetchedTotal#12256L, shuffleConsumeLocalBlocksFetchedTotal#12257L, shuffleConsumeTotalBlocksFetchedTotal#12258L, shuffleConsumeRemoteBytesReadTotal#12259L, shuffleConsumeLocalBytesReadTotal#12260L, shuffleConsumeTotalBytesReadTotal#12261L, shuffleConsumeRemoteBytesReadToDiskTotal#12262L, shuffleConsumeFetchWaitTimeTotal#12263L, shuffleProduceBytesWrittenTotal#12264L, shuffleProduceRecordsWrittenTotal#12265L, shuffleProduceWriteTimeTotal#12266L, peakExecutionMemory#12268L, peakExecutionMemoryCliqueDuration#12269L, peakExecutionMemoryCliqueSize#12270L, rddStorageDiskSizeTotal#12272L, rddStorageMemSizeTotal#12273L, rddNumCachedPartitionsTotal#12274, rddNumPartitionsTotal#12275, numberOfExecutors#12276, replenishmentRunId#12279L, tenantId#12280, cornerstoneTenantId#12281L, marketUnit#12282, scenario#12283, activityId#12284, activityType#12285, workflowType#12286, workflowId#12287, activityAttempt#12288, gitCommitId#12290]
Arguments: [activityType#12285 ASC NULLS FIRST], false, 0
(25) WriteFiles
Input [92]: [jobId#12278, stageCount#12195L, totalTaskCount#12196L, minTaskCountPerStage#12197L, maxTaskCountPerStage#12198L, medianTaskCountPerStage#12199L, bytesSpilledToDiskSerializedTotal#12200L, bytesSpilledToDiskSerializedMin#12201L, bytesSpilledToDiskSerializedMax#12202L, bytesSpilledToDiskSerializedMedian#12203L, taskCpuTimeTotal#12204L, taskCpuTimeMin#12205L, taskCpuTimeMax#12206L, taskCpuTimeMedian#12207L, taskDeserializeCpuTimeTotal#12208L, taskDeserializeCpuTimeMin#12209L, taskDeserializeCpuTimeMax#12210L, taskDeserializeCpuTimeMedian#12211L, taskDeserializeTimeTotal#12212L, taskDeserializeTimeMin#12213L, taskDeserializeTimeMax#12214L, taskDeserializeTimeMedian#12215L, taskRunTimeTotal#12216L, taskRunTimeMin#12217L, taskRunTimeMax#12218L, taskRunTimeMedian#12219L, jvmGcTimeTotal#12220L, jvmGcTimeMin#12221L, jvmGcTimeMax#12222L, jvmGcTimeMedian#12223L, bytesSpilledToDiskRawTotal#12224L, bytesSpilledToDiskRawMin#12225L, bytesSpilledToDiskRawMax#12226L, bytesSpilledToDiskRawMedian#12227L, resultSerializationTimeTotal#12228L, resultSerializationTimeMin#12229L, resultSerializationTimeMax#12230L, resultSerializationTimeMedian#12231L, resultSizeToDriverTotal#12232L, resultSizeToDriverMin#12233L, resultSizeToDriverMax#12234L, resultSizeToDriverMedian#12235L, taskPeakExecutionMemoryMin#12236L, taskPeakExecutionMemoryMax#12237L, taskPeakExecutionMemoryMedian#12238L, persistencyBytesReadTotal#12239L, persistencyBytesReadMin#12240L, persistencyBytesReadMax#12241L, persistencyBytesReadMedian#12242L, persistencyRecordsReadTotal#12243L, persistencyRecordsReadMin#12244L, persistencyRecordsReadMax#12245L, persistencyRecordsReadMedian#12246L, persistencyBytesWrittenTotal#12247L, persistencyBytesWrittenMin#12248L, persistencyBytesWrittenMax#12249L, persistencyBytesWrittenMedian#12250L, persistencyRecordsWrittenTotal#12251L, persistencyRecordsWrittenMin#12252L, persistencyRecordsWrittenMax#12253L, persistencyRecordsWrittenMedian#12254L, shuffleConsumeRecordsReadTotal#12255L, shuffleConsumeRemoteBlocksFetchedTotal#12256L, shuffleConsumeLocalBlocksFetchedTotal#12257L, shuffleConsumeTotalBlocksFetchedTotal#12258L, shuffleConsumeRemoteBytesReadTotal#12259L, shuffleConsumeLocalBytesReadTotal#12260L, shuffleConsumeTotalBytesReadTotal#12261L, shuffleConsumeRemoteBytesReadToDiskTotal#12262L, shuffleConsumeFetchWaitTimeTotal#12263L, shuffleProduceBytesWrittenTotal#12264L, shuffleProduceRecordsWrittenTotal#12265L, shuffleProduceWriteTimeTotal#12266L, peakExecutionMemory#12268L, peakExecutionMemoryCliqueDuration#12269L, peakExecutionMemoryCliqueSize#12270L, rddStorageDiskSizeTotal#12272L, rddStorageMemSizeTotal#12273L, rddNumCachedPartitionsTotal#12274, rddNumPartitionsTotal#12275, numberOfExecutors#12276, replenishmentRunId#12279L, tenantId#12280, cornerstoneTenantId#12281L, marketUnit#12282, scenario#12283, activityId#12284, activityType#12285, workflowType#12286, workflowId#12287, activityAttempt#12288, gitCommitId#12290]
(26) Execute InsertIntoHadoopFsRelationCommand
Input: []
Arguments: hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/internal/performance-metrics/10000002105, false, [activityType#12285], Parquet, [__partition_columns=["activityType"], path=hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/internal/performance-metrics/10000002105], 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#12194, stageCount#12195L, totalTaskCount#12196L, minTaskCountPerStage#12197L, maxTaskCountPerStage#12198L, medianTaskCountPerStage#12199L, bytesSpilledToDiskSerializedTotal#12200L, bytesSpilledToDiskSerializedMin#12201L, bytesSpilledToDiskSerializedMax#12202L, bytesSpilledToDiskSerializedMedian#12203L, taskCpuTimeTotal#12204L, taskCpuTimeMin#12205L, taskCpuTimeMax#12206L, taskCpuTimeMedian#12207L, taskDeserializeCpuTimeTotal#12208L, taskDeserializeCpuTimeMin#12209L, taskDeserializeCpuTimeMax#12210L, taskDeserializeCpuTimeMedian#12211L, taskDeserializeTimeTotal#12212L, taskDeserializeTimeMin#12213L, taskDeserializeTimeMax#12214L, taskDeserializeTimeMedian#12215L, taskRunTimeTotal#12216L, taskRunTimeMin#12217L, taskRunTimeMax#12218L, taskRunTimeMedian#12219L, jvmGcTimeTotal#12220L, jvmGcTimeMin#12221L, jvmGcTimeMax#12222L, jvmGcTimeMedian#12223L, bytesSpilledToDiskRawTotal#12224L, bytesSpilledToDiskRawMin#12225L, bytesSpilledToDiskRawMax#12226L, bytesSpilledToDiskRawMedian#12227L, resultSerializationTimeTotal#12228L, resultSerializationTimeMin#12229L, resultSerializationTimeMax#12230L, resultSerializationTimeMedian#12231L, resultSizeToDriverTotal#12232L, resultSizeToDriverMin#12233L, resultSizeToDriverMax#12234L, resultSizeToDriverMedian#12235L, taskPeakExecutionMemoryMin#12236L, taskPeakExecutionMemoryMax#12237L, taskPeakExecutionMemoryMedian#12238L, persistencyBytesReadTotal#12239L, persistencyBytesReadMin#12240L, persistencyBytesReadMax#12241L, persistencyBytesReadMedian#12242L, persistencyRecordsReadTotal#12243L, persistencyRecordsReadMin#12244L, persistencyRecordsReadMax#12245L, persistencyRecordsReadMedian#12246L, persistencyBytesWrittenTotal#12247L, persistencyBytesWrittenMin#12248L, persistencyBytesWrittenMax#12249L, persistencyBytesWrittenMedian#12250L, persistencyRecordsWrittenTotal#12251L, persistencyRecordsWrittenMin#12252L, persistencyRecordsWrittenMax#12253L, persistencyRecordsWrittenMedian#12254L, shuffleConsumeRecordsReadTotal#12255L, shuffleConsumeRemoteBlocksFetchedTotal#12256L, shuffleConsumeLocalBlocksFetchedTotal#12257L, shuffleConsumeTotalBlocksFetchedTotal#12258L, shuffleConsumeRemoteBytesReadTotal#12259L, shuffleConsumeLocalBytesReadTotal#12260L, shuffleConsumeTotalBytesReadTotal#12261L, shuffleConsumeRemoteBytesReadToDiskTotal#12262L, shuffleConsumeFetchWaitTimeTotal#12263L, shuffleProduceBytesWrittenTotal#12264L, shuffleProduceRecordsWrittenTotal#12265L, shuffleProduceWriteTimeTotal#12266L]
Arguments: [jobId#12194 ASC NULLS FIRST], false, 0
(29) Sort
Input [4]: [jobId#12267, peakExecutionMemory#12268L, peakExecutionMemoryCliqueDuration#12269L, peakExecutionMemoryCliqueSize#12270L]
Arguments: [jobId#12267 ASC NULLS FIRST], false, 0
(30) SortMergeJoin
Left keys [1]: [jobId#12194]
Right keys [1]: [jobId#12267]
Join type: FullOuter
Join condition: None
(31) Project
Output [76]: [coalesce(jobId#12194, jobId#12267) AS jobId#12277, stageCount#12195L, totalTaskCount#12196L, minTaskCountPerStage#12197L, maxTaskCountPerStage#12198L, medianTaskCountPerStage#12199L, bytesSpilledToDiskSerializedTotal#12200L, bytesSpilledToDiskSerializedMin#12201L, bytesSpilledToDiskSerializedMax#12202L, bytesSpilledToDiskSerializedMedian#12203L, taskCpuTimeTotal#12204L, taskCpuTimeMin#12205L, taskCpuTimeMax#12206L, taskCpuTimeMedian#12207L, taskDeserializeCpuTimeTotal#12208L, taskDeserializeCpuTimeMin#12209L, taskDeserializeCpuTimeMax#12210L, taskDeserializeCpuTimeMedian#12211L, taskDeserializeTimeTotal#12212L, taskDeserializeTimeMin#12213L, taskDeserializeTimeMax#12214L, taskDeserializeTimeMedian#12215L, taskRunTimeTotal#12216L, taskRunTimeMin#12217L, taskRunTimeMax#12218L, taskRunTimeMedian#12219L, jvmGcTimeTotal#12220L, jvmGcTimeMin#12221L, jvmGcTimeMax#12222L, jvmGcTimeMedian#12223L, bytesSpilledToDiskRawTotal#12224L, bytesSpilledToDiskRawMin#12225L, bytesSpilledToDiskRawMax#12226L, bytesSpilledToDiskRawMedian#12227L, resultSerializationTimeTotal#12228L, resultSerializationTimeMin#12229L, resultSerializationTimeMax#12230L, resultSerializationTimeMedian#12231L, resultSizeToDriverTotal#12232L, resultSizeToDriverMin#12233L, resultSizeToDriverMax#12234L, resultSizeToDriverMedian#12235L, taskPeakExecutionMemoryMin#12236L, taskPeakExecutionMemoryMax#12237L, taskPeakExecutionMemoryMedian#12238L, persistencyBytesReadTotal#12239L, persistencyBytesReadMin#12240L, persistencyBytesReadMax#12241L, persistencyBytesReadMedian#12242L, persistencyRecordsReadTotal#12243L, persistencyRecordsReadMin#12244L, persistencyRecordsReadMax#12245L, persistencyRecordsReadMedian#12246L, persistencyBytesWrittenTotal#12247L, persistencyBytesWrittenMin#12248L, persistencyBytesWrittenMax#12249L, persistencyBytesWrittenMedian#12250L, persistencyRecordsWrittenTotal#12251L, persistencyRecordsWrittenMin#12252L, persistencyRecordsWrittenMax#12253L, persistencyRecordsWrittenMedian#12254L, shuffleConsumeRecordsReadTotal#12255L, shuffleConsumeRemoteBlocksFetchedTotal#12256L, shuffleConsumeLocalBlocksFetchedTotal#12257L, shuffleConsumeTotalBlocksFetchedTotal#12258L, shuffleConsumeRemoteBytesReadTotal#12259L, shuffleConsumeLocalBytesReadTotal#12260L, shuffleConsumeTotalBytesReadTotal#12261L, shuffleConsumeRemoteBytesReadToDiskTotal#12262L, shuffleConsumeFetchWaitTimeTotal#12263L, shuffleProduceBytesWrittenTotal#12264L, shuffleProduceRecordsWrittenTotal#12265L, shuffleProduceWriteTimeTotal#12266L, peakExecutionMemory#12268L, peakExecutionMemoryCliqueDuration#12269L, peakExecutionMemoryCliqueSize#12270L]
Input [77]: [jobId#12194, stageCount#12195L, totalTaskCount#12196L, minTaskCountPerStage#12197L, maxTaskCountPerStage#12198L, medianTaskCountPerStage#12199L, bytesSpilledToDiskSerializedTotal#12200L, bytesSpilledToDiskSerializedMin#12201L, bytesSpilledToDiskSerializedMax#12202L, bytesSpilledToDiskSerializedMedian#12203L, taskCpuTimeTotal#12204L, taskCpuTimeMin#12205L, taskCpuTimeMax#12206L, taskCpuTimeMedian#12207L, taskDeserializeCpuTimeTotal#12208L, taskDeserializeCpuTimeMin#12209L, taskDeserializeCpuTimeMax#12210L, taskDeserializeCpuTimeMedian#12211L, taskDeserializeTimeTotal#12212L, taskDeserializeTimeMin#12213L, taskDeserializeTimeMax#12214L, taskDeserializeTimeMedian#12215L, taskRunTimeTotal#12216L, taskRunTimeMin#12217L, taskRunTimeMax#12218L, taskRunTimeMedian#12219L, jvmGcTimeTotal#12220L, jvmGcTimeMin#12221L, jvmGcTimeMax#12222L, jvmGcTimeMedian#12223L, bytesSpilledToDiskRawTotal#12224L, bytesSpilledToDiskRawMin#12225L, bytesSpilledToDiskRawMax#12226L, bytesSpilledToDiskRawMedian#12227L, resultSerializationTimeTotal#12228L, resultSerializationTimeMin#12229L, resultSerializationTimeMax#12230L, resultSerializationTimeMedian#12231L, resultSizeToDriverTotal#12232L, resultSizeToDriverMin#12233L, resultSizeToDriverMax#12234L, resultSizeToDriverMedian#12235L, taskPeakExecutionMemoryMin#12236L, taskPeakExecutionMemoryMax#12237L, taskPeakExecutionMemoryMedian#12238L, persistencyBytesReadTotal#12239L, persistencyBytesReadMin#12240L, persistencyBytesReadMax#12241L, persistencyBytesReadMedian#12242L, persistencyRecordsReadTotal#12243L, persistencyRecordsReadMin#12244L, persistencyRecordsReadMax#12245L, persistencyRecordsReadMedian#12246L, persistencyBytesWrittenTotal#12247L, persistencyBytesWrittenMin#12248L, persistencyBytesWrittenMax#12249L, persistencyBytesWrittenMedian#12250L, persistencyRecordsWrittenTotal#12251L, persistencyRecordsWrittenMin#12252L, persistencyRecordsWrittenMax#12253L, persistencyRecordsWrittenMedian#12254L, shuffleConsumeRecordsReadTotal#12255L, shuffleConsumeRemoteBlocksFetchedTotal#12256L, shuffleConsumeLocalBlocksFetchedTotal#12257L, shuffleConsumeTotalBlocksFetchedTotal#12258L, shuffleConsumeRemoteBytesReadTotal#12259L, shuffleConsumeLocalBytesReadTotal#12260L, shuffleConsumeTotalBytesReadTotal#12261L, shuffleConsumeRemoteBytesReadToDiskTotal#12262L, shuffleConsumeFetchWaitTimeTotal#12263L, shuffleProduceBytesWrittenTotal#12264L, shuffleProduceRecordsWrittenTotal#12265L, shuffleProduceWriteTimeTotal#12266L, jobId#12267, peakExecutionMemory#12268L, peakExecutionMemoryCliqueDuration#12269L, peakExecutionMemoryCliqueSize#12270L]
(32) Exchange
Input [76]: [jobId#12277, stageCount#12195L, totalTaskCount#12196L, minTaskCountPerStage#12197L, maxTaskCountPerStage#12198L, medianTaskCountPerStage#12199L, bytesSpilledToDiskSerializedTotal#12200L, bytesSpilledToDiskSerializedMin#12201L, bytesSpilledToDiskSerializedMax#12202L, bytesSpilledToDiskSerializedMedian#12203L, taskCpuTimeTotal#12204L, taskCpuTimeMin#12205L, taskCpuTimeMax#12206L, taskCpuTimeMedian#12207L, taskDeserializeCpuTimeTotal#12208L, taskDeserializeCpuTimeMin#12209L, taskDeserializeCpuTimeMax#12210L, taskDeserializeCpuTimeMedian#12211L, taskDeserializeTimeTotal#12212L, taskDeserializeTimeMin#12213L, taskDeserializeTimeMax#12214L, taskDeserializeTimeMedian#12215L, taskRunTimeTotal#12216L, taskRunTimeMin#12217L, taskRunTimeMax#12218L, taskRunTimeMedian#12219L, jvmGcTimeTotal#12220L, jvmGcTimeMin#12221L, jvmGcTimeMax#12222L, jvmGcTimeMedian#12223L, bytesSpilledToDiskRawTotal#12224L, bytesSpilledToDiskRawMin#12225L, bytesSpilledToDiskRawMax#12226L, bytesSpilledToDiskRawMedian#12227L, resultSerializationTimeTotal#12228L, resultSerializationTimeMin#12229L, resultSerializationTimeMax#12230L, resultSerializationTimeMedian#12231L, resultSizeToDriverTotal#12232L, resultSizeToDriverMin#12233L, resultSizeToDriverMax#12234L, resultSizeToDriverMedian#12235L, taskPeakExecutionMemoryMin#12236L, taskPeakExecutionMemoryMax#12237L, taskPeakExecutionMemoryMedian#12238L, persistencyBytesReadTotal#12239L, persistencyBytesReadMin#12240L, persistencyBytesReadMax#12241L, persistencyBytesReadMedian#12242L, persistencyRecordsReadTotal#12243L, persistencyRecordsReadMin#12244L, persistencyRecordsReadMax#12245L, persistencyRecordsReadMedian#12246L, persistencyBytesWrittenTotal#12247L, persistencyBytesWrittenMin#12248L, persistencyBytesWrittenMax#12249L, persistencyBytesWrittenMedian#12250L, persistencyRecordsWrittenTotal#12251L, persistencyRecordsWrittenMin#12252L, persistencyRecordsWrittenMax#12253L, persistencyRecordsWrittenMedian#12254L, shuffleConsumeRecordsReadTotal#12255L, shuffleConsumeRemoteBlocksFetchedTotal#12256L, shuffleConsumeLocalBlocksFetchedTotal#12257L, shuffleConsumeTotalBlocksFetchedTotal#12258L, shuffleConsumeRemoteBytesReadTotal#12259L, shuffleConsumeLocalBytesReadTotal#12260L, shuffleConsumeTotalBytesReadTotal#12261L, shuffleConsumeRemoteBytesReadToDiskTotal#12262L, shuffleConsumeFetchWaitTimeTotal#12263L, shuffleProduceBytesWrittenTotal#12264L, shuffleProduceRecordsWrittenTotal#12265L, shuffleProduceWriteTimeTotal#12266L, peakExecutionMemory#12268L, peakExecutionMemoryCliqueDuration#12269L, peakExecutionMemoryCliqueSize#12270L]
Arguments: hashpartitioning(jobId#12277, 20), ENSURE_REQUIREMENTS, [plan_id=4461]
(33) Sort
Input [76]: [jobId#12277, stageCount#12195L, totalTaskCount#12196L, minTaskCountPerStage#12197L, maxTaskCountPerStage#12198L, medianTaskCountPerStage#12199L, bytesSpilledToDiskSerializedTotal#12200L, bytesSpilledToDiskSerializedMin#12201L, bytesSpilledToDiskSerializedMax#12202L, bytesSpilledToDiskSerializedMedian#12203L, taskCpuTimeTotal#12204L, taskCpuTimeMin#12205L, taskCpuTimeMax#12206L, taskCpuTimeMedian#12207L, taskDeserializeCpuTimeTotal#12208L, taskDeserializeCpuTimeMin#12209L, taskDeserializeCpuTimeMax#12210L, taskDeserializeCpuTimeMedian#12211L, taskDeserializeTimeTotal#12212L, taskDeserializeTimeMin#12213L, taskDeserializeTimeMax#12214L, taskDeserializeTimeMedian#12215L, taskRunTimeTotal#12216L, taskRunTimeMin#12217L, taskRunTimeMax#12218L, taskRunTimeMedian#12219L, jvmGcTimeTotal#12220L, jvmGcTimeMin#12221L, jvmGcTimeMax#12222L, jvmGcTimeMedian#12223L, bytesSpilledToDiskRawTotal#12224L, bytesSpilledToDiskRawMin#12225L, bytesSpilledToDiskRawMax#12226L, bytesSpilledToDiskRawMedian#12227L, resultSerializationTimeTotal#12228L, resultSerializationTimeMin#12229L, resultSerializationTimeMax#12230L, resultSerializationTimeMedian#12231L, resultSizeToDriverTotal#12232L, resultSizeToDriverMin#12233L, resultSizeToDriverMax#12234L, resultSizeToDriverMedian#12235L, taskPeakExecutionMemoryMin#12236L, taskPeakExecutionMemoryMax#12237L, taskPeakExecutionMemoryMedian#12238L, persistencyBytesReadTotal#12239L, persistencyBytesReadMin#12240L, persistencyBytesReadMax#12241L, persistencyBytesReadMedian#12242L, persistencyRecordsReadTotal#12243L, persistencyRecordsReadMin#12244L, persistencyRecordsReadMax#12245L, persistencyRecordsReadMedian#12246L, persistencyBytesWrittenTotal#12247L, persistencyBytesWrittenMin#12248L, persistencyBytesWrittenMax#12249L, persistencyBytesWrittenMedian#12250L, persistencyRecordsWrittenTotal#12251L, persistencyRecordsWrittenMin#12252L, persistencyRecordsWrittenMax#12253L, persistencyRecordsWrittenMedian#12254L, shuffleConsumeRecordsReadTotal#12255L, shuffleConsumeRemoteBlocksFetchedTotal#12256L, shuffleConsumeLocalBlocksFetchedTotal#12257L, shuffleConsumeTotalBlocksFetchedTotal#12258L, shuffleConsumeRemoteBytesReadTotal#12259L, shuffleConsumeLocalBytesReadTotal#12260L, shuffleConsumeTotalBytesReadTotal#12261L, shuffleConsumeRemoteBytesReadToDiskTotal#12262L, shuffleConsumeFetchWaitTimeTotal#12263L, shuffleProduceBytesWrittenTotal#12264L, shuffleProduceRecordsWrittenTotal#12265L, shuffleProduceWriteTimeTotal#12266L, peakExecutionMemory#12268L, peakExecutionMemoryCliqueDuration#12269L, peakExecutionMemoryCliqueSize#12270L]
Arguments: [jobId#12277 ASC NULLS FIRST], false, 0
(34) Sort
Input [6]: [jobId#12271, rddStorageDiskSizeTotal#12272L, rddStorageMemSizeTotal#12273L, rddNumCachedPartitionsTotal#12274, rddNumPartitionsTotal#12275, numberOfExecutors#12276]
Arguments: [jobId#12271 ASC NULLS FIRST], false, 0
(35) SortMergeJoin
Left keys [1]: [jobId#12277]
Right keys [1]: [jobId#12271]
Join type: FullOuter
Join condition: None
(36) Project
Output [92]: [coalesce(jobId#12277, jobId#12271) AS jobId#12278, stageCount#12195L, totalTaskCount#12196L, minTaskCountPerStage#12197L, maxTaskCountPerStage#12198L, medianTaskCountPerStage#12199L, bytesSpilledToDiskSerializedTotal#12200L, bytesSpilledToDiskSerializedMin#12201L, bytesSpilledToDiskSerializedMax#12202L, bytesSpilledToDiskSerializedMedian#12203L, taskCpuTimeTotal#12204L, taskCpuTimeMin#12205L, taskCpuTimeMax#12206L, taskCpuTimeMedian#12207L, taskDeserializeCpuTimeTotal#12208L, taskDeserializeCpuTimeMin#12209L, taskDeserializeCpuTimeMax#12210L, taskDeserializeCpuTimeMedian#12211L, taskDeserializeTimeTotal#12212L, taskDeserializeTimeMin#12213L, taskDeserializeTimeMax#12214L, taskDeserializeTimeMedian#12215L, taskRunTimeTotal#12216L, taskRunTimeMin#12217L, taskRunTimeMax#12218L, taskRunTimeMedian#12219L, jvmGcTimeTotal#12220L, jvmGcTimeMin#12221L, jvmGcTimeMax#12222L, jvmGcTimeMedian#12223L, bytesSpilledToDiskRawTotal#12224L, bytesSpilledToDiskRawMin#12225L, bytesSpilledToDiskRawMax#12226L, bytesSpilledToDiskRawMedian#12227L, resultSerializationTimeTotal#12228L, resultSerializationTimeMin#12229L, resultSerializationTimeMax#12230L, resultSerializationTimeMedian#12231L, resultSizeToDriverTotal#12232L, resultSizeToDriverMin#12233L, resultSizeToDriverMax#12234L, resultSizeToDriverMedian#12235L, taskPeakExecutionMemoryMin#12236L, taskPeakExecutionMemoryMax#12237L, taskPeakExecutionMemoryMedian#12238L, persistencyBytesReadTotal#12239L, persistencyBytesReadMin#12240L, persistencyBytesReadMax#12241L, persistencyBytesReadMedian#12242L, persistencyRecordsReadTotal#12243L, persistencyRecordsReadMin#12244L, persistencyRecordsReadMax#12245L, persistencyRecordsReadMedian#12246L, persistencyBytesWrittenTotal#12247L, persistencyBytesWrittenMin#12248L, persistencyBytesWrittenMax#12249L, persistencyBytesWrittenMedian#12250L, persistencyRecordsWrittenTotal#12251L, persistencyRecordsWrittenMin#12252L, persistencyRecordsWrittenMax#12253L, persistencyRecordsWrittenMedian#12254L, shuffleConsumeRecordsReadTotal#12255L, shuffleConsumeRemoteBlocksFetchedTotal#12256L, shuffleConsumeLocalBlocksFetchedTotal#12257L, shuffleConsumeTotalBlocksFetchedTotal#12258L, shuffleConsumeRemoteBytesReadTotal#12259L, shuffleConsumeLocalBytesReadTotal#12260L, shuffleConsumeTotalBytesReadTotal#12261L, shuffleConsumeRemoteBytesReadToDiskTotal#12262L, shuffleConsumeFetchWaitTimeTotal#12263L, shuffleProduceBytesWrittenTotal#12264L, shuffleProduceRecordsWrittenTotal#12265L, shuffleProduceWriteTimeTotal#12266L, peakExecutionMemory#12268L, peakExecutionMemoryCliqueDuration#12269L, peakExecutionMemoryCliqueSize#12270L, rddStorageDiskSizeTotal#12272L, rddStorageMemSizeTotal#12273L, rddNumCachedPartitionsTotal#12274, rddNumPartitionsTotal#12275, numberOfExecutors#12276, 10000002105 AS replenishmentRunId#12279L, 6944346648028224943 AS tenantId#12280, 8378 AS cornerstoneTenantId#12281L, Daily_grocery AS marketUnit#12282, STANDARD AS scenario#12283, 3961f109-b13f-3cf7-ae84-59fa48c4a71b AS activityId#12284, RunStreamWithId AS activityType#12285, CalculateOrderProposalsWorkflow AS workflowType#12286, 79900f79-a3ad-3739-934c-f6e932e71ecc AS workflowId#12287, 3 AS activityAttempt#12288, AS gitCommitId#12290]
Input [82]: [jobId#12277, stageCount#12195L, totalTaskCount#12196L, minTaskCountPerStage#12197L, maxTaskCountPerStage#12198L, medianTaskCountPerStage#12199L, bytesSpilledToDiskSerializedTotal#12200L, bytesSpilledToDiskSerializedMin#12201L, bytesSpilledToDiskSerializedMax#12202L, bytesSpilledToDiskSerializedMedian#12203L, taskCpuTimeTotal#12204L, taskCpuTimeMin#12205L, taskCpuTimeMax#12206L, taskCpuTimeMedian#12207L, taskDeserializeCpuTimeTotal#12208L, taskDeserializeCpuTimeMin#12209L, taskDeserializeCpuTimeMax#12210L, taskDeserializeCpuTimeMedian#12211L, taskDeserializeTimeTotal#12212L, taskDeserializeTimeMin#12213L, taskDeserializeTimeMax#12214L, taskDeserializeTimeMedian#12215L, taskRunTimeTotal#12216L, taskRunTimeMin#12217L, taskRunTimeMax#12218L, taskRunTimeMedian#12219L, jvmGcTimeTotal#12220L, jvmGcTimeMin#12221L, jvmGcTimeMax#12222L, jvmGcTimeMedian#12223L, bytesSpilledToDiskRawTotal#12224L, bytesSpilledToDiskRawMin#12225L, bytesSpilledToDiskRawMax#12226L, bytesSpilledToDiskRawMedian#12227L, resultSerializationTimeTotal#12228L, resultSerializationTimeMin#12229L, resultSerializationTimeMax#12230L, resultSerializationTimeMedian#12231L, resultSizeToDriverTotal#12232L, resultSizeToDriverMin#12233L, resultSizeToDriverMax#12234L, resultSizeToDriverMedian#12235L, taskPeakExecutionMemoryMin#12236L, taskPeakExecutionMemoryMax#12237L, taskPeakExecutionMemoryMedian#12238L, persistencyBytesReadTotal#12239L, persistencyBytesReadMin#12240L, persistencyBytesReadMax#12241L, persistencyBytesReadMedian#12242L, persistencyRecordsReadTotal#12243L, persistencyRecordsReadMin#12244L, persistencyRecordsReadMax#12245L, persistencyRecordsReadMedian#12246L, persistencyBytesWrittenTotal#12247L, persistencyBytesWrittenMin#12248L, persistencyBytesWrittenMax#12249L, persistencyBytesWrittenMedian#12250L, persistencyRecordsWrittenTotal#12251L, persistencyRecordsWrittenMin#12252L, persistencyRecordsWrittenMax#12253L, persistencyRecordsWrittenMedian#12254L, shuffleConsumeRecordsReadTotal#12255L, shuffleConsumeRemoteBlocksFetchedTotal#12256L, shuffleConsumeLocalBlocksFetchedTotal#12257L, shuffleConsumeTotalBlocksFetchedTotal#12258L, shuffleConsumeRemoteBytesReadTotal#12259L, shuffleConsumeLocalBytesReadTotal#12260L, shuffleConsumeTotalBytesReadTotal#12261L, shuffleConsumeRemoteBytesReadToDiskTotal#12262L, shuffleConsumeFetchWaitTimeTotal#12263L, shuffleProduceBytesWrittenTotal#12264L, shuffleProduceRecordsWrittenTotal#12265L, shuffleProduceWriteTimeTotal#12266L, peakExecutionMemory#12268L, peakExecutionMemoryCliqueDuration#12269L, peakExecutionMemoryCliqueSize#12270L, jobId#12271, rddStorageDiskSizeTotal#12272L, rddStorageMemSizeTotal#12273L, rddNumCachedPartitionsTotal#12274, rddNumPartitionsTotal#12275, numberOfExecutors#12276]
(37) Sort
Input [92]: [jobId#12278, stageCount#12195L, totalTaskCount#12196L, minTaskCountPerStage#12197L, maxTaskCountPerStage#12198L, medianTaskCountPerStage#12199L, bytesSpilledToDiskSerializedTotal#12200L, bytesSpilledToDiskSerializedMin#12201L, bytesSpilledToDiskSerializedMax#12202L, bytesSpilledToDiskSerializedMedian#12203L, taskCpuTimeTotal#12204L, taskCpuTimeMin#12205L, taskCpuTimeMax#12206L, taskCpuTimeMedian#12207L, taskDeserializeCpuTimeTotal#12208L, taskDeserializeCpuTimeMin#12209L, taskDeserializeCpuTimeMax#12210L, taskDeserializeCpuTimeMedian#12211L, taskDeserializeTimeTotal#12212L, taskDeserializeTimeMin#12213L, taskDeserializeTimeMax#12214L, taskDeserializeTimeMedian#12215L, taskRunTimeTotal#12216L, taskRunTimeMin#12217L, taskRunTimeMax#12218L, taskRunTimeMedian#12219L, jvmGcTimeTotal#12220L, jvmGcTimeMin#12221L, jvmGcTimeMax#12222L, jvmGcTimeMedian#12223L, bytesSpilledToDiskRawTotal#12224L, bytesSpilledToDiskRawMin#12225L, bytesSpilledToDiskRawMax#12226L, bytesSpilledToDiskRawMedian#12227L, resultSerializationTimeTotal#12228L, resultSerializationTimeMin#12229L, resultSerializationTimeMax#12230L, resultSerializationTimeMedian#12231L, resultSizeToDriverTotal#12232L, resultSizeToDriverMin#12233L, resultSizeToDriverMax#12234L, resultSizeToDriverMedian#12235L, taskPeakExecutionMemoryMin#12236L, taskPeakExecutionMemoryMax#12237L, taskPeakExecutionMemoryMedian#12238L, persistencyBytesReadTotal#12239L, persistencyBytesReadMin#12240L, persistencyBytesReadMax#12241L, persistencyBytesReadMedian#12242L, persistencyRecordsReadTotal#12243L, persistencyRecordsReadMin#12244L, persistencyRecordsReadMax#12245L, persistencyRecordsReadMedian#12246L, persistencyBytesWrittenTotal#12247L, persistencyBytesWrittenMin#12248L, persistencyBytesWrittenMax#12249L, persistencyBytesWrittenMedian#12250L, persistencyRecordsWrittenTotal#12251L, persistencyRecordsWrittenMin#12252L, persistencyRecordsWrittenMax#12253L, persistencyRecordsWrittenMedian#12254L, shuffleConsumeRecordsReadTotal#12255L, shuffleConsumeRemoteBlocksFetchedTotal#12256L, shuffleConsumeLocalBlocksFetchedTotal#12257L, shuffleConsumeTotalBlocksFetchedTotal#12258L, shuffleConsumeRemoteBytesReadTotal#12259L, shuffleConsumeLocalBytesReadTotal#12260L, shuffleConsumeTotalBytesReadTotal#12261L, shuffleConsumeRemoteBytesReadToDiskTotal#12262L, shuffleConsumeFetchWaitTimeTotal#12263L, shuffleProduceBytesWrittenTotal#12264L, shuffleProduceRecordsWrittenTotal#12265L, shuffleProduceWriteTimeTotal#12266L, peakExecutionMemory#12268L, peakExecutionMemoryCliqueDuration#12269L, peakExecutionMemoryCliqueSize#12270L, rddStorageDiskSizeTotal#12272L, rddStorageMemSizeTotal#12273L, rddNumCachedPartitionsTotal#12274, rddNumPartitionsTotal#12275, numberOfExecutors#12276, replenishmentRunId#12279L, tenantId#12280, cornerstoneTenantId#12281L, marketUnit#12282, scenario#12283, activityId#12284, activityType#12285, workflowType#12286, workflowId#12287, activityAttempt#12288, gitCommitId#12290]
Arguments: [activityType#12285 ASC NULLS FIRST], false, 0
(38) WriteFiles
Input [92]: [jobId#12278, stageCount#12195L, totalTaskCount#12196L, minTaskCountPerStage#12197L, maxTaskCountPerStage#12198L, medianTaskCountPerStage#12199L, bytesSpilledToDiskSerializedTotal#12200L, bytesSpilledToDiskSerializedMin#12201L, bytesSpilledToDiskSerializedMax#12202L, bytesSpilledToDiskSerializedMedian#12203L, taskCpuTimeTotal#12204L, taskCpuTimeMin#12205L, taskCpuTimeMax#12206L, taskCpuTimeMedian#12207L, taskDeserializeCpuTimeTotal#12208L, taskDeserializeCpuTimeMin#12209L, taskDeserializeCpuTimeMax#12210L, taskDeserializeCpuTimeMedian#12211L, taskDeserializeTimeTotal#12212L, taskDeserializeTimeMin#12213L, taskDeserializeTimeMax#12214L, taskDeserializeTimeMedian#12215L, taskRunTimeTotal#12216L, taskRunTimeMin#12217L, taskRunTimeMax#12218L, taskRunTimeMedian#12219L, jvmGcTimeTotal#12220L, jvmGcTimeMin#12221L, jvmGcTimeMax#12222L, jvmGcTimeMedian#12223L, bytesSpilledToDiskRawTotal#12224L, bytesSpilledToDiskRawMin#12225L, bytesSpilledToDiskRawMax#12226L, bytesSpilledToDiskRawMedian#12227L, resultSerializationTimeTotal#12228L, resultSerializationTimeMin#12229L, resultSerializationTimeMax#12230L, resultSerializationTimeMedian#12231L, resultSizeToDriverTotal#12232L, resultSizeToDriverMin#12233L, resultSizeToDriverMax#12234L, resultSizeToDriverMedian#12235L, taskPeakExecutionMemoryMin#12236L, taskPeakExecutionMemoryMax#12237L, taskPeakExecutionMemoryMedian#12238L, persistencyBytesReadTotal#12239L, persistencyBytesReadMin#12240L, persistencyBytesReadMax#12241L, persistencyBytesReadMedian#12242L, persistencyRecordsReadTotal#12243L, persistencyRecordsReadMin#12244L, persistencyRecordsReadMax#12245L, persistencyRecordsReadMedian#12246L, persistencyBytesWrittenTotal#12247L, persistencyBytesWrittenMin#12248L, persistencyBytesWrittenMax#12249L, persistencyBytesWrittenMedian#12250L, persistencyRecordsWrittenTotal#12251L, persistencyRecordsWrittenMin#12252L, persistencyRecordsWrittenMax#12253L, persistencyRecordsWrittenMedian#12254L, shuffleConsumeRecordsReadTotal#12255L, shuffleConsumeRemoteBlocksFetchedTotal#12256L, shuffleConsumeLocalBlocksFetchedTotal#12257L, shuffleConsumeTotalBlocksFetchedTotal#12258L, shuffleConsumeRemoteBytesReadTotal#12259L, shuffleConsumeLocalBytesReadTotal#12260L, shuffleConsumeTotalBytesReadTotal#12261L, shuffleConsumeRemoteBytesReadToDiskTotal#12262L, shuffleConsumeFetchWaitTimeTotal#12263L, shuffleProduceBytesWrittenTotal#12264L, shuffleProduceRecordsWrittenTotal#12265L, shuffleProduceWriteTimeTotal#12266L, peakExecutionMemory#12268L, peakExecutionMemoryCliqueDuration#12269L, peakExecutionMemoryCliqueSize#12270L, rddStorageDiskSizeTotal#12272L, rddStorageMemSizeTotal#12273L, rddNumCachedPartitionsTotal#12274, rddNumPartitionsTotal#12275, numberOfExecutors#12276, replenishmentRunId#12279L, tenantId#12280, cornerstoneTenantId#12281L, marketUnit#12282, scenario#12283, activityId#12284, activityType#12285, workflowType#12286, workflowId#12287, activityAttempt#12288, gitCommitId#12290]
(39) Execute InsertIntoHadoopFsRelationCommand
Input: []
Arguments: hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/internal/performance-metrics/10000002105, false, [activityType#12285], Parquet, [__partition_columns=["activityType"], path=hdlfs://2e93940d-4be8-4f12-830d-f0b8d392c03a.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/internal/performance-metrics/10000002105], 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