== 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=87.6 KiB, rowCount=142)
: +- Exchange (13)
: +- * Project (12)
: +- * SortMergeJoin FullOuter (11)
: :- * Sort (5)
: : +- AQEShuffleRead (4)
: : +- ShuffleQueryStage (3), Statistics(sizeInBytes=84.3 KiB, rowCount=142)
: : +- Exchange (2)
: : +- LocalTableScan (1)
: +- * Sort (10)
: +- AQEShuffleRead (9)
: +- ShuffleQueryStage (8), Statistics(sizeInBytes=6.7 KiB, rowCount=142)
: +- Exchange (7)
: +- LocalTableScan (6)
+- * Sort (21)
+- AQEShuffleRead (20)
+- ShuffleQueryStage (19), Statistics(sizeInBytes=8.9 KiB, rowCount=142)
+- 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#11914, stageCount#11915L, totalTaskCount#11916L, minTaskCountPerStage#11917L, maxTaskCountPerStage#11918L, medianTaskCountPerStage#11919L, bytesSpilledToDiskSerializedTotal#11920L, bytesSpilledToDiskSerializedMin#11921L, bytesSpilledToDiskSerializedMax#11922L, bytesSpilledToDiskSerializedMedian#11923L, taskCpuTimeTotal#11924L, taskCpuTimeMin#11925L, taskCpuTimeMax#11926L, taskCpuTimeMedian#11927L, taskDeserializeCpuTimeTotal#11928L, taskDeserializeCpuTimeMin#11929L, taskDeserializeCpuTimeMax#11930L, taskDeserializeCpuTimeMedian#11931L, taskDeserializeTimeTotal#11932L, taskDeserializeTimeMin#11933L, taskDeserializeTimeMax#11934L, taskDeserializeTimeMedian#11935L, taskRunTimeTotal#11936L, taskRunTimeMin#11937L, taskRunTimeMax#11938L, taskRunTimeMedian#11939L, jvmGcTimeTotal#11940L, jvmGcTimeMin#11941L, jvmGcTimeMax#11942L, jvmGcTimeMedian#11943L, bytesSpilledToDiskRawTotal#11944L, bytesSpilledToDiskRawMin#11945L, bytesSpilledToDiskRawMax#11946L, bytesSpilledToDiskRawMedian#11947L, resultSerializationTimeTotal#11948L, resultSerializationTimeMin#11949L, resultSerializationTimeMax#11950L, resultSerializationTimeMedian#11951L, resultSizeToDriverTotal#11952L, resultSizeToDriverMin#11953L, resultSizeToDriverMax#11954L, resultSizeToDriverMedian#11955L, taskPeakExecutionMemoryMin#11956L, taskPeakExecutionMemoryMax#11957L, taskPeakExecutionMemoryMedian#11958L, persistencyBytesReadTotal#11959L, persistencyBytesReadMin#11960L, persistencyBytesReadMax#11961L, persistencyBytesReadMedian#11962L, persistencyRecordsReadTotal#11963L, persistencyRecordsReadMin#11964L, persistencyRecordsReadMax#11965L, persistencyRecordsReadMedian#11966L, persistencyBytesWrittenTotal#11967L, persistencyBytesWrittenMin#11968L, persistencyBytesWrittenMax#11969L, persistencyBytesWrittenMedian#11970L, persistencyRecordsWrittenTotal#11971L, persistencyRecordsWrittenMin#11972L, persistencyRecordsWrittenMax#11973L, persistencyRecordsWrittenMedian#11974L, shuffleConsumeRecordsReadTotal#11975L, shuffleConsumeRemoteBlocksFetchedTotal#11976L, shuffleConsumeLocalBlocksFetchedTotal#11977L, shuffleConsumeTotalBlocksFetchedTotal#11978L, shuffleConsumeRemoteBytesReadTotal#11979L, shuffleConsumeLocalBytesReadTotal#11980L, shuffleConsumeTotalBytesReadTotal#11981L, shuffleConsumeRemoteBytesReadToDiskTotal#11982L, shuffleConsumeFetchWaitTimeTotal#11983L, shuffleProduceBytesWrittenTotal#11984L, shuffleProduceRecordsWrittenTotal#11985L, shuffleProduceWriteTimeTotal#11986L]
Arguments: [jobId#11914, stageCount#11915L, totalTaskCount#11916L, minTaskCountPerStage#11917L, maxTaskCountPerStage#11918L, medianTaskCountPerStage#11919L, bytesSpilledToDiskSerializedTotal#11920L, bytesSpilledToDiskSerializedMin#11921L, bytesSpilledToDiskSerializedMax#11922L, bytesSpilledToDiskSerializedMedian#11923L, taskCpuTimeTotal#11924L, taskCpuTimeMin#11925L, taskCpuTimeMax#11926L, taskCpuTimeMedian#11927L, taskDeserializeCpuTimeTotal#11928L, taskDeserializeCpuTimeMin#11929L, taskDeserializeCpuTimeMax#11930L, taskDeserializeCpuTimeMedian#11931L, taskDeserializeTimeTotal#11932L, taskDeserializeTimeMin#11933L, taskDeserializeTimeMax#11934L, taskDeserializeTimeMedian#11935L, taskRunTimeTotal#11936L, taskRunTimeMin#11937L, taskRunTimeMax#11938L, ... 48 more fields]
(2) Exchange
Input [73]: [jobId#11914, stageCount#11915L, totalTaskCount#11916L, minTaskCountPerStage#11917L, maxTaskCountPerStage#11918L, medianTaskCountPerStage#11919L, bytesSpilledToDiskSerializedTotal#11920L, bytesSpilledToDiskSerializedMin#11921L, bytesSpilledToDiskSerializedMax#11922L, bytesSpilledToDiskSerializedMedian#11923L, taskCpuTimeTotal#11924L, taskCpuTimeMin#11925L, taskCpuTimeMax#11926L, taskCpuTimeMedian#11927L, taskDeserializeCpuTimeTotal#11928L, taskDeserializeCpuTimeMin#11929L, taskDeserializeCpuTimeMax#11930L, taskDeserializeCpuTimeMedian#11931L, taskDeserializeTimeTotal#11932L, taskDeserializeTimeMin#11933L, taskDeserializeTimeMax#11934L, taskDeserializeTimeMedian#11935L, taskRunTimeTotal#11936L, taskRunTimeMin#11937L, taskRunTimeMax#11938L, taskRunTimeMedian#11939L, jvmGcTimeTotal#11940L, jvmGcTimeMin#11941L, jvmGcTimeMax#11942L, jvmGcTimeMedian#11943L, bytesSpilledToDiskRawTotal#11944L, bytesSpilledToDiskRawMin#11945L, bytesSpilledToDiskRawMax#11946L, bytesSpilledToDiskRawMedian#11947L, resultSerializationTimeTotal#11948L, resultSerializationTimeMin#11949L, resultSerializationTimeMax#11950L, resultSerializationTimeMedian#11951L, resultSizeToDriverTotal#11952L, resultSizeToDriverMin#11953L, resultSizeToDriverMax#11954L, resultSizeToDriverMedian#11955L, taskPeakExecutionMemoryMin#11956L, taskPeakExecutionMemoryMax#11957L, taskPeakExecutionMemoryMedian#11958L, persistencyBytesReadTotal#11959L, persistencyBytesReadMin#11960L, persistencyBytesReadMax#11961L, persistencyBytesReadMedian#11962L, persistencyRecordsReadTotal#11963L, persistencyRecordsReadMin#11964L, persistencyRecordsReadMax#11965L, persistencyRecordsReadMedian#11966L, persistencyBytesWrittenTotal#11967L, persistencyBytesWrittenMin#11968L, persistencyBytesWrittenMax#11969L, persistencyBytesWrittenMedian#11970L, persistencyRecordsWrittenTotal#11971L, persistencyRecordsWrittenMin#11972L, persistencyRecordsWrittenMax#11973L, persistencyRecordsWrittenMedian#11974L, shuffleConsumeRecordsReadTotal#11975L, shuffleConsumeRemoteBlocksFetchedTotal#11976L, shuffleConsumeLocalBlocksFetchedTotal#11977L, shuffleConsumeTotalBlocksFetchedTotal#11978L, shuffleConsumeRemoteBytesReadTotal#11979L, shuffleConsumeLocalBytesReadTotal#11980L, shuffleConsumeTotalBytesReadTotal#11981L, shuffleConsumeRemoteBytesReadToDiskTotal#11982L, shuffleConsumeFetchWaitTimeTotal#11983L, shuffleProduceBytesWrittenTotal#11984L, shuffleProduceRecordsWrittenTotal#11985L, shuffleProduceWriteTimeTotal#11986L]
Arguments: hashpartitioning(jobId#11914, 37), ENSURE_REQUIREMENTS, [plan_id=112339]
(3) ShuffleQueryStage
Output [73]: [jobId#11914, stageCount#11915L, totalTaskCount#11916L, minTaskCountPerStage#11917L, maxTaskCountPerStage#11918L, medianTaskCountPerStage#11919L, bytesSpilledToDiskSerializedTotal#11920L, bytesSpilledToDiskSerializedMin#11921L, bytesSpilledToDiskSerializedMax#11922L, bytesSpilledToDiskSerializedMedian#11923L, taskCpuTimeTotal#11924L, taskCpuTimeMin#11925L, taskCpuTimeMax#11926L, taskCpuTimeMedian#11927L, taskDeserializeCpuTimeTotal#11928L, taskDeserializeCpuTimeMin#11929L, taskDeserializeCpuTimeMax#11930L, taskDeserializeCpuTimeMedian#11931L, taskDeserializeTimeTotal#11932L, taskDeserializeTimeMin#11933L, taskDeserializeTimeMax#11934L, taskDeserializeTimeMedian#11935L, taskRunTimeTotal#11936L, taskRunTimeMin#11937L, taskRunTimeMax#11938L, taskRunTimeMedian#11939L, jvmGcTimeTotal#11940L, jvmGcTimeMin#11941L, jvmGcTimeMax#11942L, jvmGcTimeMedian#11943L, bytesSpilledToDiskRawTotal#11944L, bytesSpilledToDiskRawMin#11945L, bytesSpilledToDiskRawMax#11946L, bytesSpilledToDiskRawMedian#11947L, resultSerializationTimeTotal#11948L, resultSerializationTimeMin#11949L, resultSerializationTimeMax#11950L, resultSerializationTimeMedian#11951L, resultSizeToDriverTotal#11952L, resultSizeToDriverMin#11953L, resultSizeToDriverMax#11954L, resultSizeToDriverMedian#11955L, taskPeakExecutionMemoryMin#11956L, taskPeakExecutionMemoryMax#11957L, taskPeakExecutionMemoryMedian#11958L, persistencyBytesReadTotal#11959L, persistencyBytesReadMin#11960L, persistencyBytesReadMax#11961L, persistencyBytesReadMedian#11962L, persistencyRecordsReadTotal#11963L, persistencyRecordsReadMin#11964L, persistencyRecordsReadMax#11965L, persistencyRecordsReadMedian#11966L, persistencyBytesWrittenTotal#11967L, persistencyBytesWrittenMin#11968L, persistencyBytesWrittenMax#11969L, persistencyBytesWrittenMedian#11970L, persistencyRecordsWrittenTotal#11971L, persistencyRecordsWrittenMin#11972L, persistencyRecordsWrittenMax#11973L, persistencyRecordsWrittenMedian#11974L, shuffleConsumeRecordsReadTotal#11975L, shuffleConsumeRemoteBlocksFetchedTotal#11976L, shuffleConsumeLocalBlocksFetchedTotal#11977L, shuffleConsumeTotalBlocksFetchedTotal#11978L, shuffleConsumeRemoteBytesReadTotal#11979L, shuffleConsumeLocalBytesReadTotal#11980L, shuffleConsumeTotalBytesReadTotal#11981L, shuffleConsumeRemoteBytesReadToDiskTotal#11982L, shuffleConsumeFetchWaitTimeTotal#11983L, shuffleProduceBytesWrittenTotal#11984L, shuffleProduceRecordsWrittenTotal#11985L, shuffleProduceWriteTimeTotal#11986L]
Arguments: 0
(4) AQEShuffleRead
Input [73]: [jobId#11914, stageCount#11915L, totalTaskCount#11916L, minTaskCountPerStage#11917L, maxTaskCountPerStage#11918L, medianTaskCountPerStage#11919L, bytesSpilledToDiskSerializedTotal#11920L, bytesSpilledToDiskSerializedMin#11921L, bytesSpilledToDiskSerializedMax#11922L, bytesSpilledToDiskSerializedMedian#11923L, taskCpuTimeTotal#11924L, taskCpuTimeMin#11925L, taskCpuTimeMax#11926L, taskCpuTimeMedian#11927L, taskDeserializeCpuTimeTotal#11928L, taskDeserializeCpuTimeMin#11929L, taskDeserializeCpuTimeMax#11930L, taskDeserializeCpuTimeMedian#11931L, taskDeserializeTimeTotal#11932L, taskDeserializeTimeMin#11933L, taskDeserializeTimeMax#11934L, taskDeserializeTimeMedian#11935L, taskRunTimeTotal#11936L, taskRunTimeMin#11937L, taskRunTimeMax#11938L, taskRunTimeMedian#11939L, jvmGcTimeTotal#11940L, jvmGcTimeMin#11941L, jvmGcTimeMax#11942L, jvmGcTimeMedian#11943L, bytesSpilledToDiskRawTotal#11944L, bytesSpilledToDiskRawMin#11945L, bytesSpilledToDiskRawMax#11946L, bytesSpilledToDiskRawMedian#11947L, resultSerializationTimeTotal#11948L, resultSerializationTimeMin#11949L, resultSerializationTimeMax#11950L, resultSerializationTimeMedian#11951L, resultSizeToDriverTotal#11952L, resultSizeToDriverMin#11953L, resultSizeToDriverMax#11954L, resultSizeToDriverMedian#11955L, taskPeakExecutionMemoryMin#11956L, taskPeakExecutionMemoryMax#11957L, taskPeakExecutionMemoryMedian#11958L, persistencyBytesReadTotal#11959L, persistencyBytesReadMin#11960L, persistencyBytesReadMax#11961L, persistencyBytesReadMedian#11962L, persistencyRecordsReadTotal#11963L, persistencyRecordsReadMin#11964L, persistencyRecordsReadMax#11965L, persistencyRecordsReadMedian#11966L, persistencyBytesWrittenTotal#11967L, persistencyBytesWrittenMin#11968L, persistencyBytesWrittenMax#11969L, persistencyBytesWrittenMedian#11970L, persistencyRecordsWrittenTotal#11971L, persistencyRecordsWrittenMin#11972L, persistencyRecordsWrittenMax#11973L, persistencyRecordsWrittenMedian#11974L, shuffleConsumeRecordsReadTotal#11975L, shuffleConsumeRemoteBlocksFetchedTotal#11976L, shuffleConsumeLocalBlocksFetchedTotal#11977L, shuffleConsumeTotalBlocksFetchedTotal#11978L, shuffleConsumeRemoteBytesReadTotal#11979L, shuffleConsumeLocalBytesReadTotal#11980L, shuffleConsumeTotalBytesReadTotal#11981L, shuffleConsumeRemoteBytesReadToDiskTotal#11982L, shuffleConsumeFetchWaitTimeTotal#11983L, shuffleProduceBytesWrittenTotal#11984L, shuffleProduceRecordsWrittenTotal#11985L, shuffleProduceWriteTimeTotal#11986L]
Arguments: coalesced
(5) Sort [codegen id : 1]
Input [73]: [jobId#11914, stageCount#11915L, totalTaskCount#11916L, minTaskCountPerStage#11917L, maxTaskCountPerStage#11918L, medianTaskCountPerStage#11919L, bytesSpilledToDiskSerializedTotal#11920L, bytesSpilledToDiskSerializedMin#11921L, bytesSpilledToDiskSerializedMax#11922L, bytesSpilledToDiskSerializedMedian#11923L, taskCpuTimeTotal#11924L, taskCpuTimeMin#11925L, taskCpuTimeMax#11926L, taskCpuTimeMedian#11927L, taskDeserializeCpuTimeTotal#11928L, taskDeserializeCpuTimeMin#11929L, taskDeserializeCpuTimeMax#11930L, taskDeserializeCpuTimeMedian#11931L, taskDeserializeTimeTotal#11932L, taskDeserializeTimeMin#11933L, taskDeserializeTimeMax#11934L, taskDeserializeTimeMedian#11935L, taskRunTimeTotal#11936L, taskRunTimeMin#11937L, taskRunTimeMax#11938L, taskRunTimeMedian#11939L, jvmGcTimeTotal#11940L, jvmGcTimeMin#11941L, jvmGcTimeMax#11942L, jvmGcTimeMedian#11943L, bytesSpilledToDiskRawTotal#11944L, bytesSpilledToDiskRawMin#11945L, bytesSpilledToDiskRawMax#11946L, bytesSpilledToDiskRawMedian#11947L, resultSerializationTimeTotal#11948L, resultSerializationTimeMin#11949L, resultSerializationTimeMax#11950L, resultSerializationTimeMedian#11951L, resultSizeToDriverTotal#11952L, resultSizeToDriverMin#11953L, resultSizeToDriverMax#11954L, resultSizeToDriverMedian#11955L, taskPeakExecutionMemoryMin#11956L, taskPeakExecutionMemoryMax#11957L, taskPeakExecutionMemoryMedian#11958L, persistencyBytesReadTotal#11959L, persistencyBytesReadMin#11960L, persistencyBytesReadMax#11961L, persistencyBytesReadMedian#11962L, persistencyRecordsReadTotal#11963L, persistencyRecordsReadMin#11964L, persistencyRecordsReadMax#11965L, persistencyRecordsReadMedian#11966L, persistencyBytesWrittenTotal#11967L, persistencyBytesWrittenMin#11968L, persistencyBytesWrittenMax#11969L, persistencyBytesWrittenMedian#11970L, persistencyRecordsWrittenTotal#11971L, persistencyRecordsWrittenMin#11972L, persistencyRecordsWrittenMax#11973L, persistencyRecordsWrittenMedian#11974L, shuffleConsumeRecordsReadTotal#11975L, shuffleConsumeRemoteBlocksFetchedTotal#11976L, shuffleConsumeLocalBlocksFetchedTotal#11977L, shuffleConsumeTotalBlocksFetchedTotal#11978L, shuffleConsumeRemoteBytesReadTotal#11979L, shuffleConsumeLocalBytesReadTotal#11980L, shuffleConsumeTotalBytesReadTotal#11981L, shuffleConsumeRemoteBytesReadToDiskTotal#11982L, shuffleConsumeFetchWaitTimeTotal#11983L, shuffleProduceBytesWrittenTotal#11984L, shuffleProduceRecordsWrittenTotal#11985L, shuffleProduceWriteTimeTotal#11986L]
Arguments: [jobId#11914 ASC NULLS FIRST], false, 0
(6) LocalTableScan
Output [4]: [jobId#11987, peakExecutionMemory#11988L, peakExecutionMemoryCliqueDuration#11989L, peakExecutionMemoryCliqueSize#11990L]
Arguments: [jobId#11987, peakExecutionMemory#11988L, peakExecutionMemoryCliqueDuration#11989L, peakExecutionMemoryCliqueSize#11990L]
(7) Exchange
Input [4]: [jobId#11987, peakExecutionMemory#11988L, peakExecutionMemoryCliqueDuration#11989L, peakExecutionMemoryCliqueSize#11990L]
Arguments: hashpartitioning(jobId#11987, 37), ENSURE_REQUIREMENTS, [plan_id=112340]
(8) ShuffleQueryStage
Output [4]: [jobId#11987, peakExecutionMemory#11988L, peakExecutionMemoryCliqueDuration#11989L, peakExecutionMemoryCliqueSize#11990L]
Arguments: 1
(9) AQEShuffleRead
Input [4]: [jobId#11987, peakExecutionMemory#11988L, peakExecutionMemoryCliqueDuration#11989L, peakExecutionMemoryCliqueSize#11990L]
Arguments: coalesced
(10) Sort [codegen id : 2]
Input [4]: [jobId#11987, peakExecutionMemory#11988L, peakExecutionMemoryCliqueDuration#11989L, peakExecutionMemoryCliqueSize#11990L]
Arguments: [jobId#11987 ASC NULLS FIRST], false, 0
(11) SortMergeJoin [codegen id : 3]
Left keys [1]: [jobId#11914]
Right keys [1]: [jobId#11987]
Join type: FullOuter
Join condition: None
(12) Project [codegen id : 3]
Output [76]: [coalesce(jobId#11914, jobId#11987) AS jobId#11997, stageCount#11915L, totalTaskCount#11916L, minTaskCountPerStage#11917L, maxTaskCountPerStage#11918L, medianTaskCountPerStage#11919L, bytesSpilledToDiskSerializedTotal#11920L, bytesSpilledToDiskSerializedMin#11921L, bytesSpilledToDiskSerializedMax#11922L, bytesSpilledToDiskSerializedMedian#11923L, taskCpuTimeTotal#11924L, taskCpuTimeMin#11925L, taskCpuTimeMax#11926L, taskCpuTimeMedian#11927L, taskDeserializeCpuTimeTotal#11928L, taskDeserializeCpuTimeMin#11929L, taskDeserializeCpuTimeMax#11930L, taskDeserializeCpuTimeMedian#11931L, taskDeserializeTimeTotal#11932L, taskDeserializeTimeMin#11933L, taskDeserializeTimeMax#11934L, taskDeserializeTimeMedian#11935L, taskRunTimeTotal#11936L, taskRunTimeMin#11937L, taskRunTimeMax#11938L, taskRunTimeMedian#11939L, jvmGcTimeTotal#11940L, jvmGcTimeMin#11941L, jvmGcTimeMax#11942L, jvmGcTimeMedian#11943L, bytesSpilledToDiskRawTotal#11944L, bytesSpilledToDiskRawMin#11945L, bytesSpilledToDiskRawMax#11946L, bytesSpilledToDiskRawMedian#11947L, resultSerializationTimeTotal#11948L, resultSerializationTimeMin#11949L, resultSerializationTimeMax#11950L, resultSerializationTimeMedian#11951L, resultSizeToDriverTotal#11952L, resultSizeToDriverMin#11953L, resultSizeToDriverMax#11954L, resultSizeToDriverMedian#11955L, taskPeakExecutionMemoryMin#11956L, taskPeakExecutionMemoryMax#11957L, taskPeakExecutionMemoryMedian#11958L, persistencyBytesReadTotal#11959L, persistencyBytesReadMin#11960L, persistencyBytesReadMax#11961L, persistencyBytesReadMedian#11962L, persistencyRecordsReadTotal#11963L, persistencyRecordsReadMin#11964L, persistencyRecordsReadMax#11965L, persistencyRecordsReadMedian#11966L, persistencyBytesWrittenTotal#11967L, persistencyBytesWrittenMin#11968L, persistencyBytesWrittenMax#11969L, persistencyBytesWrittenMedian#11970L, persistencyRecordsWrittenTotal#11971L, persistencyRecordsWrittenMin#11972L, persistencyRecordsWrittenMax#11973L, persistencyRecordsWrittenMedian#11974L, shuffleConsumeRecordsReadTotal#11975L, shuffleConsumeRemoteBlocksFetchedTotal#11976L, shuffleConsumeLocalBlocksFetchedTotal#11977L, shuffleConsumeTotalBlocksFetchedTotal#11978L, shuffleConsumeRemoteBytesReadTotal#11979L, shuffleConsumeLocalBytesReadTotal#11980L, shuffleConsumeTotalBytesReadTotal#11981L, shuffleConsumeRemoteBytesReadToDiskTotal#11982L, shuffleConsumeFetchWaitTimeTotal#11983L, shuffleProduceBytesWrittenTotal#11984L, shuffleProduceRecordsWrittenTotal#11985L, shuffleProduceWriteTimeTotal#11986L, peakExecutionMemory#11988L, peakExecutionMemoryCliqueDuration#11989L, peakExecutionMemoryCliqueSize#11990L]
Input [77]: [jobId#11914, stageCount#11915L, totalTaskCount#11916L, minTaskCountPerStage#11917L, maxTaskCountPerStage#11918L, medianTaskCountPerStage#11919L, bytesSpilledToDiskSerializedTotal#11920L, bytesSpilledToDiskSerializedMin#11921L, bytesSpilledToDiskSerializedMax#11922L, bytesSpilledToDiskSerializedMedian#11923L, taskCpuTimeTotal#11924L, taskCpuTimeMin#11925L, taskCpuTimeMax#11926L, taskCpuTimeMedian#11927L, taskDeserializeCpuTimeTotal#11928L, taskDeserializeCpuTimeMin#11929L, taskDeserializeCpuTimeMax#11930L, taskDeserializeCpuTimeMedian#11931L, taskDeserializeTimeTotal#11932L, taskDeserializeTimeMin#11933L, taskDeserializeTimeMax#11934L, taskDeserializeTimeMedian#11935L, taskRunTimeTotal#11936L, taskRunTimeMin#11937L, taskRunTimeMax#11938L, taskRunTimeMedian#11939L, jvmGcTimeTotal#11940L, jvmGcTimeMin#11941L, jvmGcTimeMax#11942L, jvmGcTimeMedian#11943L, bytesSpilledToDiskRawTotal#11944L, bytesSpilledToDiskRawMin#11945L, bytesSpilledToDiskRawMax#11946L, bytesSpilledToDiskRawMedian#11947L, resultSerializationTimeTotal#11948L, resultSerializationTimeMin#11949L, resultSerializationTimeMax#11950L, resultSerializationTimeMedian#11951L, resultSizeToDriverTotal#11952L, resultSizeToDriverMin#11953L, resultSizeToDriverMax#11954L, resultSizeToDriverMedian#11955L, taskPeakExecutionMemoryMin#11956L, taskPeakExecutionMemoryMax#11957L, taskPeakExecutionMemoryMedian#11958L, persistencyBytesReadTotal#11959L, persistencyBytesReadMin#11960L, persistencyBytesReadMax#11961L, persistencyBytesReadMedian#11962L, persistencyRecordsReadTotal#11963L, persistencyRecordsReadMin#11964L, persistencyRecordsReadMax#11965L, persistencyRecordsReadMedian#11966L, persistencyBytesWrittenTotal#11967L, persistencyBytesWrittenMin#11968L, persistencyBytesWrittenMax#11969L, persistencyBytesWrittenMedian#11970L, persistencyRecordsWrittenTotal#11971L, persistencyRecordsWrittenMin#11972L, persistencyRecordsWrittenMax#11973L, persistencyRecordsWrittenMedian#11974L, shuffleConsumeRecordsReadTotal#11975L, shuffleConsumeRemoteBlocksFetchedTotal#11976L, shuffleConsumeLocalBlocksFetchedTotal#11977L, shuffleConsumeTotalBlocksFetchedTotal#11978L, shuffleConsumeRemoteBytesReadTotal#11979L, shuffleConsumeLocalBytesReadTotal#11980L, shuffleConsumeTotalBytesReadTotal#11981L, shuffleConsumeRemoteBytesReadToDiskTotal#11982L, shuffleConsumeFetchWaitTimeTotal#11983L, shuffleProduceBytesWrittenTotal#11984L, shuffleProduceRecordsWrittenTotal#11985L, shuffleProduceWriteTimeTotal#11986L, jobId#11987, peakExecutionMemory#11988L, peakExecutionMemoryCliqueDuration#11989L, peakExecutionMemoryCliqueSize#11990L]
(13) Exchange
Input [76]: [jobId#11997, stageCount#11915L, totalTaskCount#11916L, minTaskCountPerStage#11917L, maxTaskCountPerStage#11918L, medianTaskCountPerStage#11919L, bytesSpilledToDiskSerializedTotal#11920L, bytesSpilledToDiskSerializedMin#11921L, bytesSpilledToDiskSerializedMax#11922L, bytesSpilledToDiskSerializedMedian#11923L, taskCpuTimeTotal#11924L, taskCpuTimeMin#11925L, taskCpuTimeMax#11926L, taskCpuTimeMedian#11927L, taskDeserializeCpuTimeTotal#11928L, taskDeserializeCpuTimeMin#11929L, taskDeserializeCpuTimeMax#11930L, taskDeserializeCpuTimeMedian#11931L, taskDeserializeTimeTotal#11932L, taskDeserializeTimeMin#11933L, taskDeserializeTimeMax#11934L, taskDeserializeTimeMedian#11935L, taskRunTimeTotal#11936L, taskRunTimeMin#11937L, taskRunTimeMax#11938L, taskRunTimeMedian#11939L, jvmGcTimeTotal#11940L, jvmGcTimeMin#11941L, jvmGcTimeMax#11942L, jvmGcTimeMedian#11943L, bytesSpilledToDiskRawTotal#11944L, bytesSpilledToDiskRawMin#11945L, bytesSpilledToDiskRawMax#11946L, bytesSpilledToDiskRawMedian#11947L, resultSerializationTimeTotal#11948L, resultSerializationTimeMin#11949L, resultSerializationTimeMax#11950L, resultSerializationTimeMedian#11951L, resultSizeToDriverTotal#11952L, resultSizeToDriverMin#11953L, resultSizeToDriverMax#11954L, resultSizeToDriverMedian#11955L, taskPeakExecutionMemoryMin#11956L, taskPeakExecutionMemoryMax#11957L, taskPeakExecutionMemoryMedian#11958L, persistencyBytesReadTotal#11959L, persistencyBytesReadMin#11960L, persistencyBytesReadMax#11961L, persistencyBytesReadMedian#11962L, persistencyRecordsReadTotal#11963L, persistencyRecordsReadMin#11964L, persistencyRecordsReadMax#11965L, persistencyRecordsReadMedian#11966L, persistencyBytesWrittenTotal#11967L, persistencyBytesWrittenMin#11968L, persistencyBytesWrittenMax#11969L, persistencyBytesWrittenMedian#11970L, persistencyRecordsWrittenTotal#11971L, persistencyRecordsWrittenMin#11972L, persistencyRecordsWrittenMax#11973L, persistencyRecordsWrittenMedian#11974L, shuffleConsumeRecordsReadTotal#11975L, shuffleConsumeRemoteBlocksFetchedTotal#11976L, shuffleConsumeLocalBlocksFetchedTotal#11977L, shuffleConsumeTotalBlocksFetchedTotal#11978L, shuffleConsumeRemoteBytesReadTotal#11979L, shuffleConsumeLocalBytesReadTotal#11980L, shuffleConsumeTotalBytesReadTotal#11981L, shuffleConsumeRemoteBytesReadToDiskTotal#11982L, shuffleConsumeFetchWaitTimeTotal#11983L, shuffleProduceBytesWrittenTotal#11984L, shuffleProduceRecordsWrittenTotal#11985L, shuffleProduceWriteTimeTotal#11986L, peakExecutionMemory#11988L, peakExecutionMemoryCliqueDuration#11989L, peakExecutionMemoryCliqueSize#11990L]
Arguments: hashpartitioning(jobId#11997, 37), ENSURE_REQUIREMENTS, [plan_id=112544]
(14) ShuffleQueryStage
Output [76]: [jobId#11997, stageCount#11915L, totalTaskCount#11916L, minTaskCountPerStage#11917L, maxTaskCountPerStage#11918L, medianTaskCountPerStage#11919L, bytesSpilledToDiskSerializedTotal#11920L, bytesSpilledToDiskSerializedMin#11921L, bytesSpilledToDiskSerializedMax#11922L, bytesSpilledToDiskSerializedMedian#11923L, taskCpuTimeTotal#11924L, taskCpuTimeMin#11925L, taskCpuTimeMax#11926L, taskCpuTimeMedian#11927L, taskDeserializeCpuTimeTotal#11928L, taskDeserializeCpuTimeMin#11929L, taskDeserializeCpuTimeMax#11930L, taskDeserializeCpuTimeMedian#11931L, taskDeserializeTimeTotal#11932L, taskDeserializeTimeMin#11933L, taskDeserializeTimeMax#11934L, taskDeserializeTimeMedian#11935L, taskRunTimeTotal#11936L, taskRunTimeMin#11937L, taskRunTimeMax#11938L, taskRunTimeMedian#11939L, jvmGcTimeTotal#11940L, jvmGcTimeMin#11941L, jvmGcTimeMax#11942L, jvmGcTimeMedian#11943L, bytesSpilledToDiskRawTotal#11944L, bytesSpilledToDiskRawMin#11945L, bytesSpilledToDiskRawMax#11946L, bytesSpilledToDiskRawMedian#11947L, resultSerializationTimeTotal#11948L, resultSerializationTimeMin#11949L, resultSerializationTimeMax#11950L, resultSerializationTimeMedian#11951L, resultSizeToDriverTotal#11952L, resultSizeToDriverMin#11953L, resultSizeToDriverMax#11954L, resultSizeToDriverMedian#11955L, taskPeakExecutionMemoryMin#11956L, taskPeakExecutionMemoryMax#11957L, taskPeakExecutionMemoryMedian#11958L, persistencyBytesReadTotal#11959L, persistencyBytesReadMin#11960L, persistencyBytesReadMax#11961L, persistencyBytesReadMedian#11962L, persistencyRecordsReadTotal#11963L, persistencyRecordsReadMin#11964L, persistencyRecordsReadMax#11965L, persistencyRecordsReadMedian#11966L, persistencyBytesWrittenTotal#11967L, persistencyBytesWrittenMin#11968L, persistencyBytesWrittenMax#11969L, persistencyBytesWrittenMedian#11970L, persistencyRecordsWrittenTotal#11971L, persistencyRecordsWrittenMin#11972L, persistencyRecordsWrittenMax#11973L, persistencyRecordsWrittenMedian#11974L, shuffleConsumeRecordsReadTotal#11975L, shuffleConsumeRemoteBlocksFetchedTotal#11976L, shuffleConsumeLocalBlocksFetchedTotal#11977L, shuffleConsumeTotalBlocksFetchedTotal#11978L, shuffleConsumeRemoteBytesReadTotal#11979L, shuffleConsumeLocalBytesReadTotal#11980L, shuffleConsumeTotalBytesReadTotal#11981L, shuffleConsumeRemoteBytesReadToDiskTotal#11982L, shuffleConsumeFetchWaitTimeTotal#11983L, shuffleProduceBytesWrittenTotal#11984L, shuffleProduceRecordsWrittenTotal#11985L, shuffleProduceWriteTimeTotal#11986L, peakExecutionMemory#11988L, peakExecutionMemoryCliqueDuration#11989L, peakExecutionMemoryCliqueSize#11990L]
Arguments: 3
(15) AQEShuffleRead
Input [76]: [jobId#11997, stageCount#11915L, totalTaskCount#11916L, minTaskCountPerStage#11917L, maxTaskCountPerStage#11918L, medianTaskCountPerStage#11919L, bytesSpilledToDiskSerializedTotal#11920L, bytesSpilledToDiskSerializedMin#11921L, bytesSpilledToDiskSerializedMax#11922L, bytesSpilledToDiskSerializedMedian#11923L, taskCpuTimeTotal#11924L, taskCpuTimeMin#11925L, taskCpuTimeMax#11926L, taskCpuTimeMedian#11927L, taskDeserializeCpuTimeTotal#11928L, taskDeserializeCpuTimeMin#11929L, taskDeserializeCpuTimeMax#11930L, taskDeserializeCpuTimeMedian#11931L, taskDeserializeTimeTotal#11932L, taskDeserializeTimeMin#11933L, taskDeserializeTimeMax#11934L, taskDeserializeTimeMedian#11935L, taskRunTimeTotal#11936L, taskRunTimeMin#11937L, taskRunTimeMax#11938L, taskRunTimeMedian#11939L, jvmGcTimeTotal#11940L, jvmGcTimeMin#11941L, jvmGcTimeMax#11942L, jvmGcTimeMedian#11943L, bytesSpilledToDiskRawTotal#11944L, bytesSpilledToDiskRawMin#11945L, bytesSpilledToDiskRawMax#11946L, bytesSpilledToDiskRawMedian#11947L, resultSerializationTimeTotal#11948L, resultSerializationTimeMin#11949L, resultSerializationTimeMax#11950L, resultSerializationTimeMedian#11951L, resultSizeToDriverTotal#11952L, resultSizeToDriverMin#11953L, resultSizeToDriverMax#11954L, resultSizeToDriverMedian#11955L, taskPeakExecutionMemoryMin#11956L, taskPeakExecutionMemoryMax#11957L, taskPeakExecutionMemoryMedian#11958L, persistencyBytesReadTotal#11959L, persistencyBytesReadMin#11960L, persistencyBytesReadMax#11961L, persistencyBytesReadMedian#11962L, persistencyRecordsReadTotal#11963L, persistencyRecordsReadMin#11964L, persistencyRecordsReadMax#11965L, persistencyRecordsReadMedian#11966L, persistencyBytesWrittenTotal#11967L, persistencyBytesWrittenMin#11968L, persistencyBytesWrittenMax#11969L, persistencyBytesWrittenMedian#11970L, persistencyRecordsWrittenTotal#11971L, persistencyRecordsWrittenMin#11972L, persistencyRecordsWrittenMax#11973L, persistencyRecordsWrittenMedian#11974L, shuffleConsumeRecordsReadTotal#11975L, shuffleConsumeRemoteBlocksFetchedTotal#11976L, shuffleConsumeLocalBlocksFetchedTotal#11977L, shuffleConsumeTotalBlocksFetchedTotal#11978L, shuffleConsumeRemoteBytesReadTotal#11979L, shuffleConsumeLocalBytesReadTotal#11980L, shuffleConsumeTotalBytesReadTotal#11981L, shuffleConsumeRemoteBytesReadToDiskTotal#11982L, shuffleConsumeFetchWaitTimeTotal#11983L, shuffleProduceBytesWrittenTotal#11984L, shuffleProduceRecordsWrittenTotal#11985L, shuffleProduceWriteTimeTotal#11986L, peakExecutionMemory#11988L, peakExecutionMemoryCliqueDuration#11989L, peakExecutionMemoryCliqueSize#11990L]
Arguments: coalesced
(16) Sort [codegen id : 4]
Input [76]: [jobId#11997, stageCount#11915L, totalTaskCount#11916L, minTaskCountPerStage#11917L, maxTaskCountPerStage#11918L, medianTaskCountPerStage#11919L, bytesSpilledToDiskSerializedTotal#11920L, bytesSpilledToDiskSerializedMin#11921L, bytesSpilledToDiskSerializedMax#11922L, bytesSpilledToDiskSerializedMedian#11923L, taskCpuTimeTotal#11924L, taskCpuTimeMin#11925L, taskCpuTimeMax#11926L, taskCpuTimeMedian#11927L, taskDeserializeCpuTimeTotal#11928L, taskDeserializeCpuTimeMin#11929L, taskDeserializeCpuTimeMax#11930L, taskDeserializeCpuTimeMedian#11931L, taskDeserializeTimeTotal#11932L, taskDeserializeTimeMin#11933L, taskDeserializeTimeMax#11934L, taskDeserializeTimeMedian#11935L, taskRunTimeTotal#11936L, taskRunTimeMin#11937L, taskRunTimeMax#11938L, taskRunTimeMedian#11939L, jvmGcTimeTotal#11940L, jvmGcTimeMin#11941L, jvmGcTimeMax#11942L, jvmGcTimeMedian#11943L, bytesSpilledToDiskRawTotal#11944L, bytesSpilledToDiskRawMin#11945L, bytesSpilledToDiskRawMax#11946L, bytesSpilledToDiskRawMedian#11947L, resultSerializationTimeTotal#11948L, resultSerializationTimeMin#11949L, resultSerializationTimeMax#11950L, resultSerializationTimeMedian#11951L, resultSizeToDriverTotal#11952L, resultSizeToDriverMin#11953L, resultSizeToDriverMax#11954L, resultSizeToDriverMedian#11955L, taskPeakExecutionMemoryMin#11956L, taskPeakExecutionMemoryMax#11957L, taskPeakExecutionMemoryMedian#11958L, persistencyBytesReadTotal#11959L, persistencyBytesReadMin#11960L, persistencyBytesReadMax#11961L, persistencyBytesReadMedian#11962L, persistencyRecordsReadTotal#11963L, persistencyRecordsReadMin#11964L, persistencyRecordsReadMax#11965L, persistencyRecordsReadMedian#11966L, persistencyBytesWrittenTotal#11967L, persistencyBytesWrittenMin#11968L, persistencyBytesWrittenMax#11969L, persistencyBytesWrittenMedian#11970L, persistencyRecordsWrittenTotal#11971L, persistencyRecordsWrittenMin#11972L, persistencyRecordsWrittenMax#11973L, persistencyRecordsWrittenMedian#11974L, shuffleConsumeRecordsReadTotal#11975L, shuffleConsumeRemoteBlocksFetchedTotal#11976L, shuffleConsumeLocalBlocksFetchedTotal#11977L, shuffleConsumeTotalBlocksFetchedTotal#11978L, shuffleConsumeRemoteBytesReadTotal#11979L, shuffleConsumeLocalBytesReadTotal#11980L, shuffleConsumeTotalBytesReadTotal#11981L, shuffleConsumeRemoteBytesReadToDiskTotal#11982L, shuffleConsumeFetchWaitTimeTotal#11983L, shuffleProduceBytesWrittenTotal#11984L, shuffleProduceRecordsWrittenTotal#11985L, shuffleProduceWriteTimeTotal#11986L, peakExecutionMemory#11988L, peakExecutionMemoryCliqueDuration#11989L, peakExecutionMemoryCliqueSize#11990L]
Arguments: [jobId#11997 ASC NULLS FIRST], false, 0
(17) LocalTableScan
Output [6]: [jobId#11991, rddStorageDiskSizeTotal#11992L, rddStorageMemSizeTotal#11993L, rddNumCachedPartitionsTotal#11994, rddNumPartitionsTotal#11995, numberOfExecutors#11996]
Arguments: [jobId#11991, rddStorageDiskSizeTotal#11992L, rddStorageMemSizeTotal#11993L, rddNumCachedPartitionsTotal#11994, rddNumPartitionsTotal#11995, numberOfExecutors#11996]
(18) Exchange
Input [6]: [jobId#11991, rddStorageDiskSizeTotal#11992L, rddStorageMemSizeTotal#11993L, rddNumCachedPartitionsTotal#11994, rddNumPartitionsTotal#11995, numberOfExecutors#11996]
Arguments: hashpartitioning(jobId#11991, 37), ENSURE_REQUIREMENTS, [plan_id=112348]
(19) ShuffleQueryStage
Output [6]: [jobId#11991, rddStorageDiskSizeTotal#11992L, rddStorageMemSizeTotal#11993L, rddNumCachedPartitionsTotal#11994, rddNumPartitionsTotal#11995, numberOfExecutors#11996]
Arguments: 2
(20) AQEShuffleRead
Input [6]: [jobId#11991, rddStorageDiskSizeTotal#11992L, rddStorageMemSizeTotal#11993L, rddNumCachedPartitionsTotal#11994, rddNumPartitionsTotal#11995, numberOfExecutors#11996]
Arguments: coalesced
(21) Sort [codegen id : 5]
Input [6]: [jobId#11991, rddStorageDiskSizeTotal#11992L, rddStorageMemSizeTotal#11993L, rddNumCachedPartitionsTotal#11994, rddNumPartitionsTotal#11995, numberOfExecutors#11996]
Arguments: [jobId#11991 ASC NULLS FIRST], false, 0
(22) SortMergeJoin [codegen id : 6]
Left keys [1]: [jobId#11997]
Right keys [1]: [jobId#11991]
Join type: FullOuter
Join condition: None
(23) Project [codegen id : 6]
Output [92]: [coalesce(jobId#11997, jobId#11991) AS jobId#11998, stageCount#11915L, totalTaskCount#11916L, minTaskCountPerStage#11917L, maxTaskCountPerStage#11918L, medianTaskCountPerStage#11919L, bytesSpilledToDiskSerializedTotal#11920L, bytesSpilledToDiskSerializedMin#11921L, bytesSpilledToDiskSerializedMax#11922L, bytesSpilledToDiskSerializedMedian#11923L, taskCpuTimeTotal#11924L, taskCpuTimeMin#11925L, taskCpuTimeMax#11926L, taskCpuTimeMedian#11927L, taskDeserializeCpuTimeTotal#11928L, taskDeserializeCpuTimeMin#11929L, taskDeserializeCpuTimeMax#11930L, taskDeserializeCpuTimeMedian#11931L, taskDeserializeTimeTotal#11932L, taskDeserializeTimeMin#11933L, taskDeserializeTimeMax#11934L, taskDeserializeTimeMedian#11935L, taskRunTimeTotal#11936L, taskRunTimeMin#11937L, taskRunTimeMax#11938L, taskRunTimeMedian#11939L, jvmGcTimeTotal#11940L, jvmGcTimeMin#11941L, jvmGcTimeMax#11942L, jvmGcTimeMedian#11943L, bytesSpilledToDiskRawTotal#11944L, bytesSpilledToDiskRawMin#11945L, bytesSpilledToDiskRawMax#11946L, bytesSpilledToDiskRawMedian#11947L, resultSerializationTimeTotal#11948L, resultSerializationTimeMin#11949L, resultSerializationTimeMax#11950L, resultSerializationTimeMedian#11951L, resultSizeToDriverTotal#11952L, resultSizeToDriverMin#11953L, resultSizeToDriverMax#11954L, resultSizeToDriverMedian#11955L, taskPeakExecutionMemoryMin#11956L, taskPeakExecutionMemoryMax#11957L, taskPeakExecutionMemoryMedian#11958L, persistencyBytesReadTotal#11959L, persistencyBytesReadMin#11960L, persistencyBytesReadMax#11961L, persistencyBytesReadMedian#11962L, persistencyRecordsReadTotal#11963L, persistencyRecordsReadMin#11964L, persistencyRecordsReadMax#11965L, persistencyRecordsReadMedian#11966L, persistencyBytesWrittenTotal#11967L, persistencyBytesWrittenMin#11968L, persistencyBytesWrittenMax#11969L, persistencyBytesWrittenMedian#11970L, persistencyRecordsWrittenTotal#11971L, persistencyRecordsWrittenMin#11972L, persistencyRecordsWrittenMax#11973L, persistencyRecordsWrittenMedian#11974L, shuffleConsumeRecordsReadTotal#11975L, shuffleConsumeRemoteBlocksFetchedTotal#11976L, shuffleConsumeLocalBlocksFetchedTotal#11977L, shuffleConsumeTotalBlocksFetchedTotal#11978L, shuffleConsumeRemoteBytesReadTotal#11979L, shuffleConsumeLocalBytesReadTotal#11980L, shuffleConsumeTotalBytesReadTotal#11981L, shuffleConsumeRemoteBytesReadToDiskTotal#11982L, shuffleConsumeFetchWaitTimeTotal#11983L, shuffleProduceBytesWrittenTotal#11984L, shuffleProduceRecordsWrittenTotal#11985L, shuffleProduceWriteTimeTotal#11986L, peakExecutionMemory#11988L, peakExecutionMemoryCliqueDuration#11989L, peakExecutionMemoryCliqueSize#11990L, rddStorageDiskSizeTotal#11992L, rddStorageMemSizeTotal#11993L, rddNumCachedPartitionsTotal#11994, rddNumPartitionsTotal#11995, numberOfExecutors#11996, 10000000004 AS replenishmentRunId#11999L, 8793759653749352888 AS tenantId#12000, 8445 AS cornerstoneTenantId#12001L, 10000_OP_PERF AS marketUnit#12002, STANDARD AS scenario#12003, 36e0914c-7e4e-3a52-bc93-e306e07299ba AS activityId#12004, BufferDataSnapShot AS activityType#12005, KpiPrepareDataSnapshotWorkflow AS workflowType#12006, b49fb3c6-88b3-3c61-97e8-cbe3f98f9409 AS workflowId#12007, 1 AS activityAttempt#12008, AS gitCommitId#12010]
Input [82]: [jobId#11997, stageCount#11915L, totalTaskCount#11916L, minTaskCountPerStage#11917L, maxTaskCountPerStage#11918L, medianTaskCountPerStage#11919L, bytesSpilledToDiskSerializedTotal#11920L, bytesSpilledToDiskSerializedMin#11921L, bytesSpilledToDiskSerializedMax#11922L, bytesSpilledToDiskSerializedMedian#11923L, taskCpuTimeTotal#11924L, taskCpuTimeMin#11925L, taskCpuTimeMax#11926L, taskCpuTimeMedian#11927L, taskDeserializeCpuTimeTotal#11928L, taskDeserializeCpuTimeMin#11929L, taskDeserializeCpuTimeMax#11930L, taskDeserializeCpuTimeMedian#11931L, taskDeserializeTimeTotal#11932L, taskDeserializeTimeMin#11933L, taskDeserializeTimeMax#11934L, taskDeserializeTimeMedian#11935L, taskRunTimeTotal#11936L, taskRunTimeMin#11937L, taskRunTimeMax#11938L, taskRunTimeMedian#11939L, jvmGcTimeTotal#11940L, jvmGcTimeMin#11941L, jvmGcTimeMax#11942L, jvmGcTimeMedian#11943L, bytesSpilledToDiskRawTotal#11944L, bytesSpilledToDiskRawMin#11945L, bytesSpilledToDiskRawMax#11946L, bytesSpilledToDiskRawMedian#11947L, resultSerializationTimeTotal#11948L, resultSerializationTimeMin#11949L, resultSerializationTimeMax#11950L, resultSerializationTimeMedian#11951L, resultSizeToDriverTotal#11952L, resultSizeToDriverMin#11953L, resultSizeToDriverMax#11954L, resultSizeToDriverMedian#11955L, taskPeakExecutionMemoryMin#11956L, taskPeakExecutionMemoryMax#11957L, taskPeakExecutionMemoryMedian#11958L, persistencyBytesReadTotal#11959L, persistencyBytesReadMin#11960L, persistencyBytesReadMax#11961L, persistencyBytesReadMedian#11962L, persistencyRecordsReadTotal#11963L, persistencyRecordsReadMin#11964L, persistencyRecordsReadMax#11965L, persistencyRecordsReadMedian#11966L, persistencyBytesWrittenTotal#11967L, persistencyBytesWrittenMin#11968L, persistencyBytesWrittenMax#11969L, persistencyBytesWrittenMedian#11970L, persistencyRecordsWrittenTotal#11971L, persistencyRecordsWrittenMin#11972L, persistencyRecordsWrittenMax#11973L, persistencyRecordsWrittenMedian#11974L, shuffleConsumeRecordsReadTotal#11975L, shuffleConsumeRemoteBlocksFetchedTotal#11976L, shuffleConsumeLocalBlocksFetchedTotal#11977L, shuffleConsumeTotalBlocksFetchedTotal#11978L, shuffleConsumeRemoteBytesReadTotal#11979L, shuffleConsumeLocalBytesReadTotal#11980L, shuffleConsumeTotalBytesReadTotal#11981L, shuffleConsumeRemoteBytesReadToDiskTotal#11982L, shuffleConsumeFetchWaitTimeTotal#11983L, shuffleProduceBytesWrittenTotal#11984L, shuffleProduceRecordsWrittenTotal#11985L, shuffleProduceWriteTimeTotal#11986L, peakExecutionMemory#11988L, peakExecutionMemoryCliqueDuration#11989L, peakExecutionMemoryCliqueSize#11990L, jobId#11991, rddStorageDiskSizeTotal#11992L, rddStorageMemSizeTotal#11993L, rddNumCachedPartitionsTotal#11994, rddNumPartitionsTotal#11995, numberOfExecutors#11996]
(24) Sort [codegen id : 6]
Input [92]: [jobId#11998, stageCount#11915L, totalTaskCount#11916L, minTaskCountPerStage#11917L, maxTaskCountPerStage#11918L, medianTaskCountPerStage#11919L, bytesSpilledToDiskSerializedTotal#11920L, bytesSpilledToDiskSerializedMin#11921L, bytesSpilledToDiskSerializedMax#11922L, bytesSpilledToDiskSerializedMedian#11923L, taskCpuTimeTotal#11924L, taskCpuTimeMin#11925L, taskCpuTimeMax#11926L, taskCpuTimeMedian#11927L, taskDeserializeCpuTimeTotal#11928L, taskDeserializeCpuTimeMin#11929L, taskDeserializeCpuTimeMax#11930L, taskDeserializeCpuTimeMedian#11931L, taskDeserializeTimeTotal#11932L, taskDeserializeTimeMin#11933L, taskDeserializeTimeMax#11934L, taskDeserializeTimeMedian#11935L, taskRunTimeTotal#11936L, taskRunTimeMin#11937L, taskRunTimeMax#11938L, taskRunTimeMedian#11939L, jvmGcTimeTotal#11940L, jvmGcTimeMin#11941L, jvmGcTimeMax#11942L, jvmGcTimeMedian#11943L, bytesSpilledToDiskRawTotal#11944L, bytesSpilledToDiskRawMin#11945L, bytesSpilledToDiskRawMax#11946L, bytesSpilledToDiskRawMedian#11947L, resultSerializationTimeTotal#11948L, resultSerializationTimeMin#11949L, resultSerializationTimeMax#11950L, resultSerializationTimeMedian#11951L, resultSizeToDriverTotal#11952L, resultSizeToDriverMin#11953L, resultSizeToDriverMax#11954L, resultSizeToDriverMedian#11955L, taskPeakExecutionMemoryMin#11956L, taskPeakExecutionMemoryMax#11957L, taskPeakExecutionMemoryMedian#11958L, persistencyBytesReadTotal#11959L, persistencyBytesReadMin#11960L, persistencyBytesReadMax#11961L, persistencyBytesReadMedian#11962L, persistencyRecordsReadTotal#11963L, persistencyRecordsReadMin#11964L, persistencyRecordsReadMax#11965L, persistencyRecordsReadMedian#11966L, persistencyBytesWrittenTotal#11967L, persistencyBytesWrittenMin#11968L, persistencyBytesWrittenMax#11969L, persistencyBytesWrittenMedian#11970L, persistencyRecordsWrittenTotal#11971L, persistencyRecordsWrittenMin#11972L, persistencyRecordsWrittenMax#11973L, persistencyRecordsWrittenMedian#11974L, shuffleConsumeRecordsReadTotal#11975L, shuffleConsumeRemoteBlocksFetchedTotal#11976L, shuffleConsumeLocalBlocksFetchedTotal#11977L, shuffleConsumeTotalBlocksFetchedTotal#11978L, shuffleConsumeRemoteBytesReadTotal#11979L, shuffleConsumeLocalBytesReadTotal#11980L, shuffleConsumeTotalBytesReadTotal#11981L, shuffleConsumeRemoteBytesReadToDiskTotal#11982L, shuffleConsumeFetchWaitTimeTotal#11983L, shuffleProduceBytesWrittenTotal#11984L, shuffleProduceRecordsWrittenTotal#11985L, shuffleProduceWriteTimeTotal#11986L, peakExecutionMemory#11988L, peakExecutionMemoryCliqueDuration#11989L, peakExecutionMemoryCliqueSize#11990L, rddStorageDiskSizeTotal#11992L, rddStorageMemSizeTotal#11993L, rddNumCachedPartitionsTotal#11994, rddNumPartitionsTotal#11995, numberOfExecutors#11996, replenishmentRunId#11999L, tenantId#12000, cornerstoneTenantId#12001L, marketUnit#12002, scenario#12003, activityId#12004, activityType#12005, workflowType#12006, workflowId#12007, activityAttempt#12008, gitCommitId#12010]
Arguments: [activityType#12005 ASC NULLS FIRST], false, 0
(25) WriteFiles
Input [92]: [jobId#11998, stageCount#11915L, totalTaskCount#11916L, minTaskCountPerStage#11917L, maxTaskCountPerStage#11918L, medianTaskCountPerStage#11919L, bytesSpilledToDiskSerializedTotal#11920L, bytesSpilledToDiskSerializedMin#11921L, bytesSpilledToDiskSerializedMax#11922L, bytesSpilledToDiskSerializedMedian#11923L, taskCpuTimeTotal#11924L, taskCpuTimeMin#11925L, taskCpuTimeMax#11926L, taskCpuTimeMedian#11927L, taskDeserializeCpuTimeTotal#11928L, taskDeserializeCpuTimeMin#11929L, taskDeserializeCpuTimeMax#11930L, taskDeserializeCpuTimeMedian#11931L, taskDeserializeTimeTotal#11932L, taskDeserializeTimeMin#11933L, taskDeserializeTimeMax#11934L, taskDeserializeTimeMedian#11935L, taskRunTimeTotal#11936L, taskRunTimeMin#11937L, taskRunTimeMax#11938L, taskRunTimeMedian#11939L, jvmGcTimeTotal#11940L, jvmGcTimeMin#11941L, jvmGcTimeMax#11942L, jvmGcTimeMedian#11943L, bytesSpilledToDiskRawTotal#11944L, bytesSpilledToDiskRawMin#11945L, bytesSpilledToDiskRawMax#11946L, bytesSpilledToDiskRawMedian#11947L, resultSerializationTimeTotal#11948L, resultSerializationTimeMin#11949L, resultSerializationTimeMax#11950L, resultSerializationTimeMedian#11951L, resultSizeToDriverTotal#11952L, resultSizeToDriverMin#11953L, resultSizeToDriverMax#11954L, resultSizeToDriverMedian#11955L, taskPeakExecutionMemoryMin#11956L, taskPeakExecutionMemoryMax#11957L, taskPeakExecutionMemoryMedian#11958L, persistencyBytesReadTotal#11959L, persistencyBytesReadMin#11960L, persistencyBytesReadMax#11961L, persistencyBytesReadMedian#11962L, persistencyRecordsReadTotal#11963L, persistencyRecordsReadMin#11964L, persistencyRecordsReadMax#11965L, persistencyRecordsReadMedian#11966L, persistencyBytesWrittenTotal#11967L, persistencyBytesWrittenMin#11968L, persistencyBytesWrittenMax#11969L, persistencyBytesWrittenMedian#11970L, persistencyRecordsWrittenTotal#11971L, persistencyRecordsWrittenMin#11972L, persistencyRecordsWrittenMax#11973L, persistencyRecordsWrittenMedian#11974L, shuffleConsumeRecordsReadTotal#11975L, shuffleConsumeRemoteBlocksFetchedTotal#11976L, shuffleConsumeLocalBlocksFetchedTotal#11977L, shuffleConsumeTotalBlocksFetchedTotal#11978L, shuffleConsumeRemoteBytesReadTotal#11979L, shuffleConsumeLocalBytesReadTotal#11980L, shuffleConsumeTotalBytesReadTotal#11981L, shuffleConsumeRemoteBytesReadToDiskTotal#11982L, shuffleConsumeFetchWaitTimeTotal#11983L, shuffleProduceBytesWrittenTotal#11984L, shuffleProduceRecordsWrittenTotal#11985L, shuffleProduceWriteTimeTotal#11986L, peakExecutionMemory#11988L, peakExecutionMemoryCliqueDuration#11989L, peakExecutionMemoryCliqueSize#11990L, rddStorageDiskSizeTotal#11992L, rddStorageMemSizeTotal#11993L, rddNumCachedPartitionsTotal#11994, rddNumPartitionsTotal#11995, numberOfExecutors#11996, replenishmentRunId#11999L, tenantId#12000, cornerstoneTenantId#12001L, marketUnit#12002, scenario#12003, activityId#12004, activityType#12005, workflowType#12006, workflowId#12007, activityAttempt#12008, gitCommitId#12010]
(26) Execute InsertIntoHadoopFsRelationCommand
Input: []
Arguments: hdlfs://7da5304c-1f57-47fa-b75a-0f0b4349c280.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/internal/performance-metrics/10000000004, false, [activityType#12005], Parquet, [__partition_columns=["activityType"], path=hdlfs://7da5304c-1f57-47fa-b75a-0f0b4349c280.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/internal/performance-metrics/10000000004], 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#11914, stageCount#11915L, totalTaskCount#11916L, minTaskCountPerStage#11917L, maxTaskCountPerStage#11918L, medianTaskCountPerStage#11919L, bytesSpilledToDiskSerializedTotal#11920L, bytesSpilledToDiskSerializedMin#11921L, bytesSpilledToDiskSerializedMax#11922L, bytesSpilledToDiskSerializedMedian#11923L, taskCpuTimeTotal#11924L, taskCpuTimeMin#11925L, taskCpuTimeMax#11926L, taskCpuTimeMedian#11927L, taskDeserializeCpuTimeTotal#11928L, taskDeserializeCpuTimeMin#11929L, taskDeserializeCpuTimeMax#11930L, taskDeserializeCpuTimeMedian#11931L, taskDeserializeTimeTotal#11932L, taskDeserializeTimeMin#11933L, taskDeserializeTimeMax#11934L, taskDeserializeTimeMedian#11935L, taskRunTimeTotal#11936L, taskRunTimeMin#11937L, taskRunTimeMax#11938L, taskRunTimeMedian#11939L, jvmGcTimeTotal#11940L, jvmGcTimeMin#11941L, jvmGcTimeMax#11942L, jvmGcTimeMedian#11943L, bytesSpilledToDiskRawTotal#11944L, bytesSpilledToDiskRawMin#11945L, bytesSpilledToDiskRawMax#11946L, bytesSpilledToDiskRawMedian#11947L, resultSerializationTimeTotal#11948L, resultSerializationTimeMin#11949L, resultSerializationTimeMax#11950L, resultSerializationTimeMedian#11951L, resultSizeToDriverTotal#11952L, resultSizeToDriverMin#11953L, resultSizeToDriverMax#11954L, resultSizeToDriverMedian#11955L, taskPeakExecutionMemoryMin#11956L, taskPeakExecutionMemoryMax#11957L, taskPeakExecutionMemoryMedian#11958L, persistencyBytesReadTotal#11959L, persistencyBytesReadMin#11960L, persistencyBytesReadMax#11961L, persistencyBytesReadMedian#11962L, persistencyRecordsReadTotal#11963L, persistencyRecordsReadMin#11964L, persistencyRecordsReadMax#11965L, persistencyRecordsReadMedian#11966L, persistencyBytesWrittenTotal#11967L, persistencyBytesWrittenMin#11968L, persistencyBytesWrittenMax#11969L, persistencyBytesWrittenMedian#11970L, persistencyRecordsWrittenTotal#11971L, persistencyRecordsWrittenMin#11972L, persistencyRecordsWrittenMax#11973L, persistencyRecordsWrittenMedian#11974L, shuffleConsumeRecordsReadTotal#11975L, shuffleConsumeRemoteBlocksFetchedTotal#11976L, shuffleConsumeLocalBlocksFetchedTotal#11977L, shuffleConsumeTotalBlocksFetchedTotal#11978L, shuffleConsumeRemoteBytesReadTotal#11979L, shuffleConsumeLocalBytesReadTotal#11980L, shuffleConsumeTotalBytesReadTotal#11981L, shuffleConsumeRemoteBytesReadToDiskTotal#11982L, shuffleConsumeFetchWaitTimeTotal#11983L, shuffleProduceBytesWrittenTotal#11984L, shuffleProduceRecordsWrittenTotal#11985L, shuffleProduceWriteTimeTotal#11986L]
Arguments: [jobId#11914 ASC NULLS FIRST], false, 0
(29) Sort
Input [4]: [jobId#11987, peakExecutionMemory#11988L, peakExecutionMemoryCliqueDuration#11989L, peakExecutionMemoryCliqueSize#11990L]
Arguments: [jobId#11987 ASC NULLS FIRST], false, 0
(30) SortMergeJoin
Left keys [1]: [jobId#11914]
Right keys [1]: [jobId#11987]
Join type: FullOuter
Join condition: None
(31) Project
Output [76]: [coalesce(jobId#11914, jobId#11987) AS jobId#11997, stageCount#11915L, totalTaskCount#11916L, minTaskCountPerStage#11917L, maxTaskCountPerStage#11918L, medianTaskCountPerStage#11919L, bytesSpilledToDiskSerializedTotal#11920L, bytesSpilledToDiskSerializedMin#11921L, bytesSpilledToDiskSerializedMax#11922L, bytesSpilledToDiskSerializedMedian#11923L, taskCpuTimeTotal#11924L, taskCpuTimeMin#11925L, taskCpuTimeMax#11926L, taskCpuTimeMedian#11927L, taskDeserializeCpuTimeTotal#11928L, taskDeserializeCpuTimeMin#11929L, taskDeserializeCpuTimeMax#11930L, taskDeserializeCpuTimeMedian#11931L, taskDeserializeTimeTotal#11932L, taskDeserializeTimeMin#11933L, taskDeserializeTimeMax#11934L, taskDeserializeTimeMedian#11935L, taskRunTimeTotal#11936L, taskRunTimeMin#11937L, taskRunTimeMax#11938L, taskRunTimeMedian#11939L, jvmGcTimeTotal#11940L, jvmGcTimeMin#11941L, jvmGcTimeMax#11942L, jvmGcTimeMedian#11943L, bytesSpilledToDiskRawTotal#11944L, bytesSpilledToDiskRawMin#11945L, bytesSpilledToDiskRawMax#11946L, bytesSpilledToDiskRawMedian#11947L, resultSerializationTimeTotal#11948L, resultSerializationTimeMin#11949L, resultSerializationTimeMax#11950L, resultSerializationTimeMedian#11951L, resultSizeToDriverTotal#11952L, resultSizeToDriverMin#11953L, resultSizeToDriverMax#11954L, resultSizeToDriverMedian#11955L, taskPeakExecutionMemoryMin#11956L, taskPeakExecutionMemoryMax#11957L, taskPeakExecutionMemoryMedian#11958L, persistencyBytesReadTotal#11959L, persistencyBytesReadMin#11960L, persistencyBytesReadMax#11961L, persistencyBytesReadMedian#11962L, persistencyRecordsReadTotal#11963L, persistencyRecordsReadMin#11964L, persistencyRecordsReadMax#11965L, persistencyRecordsReadMedian#11966L, persistencyBytesWrittenTotal#11967L, persistencyBytesWrittenMin#11968L, persistencyBytesWrittenMax#11969L, persistencyBytesWrittenMedian#11970L, persistencyRecordsWrittenTotal#11971L, persistencyRecordsWrittenMin#11972L, persistencyRecordsWrittenMax#11973L, persistencyRecordsWrittenMedian#11974L, shuffleConsumeRecordsReadTotal#11975L, shuffleConsumeRemoteBlocksFetchedTotal#11976L, shuffleConsumeLocalBlocksFetchedTotal#11977L, shuffleConsumeTotalBlocksFetchedTotal#11978L, shuffleConsumeRemoteBytesReadTotal#11979L, shuffleConsumeLocalBytesReadTotal#11980L, shuffleConsumeTotalBytesReadTotal#11981L, shuffleConsumeRemoteBytesReadToDiskTotal#11982L, shuffleConsumeFetchWaitTimeTotal#11983L, shuffleProduceBytesWrittenTotal#11984L, shuffleProduceRecordsWrittenTotal#11985L, shuffleProduceWriteTimeTotal#11986L, peakExecutionMemory#11988L, peakExecutionMemoryCliqueDuration#11989L, peakExecutionMemoryCliqueSize#11990L]
Input [77]: [jobId#11914, stageCount#11915L, totalTaskCount#11916L, minTaskCountPerStage#11917L, maxTaskCountPerStage#11918L, medianTaskCountPerStage#11919L, bytesSpilledToDiskSerializedTotal#11920L, bytesSpilledToDiskSerializedMin#11921L, bytesSpilledToDiskSerializedMax#11922L, bytesSpilledToDiskSerializedMedian#11923L, taskCpuTimeTotal#11924L, taskCpuTimeMin#11925L, taskCpuTimeMax#11926L, taskCpuTimeMedian#11927L, taskDeserializeCpuTimeTotal#11928L, taskDeserializeCpuTimeMin#11929L, taskDeserializeCpuTimeMax#11930L, taskDeserializeCpuTimeMedian#11931L, taskDeserializeTimeTotal#11932L, taskDeserializeTimeMin#11933L, taskDeserializeTimeMax#11934L, taskDeserializeTimeMedian#11935L, taskRunTimeTotal#11936L, taskRunTimeMin#11937L, taskRunTimeMax#11938L, taskRunTimeMedian#11939L, jvmGcTimeTotal#11940L, jvmGcTimeMin#11941L, jvmGcTimeMax#11942L, jvmGcTimeMedian#11943L, bytesSpilledToDiskRawTotal#11944L, bytesSpilledToDiskRawMin#11945L, bytesSpilledToDiskRawMax#11946L, bytesSpilledToDiskRawMedian#11947L, resultSerializationTimeTotal#11948L, resultSerializationTimeMin#11949L, resultSerializationTimeMax#11950L, resultSerializationTimeMedian#11951L, resultSizeToDriverTotal#11952L, resultSizeToDriverMin#11953L, resultSizeToDriverMax#11954L, resultSizeToDriverMedian#11955L, taskPeakExecutionMemoryMin#11956L, taskPeakExecutionMemoryMax#11957L, taskPeakExecutionMemoryMedian#11958L, persistencyBytesReadTotal#11959L, persistencyBytesReadMin#11960L, persistencyBytesReadMax#11961L, persistencyBytesReadMedian#11962L, persistencyRecordsReadTotal#11963L, persistencyRecordsReadMin#11964L, persistencyRecordsReadMax#11965L, persistencyRecordsReadMedian#11966L, persistencyBytesWrittenTotal#11967L, persistencyBytesWrittenMin#11968L, persistencyBytesWrittenMax#11969L, persistencyBytesWrittenMedian#11970L, persistencyRecordsWrittenTotal#11971L, persistencyRecordsWrittenMin#11972L, persistencyRecordsWrittenMax#11973L, persistencyRecordsWrittenMedian#11974L, shuffleConsumeRecordsReadTotal#11975L, shuffleConsumeRemoteBlocksFetchedTotal#11976L, shuffleConsumeLocalBlocksFetchedTotal#11977L, shuffleConsumeTotalBlocksFetchedTotal#11978L, shuffleConsumeRemoteBytesReadTotal#11979L, shuffleConsumeLocalBytesReadTotal#11980L, shuffleConsumeTotalBytesReadTotal#11981L, shuffleConsumeRemoteBytesReadToDiskTotal#11982L, shuffleConsumeFetchWaitTimeTotal#11983L, shuffleProduceBytesWrittenTotal#11984L, shuffleProduceRecordsWrittenTotal#11985L, shuffleProduceWriteTimeTotal#11986L, jobId#11987, peakExecutionMemory#11988L, peakExecutionMemoryCliqueDuration#11989L, peakExecutionMemoryCliqueSize#11990L]
(32) Exchange
Input [76]: [jobId#11997, stageCount#11915L, totalTaskCount#11916L, minTaskCountPerStage#11917L, maxTaskCountPerStage#11918L, medianTaskCountPerStage#11919L, bytesSpilledToDiskSerializedTotal#11920L, bytesSpilledToDiskSerializedMin#11921L, bytesSpilledToDiskSerializedMax#11922L, bytesSpilledToDiskSerializedMedian#11923L, taskCpuTimeTotal#11924L, taskCpuTimeMin#11925L, taskCpuTimeMax#11926L, taskCpuTimeMedian#11927L, taskDeserializeCpuTimeTotal#11928L, taskDeserializeCpuTimeMin#11929L, taskDeserializeCpuTimeMax#11930L, taskDeserializeCpuTimeMedian#11931L, taskDeserializeTimeTotal#11932L, taskDeserializeTimeMin#11933L, taskDeserializeTimeMax#11934L, taskDeserializeTimeMedian#11935L, taskRunTimeTotal#11936L, taskRunTimeMin#11937L, taskRunTimeMax#11938L, taskRunTimeMedian#11939L, jvmGcTimeTotal#11940L, jvmGcTimeMin#11941L, jvmGcTimeMax#11942L, jvmGcTimeMedian#11943L, bytesSpilledToDiskRawTotal#11944L, bytesSpilledToDiskRawMin#11945L, bytesSpilledToDiskRawMax#11946L, bytesSpilledToDiskRawMedian#11947L, resultSerializationTimeTotal#11948L, resultSerializationTimeMin#11949L, resultSerializationTimeMax#11950L, resultSerializationTimeMedian#11951L, resultSizeToDriverTotal#11952L, resultSizeToDriverMin#11953L, resultSizeToDriverMax#11954L, resultSizeToDriverMedian#11955L, taskPeakExecutionMemoryMin#11956L, taskPeakExecutionMemoryMax#11957L, taskPeakExecutionMemoryMedian#11958L, persistencyBytesReadTotal#11959L, persistencyBytesReadMin#11960L, persistencyBytesReadMax#11961L, persistencyBytesReadMedian#11962L, persistencyRecordsReadTotal#11963L, persistencyRecordsReadMin#11964L, persistencyRecordsReadMax#11965L, persistencyRecordsReadMedian#11966L, persistencyBytesWrittenTotal#11967L, persistencyBytesWrittenMin#11968L, persistencyBytesWrittenMax#11969L, persistencyBytesWrittenMedian#11970L, persistencyRecordsWrittenTotal#11971L, persistencyRecordsWrittenMin#11972L, persistencyRecordsWrittenMax#11973L, persistencyRecordsWrittenMedian#11974L, shuffleConsumeRecordsReadTotal#11975L, shuffleConsumeRemoteBlocksFetchedTotal#11976L, shuffleConsumeLocalBlocksFetchedTotal#11977L, shuffleConsumeTotalBlocksFetchedTotal#11978L, shuffleConsumeRemoteBytesReadTotal#11979L, shuffleConsumeLocalBytesReadTotal#11980L, shuffleConsumeTotalBytesReadTotal#11981L, shuffleConsumeRemoteBytesReadToDiskTotal#11982L, shuffleConsumeFetchWaitTimeTotal#11983L, shuffleProduceBytesWrittenTotal#11984L, shuffleProduceRecordsWrittenTotal#11985L, shuffleProduceWriteTimeTotal#11986L, peakExecutionMemory#11988L, peakExecutionMemoryCliqueDuration#11989L, peakExecutionMemoryCliqueSize#11990L]
Arguments: hashpartitioning(jobId#11997, 37), ENSURE_REQUIREMENTS, [plan_id=112347]
(33) Sort
Input [76]: [jobId#11997, stageCount#11915L, totalTaskCount#11916L, minTaskCountPerStage#11917L, maxTaskCountPerStage#11918L, medianTaskCountPerStage#11919L, bytesSpilledToDiskSerializedTotal#11920L, bytesSpilledToDiskSerializedMin#11921L, bytesSpilledToDiskSerializedMax#11922L, bytesSpilledToDiskSerializedMedian#11923L, taskCpuTimeTotal#11924L, taskCpuTimeMin#11925L, taskCpuTimeMax#11926L, taskCpuTimeMedian#11927L, taskDeserializeCpuTimeTotal#11928L, taskDeserializeCpuTimeMin#11929L, taskDeserializeCpuTimeMax#11930L, taskDeserializeCpuTimeMedian#11931L, taskDeserializeTimeTotal#11932L, taskDeserializeTimeMin#11933L, taskDeserializeTimeMax#11934L, taskDeserializeTimeMedian#11935L, taskRunTimeTotal#11936L, taskRunTimeMin#11937L, taskRunTimeMax#11938L, taskRunTimeMedian#11939L, jvmGcTimeTotal#11940L, jvmGcTimeMin#11941L, jvmGcTimeMax#11942L, jvmGcTimeMedian#11943L, bytesSpilledToDiskRawTotal#11944L, bytesSpilledToDiskRawMin#11945L, bytesSpilledToDiskRawMax#11946L, bytesSpilledToDiskRawMedian#11947L, resultSerializationTimeTotal#11948L, resultSerializationTimeMin#11949L, resultSerializationTimeMax#11950L, resultSerializationTimeMedian#11951L, resultSizeToDriverTotal#11952L, resultSizeToDriverMin#11953L, resultSizeToDriverMax#11954L, resultSizeToDriverMedian#11955L, taskPeakExecutionMemoryMin#11956L, taskPeakExecutionMemoryMax#11957L, taskPeakExecutionMemoryMedian#11958L, persistencyBytesReadTotal#11959L, persistencyBytesReadMin#11960L, persistencyBytesReadMax#11961L, persistencyBytesReadMedian#11962L, persistencyRecordsReadTotal#11963L, persistencyRecordsReadMin#11964L, persistencyRecordsReadMax#11965L, persistencyRecordsReadMedian#11966L, persistencyBytesWrittenTotal#11967L, persistencyBytesWrittenMin#11968L, persistencyBytesWrittenMax#11969L, persistencyBytesWrittenMedian#11970L, persistencyRecordsWrittenTotal#11971L, persistencyRecordsWrittenMin#11972L, persistencyRecordsWrittenMax#11973L, persistencyRecordsWrittenMedian#11974L, shuffleConsumeRecordsReadTotal#11975L, shuffleConsumeRemoteBlocksFetchedTotal#11976L, shuffleConsumeLocalBlocksFetchedTotal#11977L, shuffleConsumeTotalBlocksFetchedTotal#11978L, shuffleConsumeRemoteBytesReadTotal#11979L, shuffleConsumeLocalBytesReadTotal#11980L, shuffleConsumeTotalBytesReadTotal#11981L, shuffleConsumeRemoteBytesReadToDiskTotal#11982L, shuffleConsumeFetchWaitTimeTotal#11983L, shuffleProduceBytesWrittenTotal#11984L, shuffleProduceRecordsWrittenTotal#11985L, shuffleProduceWriteTimeTotal#11986L, peakExecutionMemory#11988L, peakExecutionMemoryCliqueDuration#11989L, peakExecutionMemoryCliqueSize#11990L]
Arguments: [jobId#11997 ASC NULLS FIRST], false, 0
(34) Sort
Input [6]: [jobId#11991, rddStorageDiskSizeTotal#11992L, rddStorageMemSizeTotal#11993L, rddNumCachedPartitionsTotal#11994, rddNumPartitionsTotal#11995, numberOfExecutors#11996]
Arguments: [jobId#11991 ASC NULLS FIRST], false, 0
(35) SortMergeJoin
Left keys [1]: [jobId#11997]
Right keys [1]: [jobId#11991]
Join type: FullOuter
Join condition: None
(36) Project
Output [92]: [coalesce(jobId#11997, jobId#11991) AS jobId#11998, stageCount#11915L, totalTaskCount#11916L, minTaskCountPerStage#11917L, maxTaskCountPerStage#11918L, medianTaskCountPerStage#11919L, bytesSpilledToDiskSerializedTotal#11920L, bytesSpilledToDiskSerializedMin#11921L, bytesSpilledToDiskSerializedMax#11922L, bytesSpilledToDiskSerializedMedian#11923L, taskCpuTimeTotal#11924L, taskCpuTimeMin#11925L, taskCpuTimeMax#11926L, taskCpuTimeMedian#11927L, taskDeserializeCpuTimeTotal#11928L, taskDeserializeCpuTimeMin#11929L, taskDeserializeCpuTimeMax#11930L, taskDeserializeCpuTimeMedian#11931L, taskDeserializeTimeTotal#11932L, taskDeserializeTimeMin#11933L, taskDeserializeTimeMax#11934L, taskDeserializeTimeMedian#11935L, taskRunTimeTotal#11936L, taskRunTimeMin#11937L, taskRunTimeMax#11938L, taskRunTimeMedian#11939L, jvmGcTimeTotal#11940L, jvmGcTimeMin#11941L, jvmGcTimeMax#11942L, jvmGcTimeMedian#11943L, bytesSpilledToDiskRawTotal#11944L, bytesSpilledToDiskRawMin#11945L, bytesSpilledToDiskRawMax#11946L, bytesSpilledToDiskRawMedian#11947L, resultSerializationTimeTotal#11948L, resultSerializationTimeMin#11949L, resultSerializationTimeMax#11950L, resultSerializationTimeMedian#11951L, resultSizeToDriverTotal#11952L, resultSizeToDriverMin#11953L, resultSizeToDriverMax#11954L, resultSizeToDriverMedian#11955L, taskPeakExecutionMemoryMin#11956L, taskPeakExecutionMemoryMax#11957L, taskPeakExecutionMemoryMedian#11958L, persistencyBytesReadTotal#11959L, persistencyBytesReadMin#11960L, persistencyBytesReadMax#11961L, persistencyBytesReadMedian#11962L, persistencyRecordsReadTotal#11963L, persistencyRecordsReadMin#11964L, persistencyRecordsReadMax#11965L, persistencyRecordsReadMedian#11966L, persistencyBytesWrittenTotal#11967L, persistencyBytesWrittenMin#11968L, persistencyBytesWrittenMax#11969L, persistencyBytesWrittenMedian#11970L, persistencyRecordsWrittenTotal#11971L, persistencyRecordsWrittenMin#11972L, persistencyRecordsWrittenMax#11973L, persistencyRecordsWrittenMedian#11974L, shuffleConsumeRecordsReadTotal#11975L, shuffleConsumeRemoteBlocksFetchedTotal#11976L, shuffleConsumeLocalBlocksFetchedTotal#11977L, shuffleConsumeTotalBlocksFetchedTotal#11978L, shuffleConsumeRemoteBytesReadTotal#11979L, shuffleConsumeLocalBytesReadTotal#11980L, shuffleConsumeTotalBytesReadTotal#11981L, shuffleConsumeRemoteBytesReadToDiskTotal#11982L, shuffleConsumeFetchWaitTimeTotal#11983L, shuffleProduceBytesWrittenTotal#11984L, shuffleProduceRecordsWrittenTotal#11985L, shuffleProduceWriteTimeTotal#11986L, peakExecutionMemory#11988L, peakExecutionMemoryCliqueDuration#11989L, peakExecutionMemoryCliqueSize#11990L, rddStorageDiskSizeTotal#11992L, rddStorageMemSizeTotal#11993L, rddNumCachedPartitionsTotal#11994, rddNumPartitionsTotal#11995, numberOfExecutors#11996, 10000000004 AS replenishmentRunId#11999L, 8793759653749352888 AS tenantId#12000, 8445 AS cornerstoneTenantId#12001L, 10000_OP_PERF AS marketUnit#12002, STANDARD AS scenario#12003, 36e0914c-7e4e-3a52-bc93-e306e07299ba AS activityId#12004, BufferDataSnapShot AS activityType#12005, KpiPrepareDataSnapshotWorkflow AS workflowType#12006, b49fb3c6-88b3-3c61-97e8-cbe3f98f9409 AS workflowId#12007, 1 AS activityAttempt#12008, AS gitCommitId#12010]
Input [82]: [jobId#11997, stageCount#11915L, totalTaskCount#11916L, minTaskCountPerStage#11917L, maxTaskCountPerStage#11918L, medianTaskCountPerStage#11919L, bytesSpilledToDiskSerializedTotal#11920L, bytesSpilledToDiskSerializedMin#11921L, bytesSpilledToDiskSerializedMax#11922L, bytesSpilledToDiskSerializedMedian#11923L, taskCpuTimeTotal#11924L, taskCpuTimeMin#11925L, taskCpuTimeMax#11926L, taskCpuTimeMedian#11927L, taskDeserializeCpuTimeTotal#11928L, taskDeserializeCpuTimeMin#11929L, taskDeserializeCpuTimeMax#11930L, taskDeserializeCpuTimeMedian#11931L, taskDeserializeTimeTotal#11932L, taskDeserializeTimeMin#11933L, taskDeserializeTimeMax#11934L, taskDeserializeTimeMedian#11935L, taskRunTimeTotal#11936L, taskRunTimeMin#11937L, taskRunTimeMax#11938L, taskRunTimeMedian#11939L, jvmGcTimeTotal#11940L, jvmGcTimeMin#11941L, jvmGcTimeMax#11942L, jvmGcTimeMedian#11943L, bytesSpilledToDiskRawTotal#11944L, bytesSpilledToDiskRawMin#11945L, bytesSpilledToDiskRawMax#11946L, bytesSpilledToDiskRawMedian#11947L, resultSerializationTimeTotal#11948L, resultSerializationTimeMin#11949L, resultSerializationTimeMax#11950L, resultSerializationTimeMedian#11951L, resultSizeToDriverTotal#11952L, resultSizeToDriverMin#11953L, resultSizeToDriverMax#11954L, resultSizeToDriverMedian#11955L, taskPeakExecutionMemoryMin#11956L, taskPeakExecutionMemoryMax#11957L, taskPeakExecutionMemoryMedian#11958L, persistencyBytesReadTotal#11959L, persistencyBytesReadMin#11960L, persistencyBytesReadMax#11961L, persistencyBytesReadMedian#11962L, persistencyRecordsReadTotal#11963L, persistencyRecordsReadMin#11964L, persistencyRecordsReadMax#11965L, persistencyRecordsReadMedian#11966L, persistencyBytesWrittenTotal#11967L, persistencyBytesWrittenMin#11968L, persistencyBytesWrittenMax#11969L, persistencyBytesWrittenMedian#11970L, persistencyRecordsWrittenTotal#11971L, persistencyRecordsWrittenMin#11972L, persistencyRecordsWrittenMax#11973L, persistencyRecordsWrittenMedian#11974L, shuffleConsumeRecordsReadTotal#11975L, shuffleConsumeRemoteBlocksFetchedTotal#11976L, shuffleConsumeLocalBlocksFetchedTotal#11977L, shuffleConsumeTotalBlocksFetchedTotal#11978L, shuffleConsumeRemoteBytesReadTotal#11979L, shuffleConsumeLocalBytesReadTotal#11980L, shuffleConsumeTotalBytesReadTotal#11981L, shuffleConsumeRemoteBytesReadToDiskTotal#11982L, shuffleConsumeFetchWaitTimeTotal#11983L, shuffleProduceBytesWrittenTotal#11984L, shuffleProduceRecordsWrittenTotal#11985L, shuffleProduceWriteTimeTotal#11986L, peakExecutionMemory#11988L, peakExecutionMemoryCliqueDuration#11989L, peakExecutionMemoryCliqueSize#11990L, jobId#11991, rddStorageDiskSizeTotal#11992L, rddStorageMemSizeTotal#11993L, rddNumCachedPartitionsTotal#11994, rddNumPartitionsTotal#11995, numberOfExecutors#11996]
(37) Sort
Input [92]: [jobId#11998, stageCount#11915L, totalTaskCount#11916L, minTaskCountPerStage#11917L, maxTaskCountPerStage#11918L, medianTaskCountPerStage#11919L, bytesSpilledToDiskSerializedTotal#11920L, bytesSpilledToDiskSerializedMin#11921L, bytesSpilledToDiskSerializedMax#11922L, bytesSpilledToDiskSerializedMedian#11923L, taskCpuTimeTotal#11924L, taskCpuTimeMin#11925L, taskCpuTimeMax#11926L, taskCpuTimeMedian#11927L, taskDeserializeCpuTimeTotal#11928L, taskDeserializeCpuTimeMin#11929L, taskDeserializeCpuTimeMax#11930L, taskDeserializeCpuTimeMedian#11931L, taskDeserializeTimeTotal#11932L, taskDeserializeTimeMin#11933L, taskDeserializeTimeMax#11934L, taskDeserializeTimeMedian#11935L, taskRunTimeTotal#11936L, taskRunTimeMin#11937L, taskRunTimeMax#11938L, taskRunTimeMedian#11939L, jvmGcTimeTotal#11940L, jvmGcTimeMin#11941L, jvmGcTimeMax#11942L, jvmGcTimeMedian#11943L, bytesSpilledToDiskRawTotal#11944L, bytesSpilledToDiskRawMin#11945L, bytesSpilledToDiskRawMax#11946L, bytesSpilledToDiskRawMedian#11947L, resultSerializationTimeTotal#11948L, resultSerializationTimeMin#11949L, resultSerializationTimeMax#11950L, resultSerializationTimeMedian#11951L, resultSizeToDriverTotal#11952L, resultSizeToDriverMin#11953L, resultSizeToDriverMax#11954L, resultSizeToDriverMedian#11955L, taskPeakExecutionMemoryMin#11956L, taskPeakExecutionMemoryMax#11957L, taskPeakExecutionMemoryMedian#11958L, persistencyBytesReadTotal#11959L, persistencyBytesReadMin#11960L, persistencyBytesReadMax#11961L, persistencyBytesReadMedian#11962L, persistencyRecordsReadTotal#11963L, persistencyRecordsReadMin#11964L, persistencyRecordsReadMax#11965L, persistencyRecordsReadMedian#11966L, persistencyBytesWrittenTotal#11967L, persistencyBytesWrittenMin#11968L, persistencyBytesWrittenMax#11969L, persistencyBytesWrittenMedian#11970L, persistencyRecordsWrittenTotal#11971L, persistencyRecordsWrittenMin#11972L, persistencyRecordsWrittenMax#11973L, persistencyRecordsWrittenMedian#11974L, shuffleConsumeRecordsReadTotal#11975L, shuffleConsumeRemoteBlocksFetchedTotal#11976L, shuffleConsumeLocalBlocksFetchedTotal#11977L, shuffleConsumeTotalBlocksFetchedTotal#11978L, shuffleConsumeRemoteBytesReadTotal#11979L, shuffleConsumeLocalBytesReadTotal#11980L, shuffleConsumeTotalBytesReadTotal#11981L, shuffleConsumeRemoteBytesReadToDiskTotal#11982L, shuffleConsumeFetchWaitTimeTotal#11983L, shuffleProduceBytesWrittenTotal#11984L, shuffleProduceRecordsWrittenTotal#11985L, shuffleProduceWriteTimeTotal#11986L, peakExecutionMemory#11988L, peakExecutionMemoryCliqueDuration#11989L, peakExecutionMemoryCliqueSize#11990L, rddStorageDiskSizeTotal#11992L, rddStorageMemSizeTotal#11993L, rddNumCachedPartitionsTotal#11994, rddNumPartitionsTotal#11995, numberOfExecutors#11996, replenishmentRunId#11999L, tenantId#12000, cornerstoneTenantId#12001L, marketUnit#12002, scenario#12003, activityId#12004, activityType#12005, workflowType#12006, workflowId#12007, activityAttempt#12008, gitCommitId#12010]
Arguments: [activityType#12005 ASC NULLS FIRST], false, 0
(38) WriteFiles
Input [92]: [jobId#11998, stageCount#11915L, totalTaskCount#11916L, minTaskCountPerStage#11917L, maxTaskCountPerStage#11918L, medianTaskCountPerStage#11919L, bytesSpilledToDiskSerializedTotal#11920L, bytesSpilledToDiskSerializedMin#11921L, bytesSpilledToDiskSerializedMax#11922L, bytesSpilledToDiskSerializedMedian#11923L, taskCpuTimeTotal#11924L, taskCpuTimeMin#11925L, taskCpuTimeMax#11926L, taskCpuTimeMedian#11927L, taskDeserializeCpuTimeTotal#11928L, taskDeserializeCpuTimeMin#11929L, taskDeserializeCpuTimeMax#11930L, taskDeserializeCpuTimeMedian#11931L, taskDeserializeTimeTotal#11932L, taskDeserializeTimeMin#11933L, taskDeserializeTimeMax#11934L, taskDeserializeTimeMedian#11935L, taskRunTimeTotal#11936L, taskRunTimeMin#11937L, taskRunTimeMax#11938L, taskRunTimeMedian#11939L, jvmGcTimeTotal#11940L, jvmGcTimeMin#11941L, jvmGcTimeMax#11942L, jvmGcTimeMedian#11943L, bytesSpilledToDiskRawTotal#11944L, bytesSpilledToDiskRawMin#11945L, bytesSpilledToDiskRawMax#11946L, bytesSpilledToDiskRawMedian#11947L, resultSerializationTimeTotal#11948L, resultSerializationTimeMin#11949L, resultSerializationTimeMax#11950L, resultSerializationTimeMedian#11951L, resultSizeToDriverTotal#11952L, resultSizeToDriverMin#11953L, resultSizeToDriverMax#11954L, resultSizeToDriverMedian#11955L, taskPeakExecutionMemoryMin#11956L, taskPeakExecutionMemoryMax#11957L, taskPeakExecutionMemoryMedian#11958L, persistencyBytesReadTotal#11959L, persistencyBytesReadMin#11960L, persistencyBytesReadMax#11961L, persistencyBytesReadMedian#11962L, persistencyRecordsReadTotal#11963L, persistencyRecordsReadMin#11964L, persistencyRecordsReadMax#11965L, persistencyRecordsReadMedian#11966L, persistencyBytesWrittenTotal#11967L, persistencyBytesWrittenMin#11968L, persistencyBytesWrittenMax#11969L, persistencyBytesWrittenMedian#11970L, persistencyRecordsWrittenTotal#11971L, persistencyRecordsWrittenMin#11972L, persistencyRecordsWrittenMax#11973L, persistencyRecordsWrittenMedian#11974L, shuffleConsumeRecordsReadTotal#11975L, shuffleConsumeRemoteBlocksFetchedTotal#11976L, shuffleConsumeLocalBlocksFetchedTotal#11977L, shuffleConsumeTotalBlocksFetchedTotal#11978L, shuffleConsumeRemoteBytesReadTotal#11979L, shuffleConsumeLocalBytesReadTotal#11980L, shuffleConsumeTotalBytesReadTotal#11981L, shuffleConsumeRemoteBytesReadToDiskTotal#11982L, shuffleConsumeFetchWaitTimeTotal#11983L, shuffleProduceBytesWrittenTotal#11984L, shuffleProduceRecordsWrittenTotal#11985L, shuffleProduceWriteTimeTotal#11986L, peakExecutionMemory#11988L, peakExecutionMemoryCliqueDuration#11989L, peakExecutionMemoryCliqueSize#11990L, rddStorageDiskSizeTotal#11992L, rddStorageMemSizeTotal#11993L, rddNumCachedPartitionsTotal#11994, rddNumPartitionsTotal#11995, numberOfExecutors#11996, replenishmentRunId#11999L, tenantId#12000, cornerstoneTenantId#12001L, marketUnit#12002, scenario#12003, activityId#12004, activityType#12005, workflowType#12006, workflowId#12007, activityAttempt#12008, gitCommitId#12010]
(39) Execute InsertIntoHadoopFsRelationCommand
Input: []
Arguments: hdlfs://7da5304c-1f57-47fa-b75a-0f0b4349c280.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/internal/performance-metrics/10000000004, false, [activityType#12005], Parquet, [__partition_columns=["activityType"], path=hdlfs://7da5304c-1f57-47fa-b75a-0f0b4349c280.files.hdl.prod-eu20.hanacloud.ondemand.com:443/crp-order-quantity-kpi-service/internal/performance-metrics/10000000004], 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