== 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=632.0 B, rowCount=1)
: +- Exchange (13)
: +- * Project (12)
: +- * SortMergeJoin FullOuter (11)
: :- * Sort (5)
: : +- AQEShuffleRead (4)
: : +- ShuffleQueryStage (3), Statistics(sizeInBytes=608.0 B, rowCount=1)
: : +- Exchange (2)
: : +- LocalTableScan (1)
: +- * Sort (10)
: +- AQEShuffleRead (9)
: +- ShuffleQueryStage (8), Statistics(sizeInBytes=48.0 B, rowCount=1)
: +- Exchange (7)
: +- LocalTableScan (6)
+- * Sort (21)
+- AQEShuffleRead (20)
+- ShuffleQueryStage (19), Statistics(sizeInBytes=64.0 B, rowCount=1)
+- 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#1386, stageCount#1387L, totalTaskCount#1388L, minTaskCountPerStage#1389L, maxTaskCountPerStage#1390L, medianTaskCountPerStage#1391L, bytesSpilledToDiskSerializedTotal#1392L, bytesSpilledToDiskSerializedMin#1393L, bytesSpilledToDiskSerializedMax#1394L, bytesSpilledToDiskSerializedMedian#1395L, taskCpuTimeTotal#1396L, taskCpuTimeMin#1397L, taskCpuTimeMax#1398L, taskCpuTimeMedian#1399L, taskDeserializeCpuTimeTotal#1400L, taskDeserializeCpuTimeMin#1401L, taskDeserializeCpuTimeMax#1402L, taskDeserializeCpuTimeMedian#1403L, taskDeserializeTimeTotal#1404L, taskDeserializeTimeMin#1405L, taskDeserializeTimeMax#1406L, taskDeserializeTimeMedian#1407L, taskRunTimeTotal#1408L, taskRunTimeMin#1409L, taskRunTimeMax#1410L, taskRunTimeMedian#1411L, jvmGcTimeTotal#1412L, jvmGcTimeMin#1413L, jvmGcTimeMax#1414L, jvmGcTimeMedian#1415L, bytesSpilledToDiskRawTotal#1416L, bytesSpilledToDiskRawMin#1417L, bytesSpilledToDiskRawMax#1418L, bytesSpilledToDiskRawMedian#1419L, resultSerializationTimeTotal#1420L, resultSerializationTimeMin#1421L, resultSerializationTimeMax#1422L, resultSerializationTimeMedian#1423L, resultSizeToDriverTotal#1424L, resultSizeToDriverMin#1425L, resultSizeToDriverMax#1426L, resultSizeToDriverMedian#1427L, taskPeakExecutionMemoryMin#1428L, taskPeakExecutionMemoryMax#1429L, taskPeakExecutionMemoryMedian#1430L, persistencyBytesReadTotal#1431L, persistencyBytesReadMin#1432L, persistencyBytesReadMax#1433L, persistencyBytesReadMedian#1434L, persistencyRecordsReadTotal#1435L, persistencyRecordsReadMin#1436L, persistencyRecordsReadMax#1437L, persistencyRecordsReadMedian#1438L, persistencyBytesWrittenTotal#1439L, persistencyBytesWrittenMin#1440L, persistencyBytesWrittenMax#1441L, persistencyBytesWrittenMedian#1442L, persistencyRecordsWrittenTotal#1443L, persistencyRecordsWrittenMin#1444L, persistencyRecordsWrittenMax#1445L, persistencyRecordsWrittenMedian#1446L, shuffleConsumeRecordsReadTotal#1447L, shuffleConsumeRemoteBlocksFetchedTotal#1448L, shuffleConsumeLocalBlocksFetchedTotal#1449L, shuffleConsumeTotalBlocksFetchedTotal#1450L, shuffleConsumeRemoteBytesReadTotal#1451L, shuffleConsumeLocalBytesReadTotal#1452L, shuffleConsumeTotalBytesReadTotal#1453L, shuffleConsumeRemoteBytesReadToDiskTotal#1454L, shuffleConsumeFetchWaitTimeTotal#1455L, shuffleProduceBytesWrittenTotal#1456L, shuffleProduceRecordsWrittenTotal#1457L, shuffleProduceWriteTimeTotal#1458L]
Arguments: [jobId#1386, stageCount#1387L, totalTaskCount#1388L, minTaskCountPerStage#1389L, maxTaskCountPerStage#1390L, medianTaskCountPerStage#1391L, bytesSpilledToDiskSerializedTotal#1392L, bytesSpilledToDiskSerializedMin#1393L, bytesSpilledToDiskSerializedMax#1394L, bytesSpilledToDiskSerializedMedian#1395L, taskCpuTimeTotal#1396L, taskCpuTimeMin#1397L, taskCpuTimeMax#1398L, taskCpuTimeMedian#1399L, taskDeserializeCpuTimeTotal#1400L, taskDeserializeCpuTimeMin#1401L, taskDeserializeCpuTimeMax#1402L, taskDeserializeCpuTimeMedian#1403L, taskDeserializeTimeTotal#1404L, taskDeserializeTimeMin#1405L, taskDeserializeTimeMax#1406L, taskDeserializeTimeMedian#1407L, taskRunTimeTotal#1408L, taskRunTimeMin#1409L, taskRunTimeMax#1410L, ... 48 more fields]
(2) Exchange
Input [73]: [jobId#1386, stageCount#1387L, totalTaskCount#1388L, minTaskCountPerStage#1389L, maxTaskCountPerStage#1390L, medianTaskCountPerStage#1391L, bytesSpilledToDiskSerializedTotal#1392L, bytesSpilledToDiskSerializedMin#1393L, bytesSpilledToDiskSerializedMax#1394L, bytesSpilledToDiskSerializedMedian#1395L, taskCpuTimeTotal#1396L, taskCpuTimeMin#1397L, taskCpuTimeMax#1398L, taskCpuTimeMedian#1399L, taskDeserializeCpuTimeTotal#1400L, taskDeserializeCpuTimeMin#1401L, taskDeserializeCpuTimeMax#1402L, taskDeserializeCpuTimeMedian#1403L, taskDeserializeTimeTotal#1404L, taskDeserializeTimeMin#1405L, taskDeserializeTimeMax#1406L, taskDeserializeTimeMedian#1407L, taskRunTimeTotal#1408L, taskRunTimeMin#1409L, taskRunTimeMax#1410L, taskRunTimeMedian#1411L, jvmGcTimeTotal#1412L, jvmGcTimeMin#1413L, jvmGcTimeMax#1414L, jvmGcTimeMedian#1415L, bytesSpilledToDiskRawTotal#1416L, bytesSpilledToDiskRawMin#1417L, bytesSpilledToDiskRawMax#1418L, bytesSpilledToDiskRawMedian#1419L, resultSerializationTimeTotal#1420L, resultSerializationTimeMin#1421L, resultSerializationTimeMax#1422L, resultSerializationTimeMedian#1423L, resultSizeToDriverTotal#1424L, resultSizeToDriverMin#1425L, resultSizeToDriverMax#1426L, resultSizeToDriverMedian#1427L, taskPeakExecutionMemoryMin#1428L, taskPeakExecutionMemoryMax#1429L, taskPeakExecutionMemoryMedian#1430L, persistencyBytesReadTotal#1431L, persistencyBytesReadMin#1432L, persistencyBytesReadMax#1433L, persistencyBytesReadMedian#1434L, persistencyRecordsReadTotal#1435L, persistencyRecordsReadMin#1436L, persistencyRecordsReadMax#1437L, persistencyRecordsReadMedian#1438L, persistencyBytesWrittenTotal#1439L, persistencyBytesWrittenMin#1440L, persistencyBytesWrittenMax#1441L, persistencyBytesWrittenMedian#1442L, persistencyRecordsWrittenTotal#1443L, persistencyRecordsWrittenMin#1444L, persistencyRecordsWrittenMax#1445L, persistencyRecordsWrittenMedian#1446L, shuffleConsumeRecordsReadTotal#1447L, shuffleConsumeRemoteBlocksFetchedTotal#1448L, shuffleConsumeLocalBlocksFetchedTotal#1449L, shuffleConsumeTotalBlocksFetchedTotal#1450L, shuffleConsumeRemoteBytesReadTotal#1451L, shuffleConsumeLocalBytesReadTotal#1452L, shuffleConsumeTotalBytesReadTotal#1453L, shuffleConsumeRemoteBytesReadToDiskTotal#1454L, shuffleConsumeFetchWaitTimeTotal#1455L, shuffleProduceBytesWrittenTotal#1456L, shuffleProduceRecordsWrittenTotal#1457L, shuffleProduceWriteTimeTotal#1458L]
Arguments: hashpartitioning(jobId#1386, 25), ENSURE_REQUIREMENTS, [plan_id=898]
(3) ShuffleQueryStage
Output [73]: [jobId#1386, stageCount#1387L, totalTaskCount#1388L, minTaskCountPerStage#1389L, maxTaskCountPerStage#1390L, medianTaskCountPerStage#1391L, bytesSpilledToDiskSerializedTotal#1392L, bytesSpilledToDiskSerializedMin#1393L, bytesSpilledToDiskSerializedMax#1394L, bytesSpilledToDiskSerializedMedian#1395L, taskCpuTimeTotal#1396L, taskCpuTimeMin#1397L, taskCpuTimeMax#1398L, taskCpuTimeMedian#1399L, taskDeserializeCpuTimeTotal#1400L, taskDeserializeCpuTimeMin#1401L, taskDeserializeCpuTimeMax#1402L, taskDeserializeCpuTimeMedian#1403L, taskDeserializeTimeTotal#1404L, taskDeserializeTimeMin#1405L, taskDeserializeTimeMax#1406L, taskDeserializeTimeMedian#1407L, taskRunTimeTotal#1408L, taskRunTimeMin#1409L, taskRunTimeMax#1410L, taskRunTimeMedian#1411L, jvmGcTimeTotal#1412L, jvmGcTimeMin#1413L, jvmGcTimeMax#1414L, jvmGcTimeMedian#1415L, bytesSpilledToDiskRawTotal#1416L, bytesSpilledToDiskRawMin#1417L, bytesSpilledToDiskRawMax#1418L, bytesSpilledToDiskRawMedian#1419L, resultSerializationTimeTotal#1420L, resultSerializationTimeMin#1421L, resultSerializationTimeMax#1422L, resultSerializationTimeMedian#1423L, resultSizeToDriverTotal#1424L, resultSizeToDriverMin#1425L, resultSizeToDriverMax#1426L, resultSizeToDriverMedian#1427L, taskPeakExecutionMemoryMin#1428L, taskPeakExecutionMemoryMax#1429L, taskPeakExecutionMemoryMedian#1430L, persistencyBytesReadTotal#1431L, persistencyBytesReadMin#1432L, persistencyBytesReadMax#1433L, persistencyBytesReadMedian#1434L, persistencyRecordsReadTotal#1435L, persistencyRecordsReadMin#1436L, persistencyRecordsReadMax#1437L, persistencyRecordsReadMedian#1438L, persistencyBytesWrittenTotal#1439L, persistencyBytesWrittenMin#1440L, persistencyBytesWrittenMax#1441L, persistencyBytesWrittenMedian#1442L, persistencyRecordsWrittenTotal#1443L, persistencyRecordsWrittenMin#1444L, persistencyRecordsWrittenMax#1445L, persistencyRecordsWrittenMedian#1446L, shuffleConsumeRecordsReadTotal#1447L, shuffleConsumeRemoteBlocksFetchedTotal#1448L, shuffleConsumeLocalBlocksFetchedTotal#1449L, shuffleConsumeTotalBlocksFetchedTotal#1450L, shuffleConsumeRemoteBytesReadTotal#1451L, shuffleConsumeLocalBytesReadTotal#1452L, shuffleConsumeTotalBytesReadTotal#1453L, shuffleConsumeRemoteBytesReadToDiskTotal#1454L, shuffleConsumeFetchWaitTimeTotal#1455L, shuffleProduceBytesWrittenTotal#1456L, shuffleProduceRecordsWrittenTotal#1457L, shuffleProduceWriteTimeTotal#1458L]
Arguments: 0
(4) AQEShuffleRead
Input [73]: [jobId#1386, stageCount#1387L, totalTaskCount#1388L, minTaskCountPerStage#1389L, maxTaskCountPerStage#1390L, medianTaskCountPerStage#1391L, bytesSpilledToDiskSerializedTotal#1392L, bytesSpilledToDiskSerializedMin#1393L, bytesSpilledToDiskSerializedMax#1394L, bytesSpilledToDiskSerializedMedian#1395L, taskCpuTimeTotal#1396L, taskCpuTimeMin#1397L, taskCpuTimeMax#1398L, taskCpuTimeMedian#1399L, taskDeserializeCpuTimeTotal#1400L, taskDeserializeCpuTimeMin#1401L, taskDeserializeCpuTimeMax#1402L, taskDeserializeCpuTimeMedian#1403L, taskDeserializeTimeTotal#1404L, taskDeserializeTimeMin#1405L, taskDeserializeTimeMax#1406L, taskDeserializeTimeMedian#1407L, taskRunTimeTotal#1408L, taskRunTimeMin#1409L, taskRunTimeMax#1410L, taskRunTimeMedian#1411L, jvmGcTimeTotal#1412L, jvmGcTimeMin#1413L, jvmGcTimeMax#1414L, jvmGcTimeMedian#1415L, bytesSpilledToDiskRawTotal#1416L, bytesSpilledToDiskRawMin#1417L, bytesSpilledToDiskRawMax#1418L, bytesSpilledToDiskRawMedian#1419L, resultSerializationTimeTotal#1420L, resultSerializationTimeMin#1421L, resultSerializationTimeMax#1422L, resultSerializationTimeMedian#1423L, resultSizeToDriverTotal#1424L, resultSizeToDriverMin#1425L, resultSizeToDriverMax#1426L, resultSizeToDriverMedian#1427L, taskPeakExecutionMemoryMin#1428L, taskPeakExecutionMemoryMax#1429L, taskPeakExecutionMemoryMedian#1430L, persistencyBytesReadTotal#1431L, persistencyBytesReadMin#1432L, persistencyBytesReadMax#1433L, persistencyBytesReadMedian#1434L, persistencyRecordsReadTotal#1435L, persistencyRecordsReadMin#1436L, persistencyRecordsReadMax#1437L, persistencyRecordsReadMedian#1438L, persistencyBytesWrittenTotal#1439L, persistencyBytesWrittenMin#1440L, persistencyBytesWrittenMax#1441L, persistencyBytesWrittenMedian#1442L, persistencyRecordsWrittenTotal#1443L, persistencyRecordsWrittenMin#1444L, persistencyRecordsWrittenMax#1445L, persistencyRecordsWrittenMedian#1446L, shuffleConsumeRecordsReadTotal#1447L, shuffleConsumeRemoteBlocksFetchedTotal#1448L, shuffleConsumeLocalBlocksFetchedTotal#1449L, shuffleConsumeTotalBlocksFetchedTotal#1450L, shuffleConsumeRemoteBytesReadTotal#1451L, shuffleConsumeLocalBytesReadTotal#1452L, shuffleConsumeTotalBytesReadTotal#1453L, shuffleConsumeRemoteBytesReadToDiskTotal#1454L, shuffleConsumeFetchWaitTimeTotal#1455L, shuffleProduceBytesWrittenTotal#1456L, shuffleProduceRecordsWrittenTotal#1457L, shuffleProduceWriteTimeTotal#1458L]
Arguments: coalesced
(5) Sort [codegen id : 1]
Input [73]: [jobId#1386, stageCount#1387L, totalTaskCount#1388L, minTaskCountPerStage#1389L, maxTaskCountPerStage#1390L, medianTaskCountPerStage#1391L, bytesSpilledToDiskSerializedTotal#1392L, bytesSpilledToDiskSerializedMin#1393L, bytesSpilledToDiskSerializedMax#1394L, bytesSpilledToDiskSerializedMedian#1395L, taskCpuTimeTotal#1396L, taskCpuTimeMin#1397L, taskCpuTimeMax#1398L, taskCpuTimeMedian#1399L, taskDeserializeCpuTimeTotal#1400L, taskDeserializeCpuTimeMin#1401L, taskDeserializeCpuTimeMax#1402L, taskDeserializeCpuTimeMedian#1403L, taskDeserializeTimeTotal#1404L, taskDeserializeTimeMin#1405L, taskDeserializeTimeMax#1406L, taskDeserializeTimeMedian#1407L, taskRunTimeTotal#1408L, taskRunTimeMin#1409L, taskRunTimeMax#1410L, taskRunTimeMedian#1411L, jvmGcTimeTotal#1412L, jvmGcTimeMin#1413L, jvmGcTimeMax#1414L, jvmGcTimeMedian#1415L, bytesSpilledToDiskRawTotal#1416L, bytesSpilledToDiskRawMin#1417L, bytesSpilledToDiskRawMax#1418L, bytesSpilledToDiskRawMedian#1419L, resultSerializationTimeTotal#1420L, resultSerializationTimeMin#1421L, resultSerializationTimeMax#1422L, resultSerializationTimeMedian#1423L, resultSizeToDriverTotal#1424L, resultSizeToDriverMin#1425L, resultSizeToDriverMax#1426L, resultSizeToDriverMedian#1427L, taskPeakExecutionMemoryMin#1428L, taskPeakExecutionMemoryMax#1429L, taskPeakExecutionMemoryMedian#1430L, persistencyBytesReadTotal#1431L, persistencyBytesReadMin#1432L, persistencyBytesReadMax#1433L, persistencyBytesReadMedian#1434L, persistencyRecordsReadTotal#1435L, persistencyRecordsReadMin#1436L, persistencyRecordsReadMax#1437L, persistencyRecordsReadMedian#1438L, persistencyBytesWrittenTotal#1439L, persistencyBytesWrittenMin#1440L, persistencyBytesWrittenMax#1441L, persistencyBytesWrittenMedian#1442L, persistencyRecordsWrittenTotal#1443L, persistencyRecordsWrittenMin#1444L, persistencyRecordsWrittenMax#1445L, persistencyRecordsWrittenMedian#1446L, shuffleConsumeRecordsReadTotal#1447L, shuffleConsumeRemoteBlocksFetchedTotal#1448L, shuffleConsumeLocalBlocksFetchedTotal#1449L, shuffleConsumeTotalBlocksFetchedTotal#1450L, shuffleConsumeRemoteBytesReadTotal#1451L, shuffleConsumeLocalBytesReadTotal#1452L, shuffleConsumeTotalBytesReadTotal#1453L, shuffleConsumeRemoteBytesReadToDiskTotal#1454L, shuffleConsumeFetchWaitTimeTotal#1455L, shuffleProduceBytesWrittenTotal#1456L, shuffleProduceRecordsWrittenTotal#1457L, shuffleProduceWriteTimeTotal#1458L]
Arguments: [jobId#1386 ASC NULLS FIRST], false, 0
(6) LocalTableScan
Output [4]: [jobId#1459, peakExecutionMemory#1460L, peakExecutionMemoryCliqueDuration#1461L, peakExecutionMemoryCliqueSize#1462L]
Arguments: [jobId#1459, peakExecutionMemory#1460L, peakExecutionMemoryCliqueDuration#1461L, peakExecutionMemoryCliqueSize#1462L]
(7) Exchange
Input [4]: [jobId#1459, peakExecutionMemory#1460L, peakExecutionMemoryCliqueDuration#1461L, peakExecutionMemoryCliqueSize#1462L]
Arguments: hashpartitioning(jobId#1459, 25), ENSURE_REQUIREMENTS, [plan_id=899]
(8) ShuffleQueryStage
Output [4]: [jobId#1459, peakExecutionMemory#1460L, peakExecutionMemoryCliqueDuration#1461L, peakExecutionMemoryCliqueSize#1462L]
Arguments: 1
(9) AQEShuffleRead
Input [4]: [jobId#1459, peakExecutionMemory#1460L, peakExecutionMemoryCliqueDuration#1461L, peakExecutionMemoryCliqueSize#1462L]
Arguments: coalesced
(10) Sort [codegen id : 2]
Input [4]: [jobId#1459, peakExecutionMemory#1460L, peakExecutionMemoryCliqueDuration#1461L, peakExecutionMemoryCliqueSize#1462L]
Arguments: [jobId#1459 ASC NULLS FIRST], false, 0
(11) SortMergeJoin [codegen id : 3]
Left keys [1]: [jobId#1386]
Right keys [1]: [jobId#1459]
Join type: FullOuter
Join condition: None
(12) Project [codegen id : 3]
Output [76]: [coalesce(jobId#1386, jobId#1459) AS jobId#1469, stageCount#1387L, totalTaskCount#1388L, minTaskCountPerStage#1389L, maxTaskCountPerStage#1390L, medianTaskCountPerStage#1391L, bytesSpilledToDiskSerializedTotal#1392L, bytesSpilledToDiskSerializedMin#1393L, bytesSpilledToDiskSerializedMax#1394L, bytesSpilledToDiskSerializedMedian#1395L, taskCpuTimeTotal#1396L, taskCpuTimeMin#1397L, taskCpuTimeMax#1398L, taskCpuTimeMedian#1399L, taskDeserializeCpuTimeTotal#1400L, taskDeserializeCpuTimeMin#1401L, taskDeserializeCpuTimeMax#1402L, taskDeserializeCpuTimeMedian#1403L, taskDeserializeTimeTotal#1404L, taskDeserializeTimeMin#1405L, taskDeserializeTimeMax#1406L, taskDeserializeTimeMedian#1407L, taskRunTimeTotal#1408L, taskRunTimeMin#1409L, taskRunTimeMax#1410L, taskRunTimeMedian#1411L, jvmGcTimeTotal#1412L, jvmGcTimeMin#1413L, jvmGcTimeMax#1414L, jvmGcTimeMedian#1415L, bytesSpilledToDiskRawTotal#1416L, bytesSpilledToDiskRawMin#1417L, bytesSpilledToDiskRawMax#1418L, bytesSpilledToDiskRawMedian#1419L, resultSerializationTimeTotal#1420L, resultSerializationTimeMin#1421L, resultSerializationTimeMax#1422L, resultSerializationTimeMedian#1423L, resultSizeToDriverTotal#1424L, resultSizeToDriverMin#1425L, resultSizeToDriverMax#1426L, resultSizeToDriverMedian#1427L, taskPeakExecutionMemoryMin#1428L, taskPeakExecutionMemoryMax#1429L, taskPeakExecutionMemoryMedian#1430L, persistencyBytesReadTotal#1431L, persistencyBytesReadMin#1432L, persistencyBytesReadMax#1433L, persistencyBytesReadMedian#1434L, persistencyRecordsReadTotal#1435L, persistencyRecordsReadMin#1436L, persistencyRecordsReadMax#1437L, persistencyRecordsReadMedian#1438L, persistencyBytesWrittenTotal#1439L, persistencyBytesWrittenMin#1440L, persistencyBytesWrittenMax#1441L, persistencyBytesWrittenMedian#1442L, persistencyRecordsWrittenTotal#1443L, persistencyRecordsWrittenMin#1444L, persistencyRecordsWrittenMax#1445L, persistencyRecordsWrittenMedian#1446L, shuffleConsumeRecordsReadTotal#1447L, shuffleConsumeRemoteBlocksFetchedTotal#1448L, shuffleConsumeLocalBlocksFetchedTotal#1449L, shuffleConsumeTotalBlocksFetchedTotal#1450L, shuffleConsumeRemoteBytesReadTotal#1451L, shuffleConsumeLocalBytesReadTotal#1452L, shuffleConsumeTotalBytesReadTotal#1453L, shuffleConsumeRemoteBytesReadToDiskTotal#1454L, shuffleConsumeFetchWaitTimeTotal#1455L, shuffleProduceBytesWrittenTotal#1456L, shuffleProduceRecordsWrittenTotal#1457L, shuffleProduceWriteTimeTotal#1458L, peakExecutionMemory#1460L, peakExecutionMemoryCliqueDuration#1461L, peakExecutionMemoryCliqueSize#1462L]
Input [77]: [jobId#1386, stageCount#1387L, totalTaskCount#1388L, minTaskCountPerStage#1389L, maxTaskCountPerStage#1390L, medianTaskCountPerStage#1391L, bytesSpilledToDiskSerializedTotal#1392L, bytesSpilledToDiskSerializedMin#1393L, bytesSpilledToDiskSerializedMax#1394L, bytesSpilledToDiskSerializedMedian#1395L, taskCpuTimeTotal#1396L, taskCpuTimeMin#1397L, taskCpuTimeMax#1398L, taskCpuTimeMedian#1399L, taskDeserializeCpuTimeTotal#1400L, taskDeserializeCpuTimeMin#1401L, taskDeserializeCpuTimeMax#1402L, taskDeserializeCpuTimeMedian#1403L, taskDeserializeTimeTotal#1404L, taskDeserializeTimeMin#1405L, taskDeserializeTimeMax#1406L, taskDeserializeTimeMedian#1407L, taskRunTimeTotal#1408L, taskRunTimeMin#1409L, taskRunTimeMax#1410L, taskRunTimeMedian#1411L, jvmGcTimeTotal#1412L, jvmGcTimeMin#1413L, jvmGcTimeMax#1414L, jvmGcTimeMedian#1415L, bytesSpilledToDiskRawTotal#1416L, bytesSpilledToDiskRawMin#1417L, bytesSpilledToDiskRawMax#1418L, bytesSpilledToDiskRawMedian#1419L, resultSerializationTimeTotal#1420L, resultSerializationTimeMin#1421L, resultSerializationTimeMax#1422L, resultSerializationTimeMedian#1423L, resultSizeToDriverTotal#1424L, resultSizeToDriverMin#1425L, resultSizeToDriverMax#1426L, resultSizeToDriverMedian#1427L, taskPeakExecutionMemoryMin#1428L, taskPeakExecutionMemoryMax#1429L, taskPeakExecutionMemoryMedian#1430L, persistencyBytesReadTotal#1431L, persistencyBytesReadMin#1432L, persistencyBytesReadMax#1433L, persistencyBytesReadMedian#1434L, persistencyRecordsReadTotal#1435L, persistencyRecordsReadMin#1436L, persistencyRecordsReadMax#1437L, persistencyRecordsReadMedian#1438L, persistencyBytesWrittenTotal#1439L, persistencyBytesWrittenMin#1440L, persistencyBytesWrittenMax#1441L, persistencyBytesWrittenMedian#1442L, persistencyRecordsWrittenTotal#1443L, persistencyRecordsWrittenMin#1444L, persistencyRecordsWrittenMax#1445L, persistencyRecordsWrittenMedian#1446L, shuffleConsumeRecordsReadTotal#1447L, shuffleConsumeRemoteBlocksFetchedTotal#1448L, shuffleConsumeLocalBlocksFetchedTotal#1449L, shuffleConsumeTotalBlocksFetchedTotal#1450L, shuffleConsumeRemoteBytesReadTotal#1451L, shuffleConsumeLocalBytesReadTotal#1452L, shuffleConsumeTotalBytesReadTotal#1453L, shuffleConsumeRemoteBytesReadToDiskTotal#1454L, shuffleConsumeFetchWaitTimeTotal#1455L, shuffleProduceBytesWrittenTotal#1456L, shuffleProduceRecordsWrittenTotal#1457L, shuffleProduceWriteTimeTotal#1458L, jobId#1459, peakExecutionMemory#1460L, peakExecutionMemoryCliqueDuration#1461L, peakExecutionMemoryCliqueSize#1462L]
(13) Exchange
Input [76]: [jobId#1469, stageCount#1387L, totalTaskCount#1388L, minTaskCountPerStage#1389L, maxTaskCountPerStage#1390L, medianTaskCountPerStage#1391L, bytesSpilledToDiskSerializedTotal#1392L, bytesSpilledToDiskSerializedMin#1393L, bytesSpilledToDiskSerializedMax#1394L, bytesSpilledToDiskSerializedMedian#1395L, taskCpuTimeTotal#1396L, taskCpuTimeMin#1397L, taskCpuTimeMax#1398L, taskCpuTimeMedian#1399L, taskDeserializeCpuTimeTotal#1400L, taskDeserializeCpuTimeMin#1401L, taskDeserializeCpuTimeMax#1402L, taskDeserializeCpuTimeMedian#1403L, taskDeserializeTimeTotal#1404L, taskDeserializeTimeMin#1405L, taskDeserializeTimeMax#1406L, taskDeserializeTimeMedian#1407L, taskRunTimeTotal#1408L, taskRunTimeMin#1409L, taskRunTimeMax#1410L, taskRunTimeMedian#1411L, jvmGcTimeTotal#1412L, jvmGcTimeMin#1413L, jvmGcTimeMax#1414L, jvmGcTimeMedian#1415L, bytesSpilledToDiskRawTotal#1416L, bytesSpilledToDiskRawMin#1417L, bytesSpilledToDiskRawMax#1418L, bytesSpilledToDiskRawMedian#1419L, resultSerializationTimeTotal#1420L, resultSerializationTimeMin#1421L, resultSerializationTimeMax#1422L, resultSerializationTimeMedian#1423L, resultSizeToDriverTotal#1424L, resultSizeToDriverMin#1425L, resultSizeToDriverMax#1426L, resultSizeToDriverMedian#1427L, taskPeakExecutionMemoryMin#1428L, taskPeakExecutionMemoryMax#1429L, taskPeakExecutionMemoryMedian#1430L, persistencyBytesReadTotal#1431L, persistencyBytesReadMin#1432L, persistencyBytesReadMax#1433L, persistencyBytesReadMedian#1434L, persistencyRecordsReadTotal#1435L, persistencyRecordsReadMin#1436L, persistencyRecordsReadMax#1437L, persistencyRecordsReadMedian#1438L, persistencyBytesWrittenTotal#1439L, persistencyBytesWrittenMin#1440L, persistencyBytesWrittenMax#1441L, persistencyBytesWrittenMedian#1442L, persistencyRecordsWrittenTotal#1443L, persistencyRecordsWrittenMin#1444L, persistencyRecordsWrittenMax#1445L, persistencyRecordsWrittenMedian#1446L, shuffleConsumeRecordsReadTotal#1447L, shuffleConsumeRemoteBlocksFetchedTotal#1448L, shuffleConsumeLocalBlocksFetchedTotal#1449L, shuffleConsumeTotalBlocksFetchedTotal#1450L, shuffleConsumeRemoteBytesReadTotal#1451L, shuffleConsumeLocalBytesReadTotal#1452L, shuffleConsumeTotalBytesReadTotal#1453L, shuffleConsumeRemoteBytesReadToDiskTotal#1454L, shuffleConsumeFetchWaitTimeTotal#1455L, shuffleProduceBytesWrittenTotal#1456L, shuffleProduceRecordsWrittenTotal#1457L, shuffleProduceWriteTimeTotal#1458L, peakExecutionMemory#1460L, peakExecutionMemoryCliqueDuration#1461L, peakExecutionMemoryCliqueSize#1462L]
Arguments: hashpartitioning(jobId#1469, 25), ENSURE_REQUIREMENTS, [plan_id=1062]
(14) ShuffleQueryStage
Output [76]: [jobId#1469, stageCount#1387L, totalTaskCount#1388L, minTaskCountPerStage#1389L, maxTaskCountPerStage#1390L, medianTaskCountPerStage#1391L, bytesSpilledToDiskSerializedTotal#1392L, bytesSpilledToDiskSerializedMin#1393L, bytesSpilledToDiskSerializedMax#1394L, bytesSpilledToDiskSerializedMedian#1395L, taskCpuTimeTotal#1396L, taskCpuTimeMin#1397L, taskCpuTimeMax#1398L, taskCpuTimeMedian#1399L, taskDeserializeCpuTimeTotal#1400L, taskDeserializeCpuTimeMin#1401L, taskDeserializeCpuTimeMax#1402L, taskDeserializeCpuTimeMedian#1403L, taskDeserializeTimeTotal#1404L, taskDeserializeTimeMin#1405L, taskDeserializeTimeMax#1406L, taskDeserializeTimeMedian#1407L, taskRunTimeTotal#1408L, taskRunTimeMin#1409L, taskRunTimeMax#1410L, taskRunTimeMedian#1411L, jvmGcTimeTotal#1412L, jvmGcTimeMin#1413L, jvmGcTimeMax#1414L, jvmGcTimeMedian#1415L, bytesSpilledToDiskRawTotal#1416L, bytesSpilledToDiskRawMin#1417L, bytesSpilledToDiskRawMax#1418L, bytesSpilledToDiskRawMedian#1419L, resultSerializationTimeTotal#1420L, resultSerializationTimeMin#1421L, resultSerializationTimeMax#1422L, resultSerializationTimeMedian#1423L, resultSizeToDriverTotal#1424L, resultSizeToDriverMin#1425L, resultSizeToDriverMax#1426L, resultSizeToDriverMedian#1427L, taskPeakExecutionMemoryMin#1428L, taskPeakExecutionMemoryMax#1429L, taskPeakExecutionMemoryMedian#1430L, persistencyBytesReadTotal#1431L, persistencyBytesReadMin#1432L, persistencyBytesReadMax#1433L, persistencyBytesReadMedian#1434L, persistencyRecordsReadTotal#1435L, persistencyRecordsReadMin#1436L, persistencyRecordsReadMax#1437L, persistencyRecordsReadMedian#1438L, persistencyBytesWrittenTotal#1439L, persistencyBytesWrittenMin#1440L, persistencyBytesWrittenMax#1441L, persistencyBytesWrittenMedian#1442L, persistencyRecordsWrittenTotal#1443L, persistencyRecordsWrittenMin#1444L, persistencyRecordsWrittenMax#1445L, persistencyRecordsWrittenMedian#1446L, shuffleConsumeRecordsReadTotal#1447L, shuffleConsumeRemoteBlocksFetchedTotal#1448L, shuffleConsumeLocalBlocksFetchedTotal#1449L, shuffleConsumeTotalBlocksFetchedTotal#1450L, shuffleConsumeRemoteBytesReadTotal#1451L, shuffleConsumeLocalBytesReadTotal#1452L, shuffleConsumeTotalBytesReadTotal#1453L, shuffleConsumeRemoteBytesReadToDiskTotal#1454L, shuffleConsumeFetchWaitTimeTotal#1455L, shuffleProduceBytesWrittenTotal#1456L, shuffleProduceRecordsWrittenTotal#1457L, shuffleProduceWriteTimeTotal#1458L, peakExecutionMemory#1460L, peakExecutionMemoryCliqueDuration#1461L, peakExecutionMemoryCliqueSize#1462L]
Arguments: 3
(15) AQEShuffleRead
Input [76]: [jobId#1469, stageCount#1387L, totalTaskCount#1388L, minTaskCountPerStage#1389L, maxTaskCountPerStage#1390L, medianTaskCountPerStage#1391L, bytesSpilledToDiskSerializedTotal#1392L, bytesSpilledToDiskSerializedMin#1393L, bytesSpilledToDiskSerializedMax#1394L, bytesSpilledToDiskSerializedMedian#1395L, taskCpuTimeTotal#1396L, taskCpuTimeMin#1397L, taskCpuTimeMax#1398L, taskCpuTimeMedian#1399L, taskDeserializeCpuTimeTotal#1400L, taskDeserializeCpuTimeMin#1401L, taskDeserializeCpuTimeMax#1402L, taskDeserializeCpuTimeMedian#1403L, taskDeserializeTimeTotal#1404L, taskDeserializeTimeMin#1405L, taskDeserializeTimeMax#1406L, taskDeserializeTimeMedian#1407L, taskRunTimeTotal#1408L, taskRunTimeMin#1409L, taskRunTimeMax#1410L, taskRunTimeMedian#1411L, jvmGcTimeTotal#1412L, jvmGcTimeMin#1413L, jvmGcTimeMax#1414L, jvmGcTimeMedian#1415L, bytesSpilledToDiskRawTotal#1416L, bytesSpilledToDiskRawMin#1417L, bytesSpilledToDiskRawMax#1418L, bytesSpilledToDiskRawMedian#1419L, resultSerializationTimeTotal#1420L, resultSerializationTimeMin#1421L, resultSerializationTimeMax#1422L, resultSerializationTimeMedian#1423L, resultSizeToDriverTotal#1424L, resultSizeToDriverMin#1425L, resultSizeToDriverMax#1426L, resultSizeToDriverMedian#1427L, taskPeakExecutionMemoryMin#1428L, taskPeakExecutionMemoryMax#1429L, taskPeakExecutionMemoryMedian#1430L, persistencyBytesReadTotal#1431L, persistencyBytesReadMin#1432L, persistencyBytesReadMax#1433L, persistencyBytesReadMedian#1434L, persistencyRecordsReadTotal#1435L, persistencyRecordsReadMin#1436L, persistencyRecordsReadMax#1437L, persistencyRecordsReadMedian#1438L, persistencyBytesWrittenTotal#1439L, persistencyBytesWrittenMin#1440L, persistencyBytesWrittenMax#1441L, persistencyBytesWrittenMedian#1442L, persistencyRecordsWrittenTotal#1443L, persistencyRecordsWrittenMin#1444L, persistencyRecordsWrittenMax#1445L, persistencyRecordsWrittenMedian#1446L, shuffleConsumeRecordsReadTotal#1447L, shuffleConsumeRemoteBlocksFetchedTotal#1448L, shuffleConsumeLocalBlocksFetchedTotal#1449L, shuffleConsumeTotalBlocksFetchedTotal#1450L, shuffleConsumeRemoteBytesReadTotal#1451L, shuffleConsumeLocalBytesReadTotal#1452L, shuffleConsumeTotalBytesReadTotal#1453L, shuffleConsumeRemoteBytesReadToDiskTotal#1454L, shuffleConsumeFetchWaitTimeTotal#1455L, shuffleProduceBytesWrittenTotal#1456L, shuffleProduceRecordsWrittenTotal#1457L, shuffleProduceWriteTimeTotal#1458L, peakExecutionMemory#1460L, peakExecutionMemoryCliqueDuration#1461L, peakExecutionMemoryCliqueSize#1462L]
Arguments: coalesced
(16) Sort [codegen id : 4]
Input [76]: [jobId#1469, stageCount#1387L, totalTaskCount#1388L, minTaskCountPerStage#1389L, maxTaskCountPerStage#1390L, medianTaskCountPerStage#1391L, bytesSpilledToDiskSerializedTotal#1392L, bytesSpilledToDiskSerializedMin#1393L, bytesSpilledToDiskSerializedMax#1394L, bytesSpilledToDiskSerializedMedian#1395L, taskCpuTimeTotal#1396L, taskCpuTimeMin#1397L, taskCpuTimeMax#1398L, taskCpuTimeMedian#1399L, taskDeserializeCpuTimeTotal#1400L, taskDeserializeCpuTimeMin#1401L, taskDeserializeCpuTimeMax#1402L, taskDeserializeCpuTimeMedian#1403L, taskDeserializeTimeTotal#1404L, taskDeserializeTimeMin#1405L, taskDeserializeTimeMax#1406L, taskDeserializeTimeMedian#1407L, taskRunTimeTotal#1408L, taskRunTimeMin#1409L, taskRunTimeMax#1410L, taskRunTimeMedian#1411L, jvmGcTimeTotal#1412L, jvmGcTimeMin#1413L, jvmGcTimeMax#1414L, jvmGcTimeMedian#1415L, bytesSpilledToDiskRawTotal#1416L, bytesSpilledToDiskRawMin#1417L, bytesSpilledToDiskRawMax#1418L, bytesSpilledToDiskRawMedian#1419L, resultSerializationTimeTotal#1420L, resultSerializationTimeMin#1421L, resultSerializationTimeMax#1422L, resultSerializationTimeMedian#1423L, resultSizeToDriverTotal#1424L, resultSizeToDriverMin#1425L, resultSizeToDriverMax#1426L, resultSizeToDriverMedian#1427L, taskPeakExecutionMemoryMin#1428L, taskPeakExecutionMemoryMax#1429L, taskPeakExecutionMemoryMedian#1430L, persistencyBytesReadTotal#1431L, persistencyBytesReadMin#1432L, persistencyBytesReadMax#1433L, persistencyBytesReadMedian#1434L, persistencyRecordsReadTotal#1435L, persistencyRecordsReadMin#1436L, persistencyRecordsReadMax#1437L, persistencyRecordsReadMedian#1438L, persistencyBytesWrittenTotal#1439L, persistencyBytesWrittenMin#1440L, persistencyBytesWrittenMax#1441L, persistencyBytesWrittenMedian#1442L, persistencyRecordsWrittenTotal#1443L, persistencyRecordsWrittenMin#1444L, persistencyRecordsWrittenMax#1445L, persistencyRecordsWrittenMedian#1446L, shuffleConsumeRecordsReadTotal#1447L, shuffleConsumeRemoteBlocksFetchedTotal#1448L, shuffleConsumeLocalBlocksFetchedTotal#1449L, shuffleConsumeTotalBlocksFetchedTotal#1450L, shuffleConsumeRemoteBytesReadTotal#1451L, shuffleConsumeLocalBytesReadTotal#1452L, shuffleConsumeTotalBytesReadTotal#1453L, shuffleConsumeRemoteBytesReadToDiskTotal#1454L, shuffleConsumeFetchWaitTimeTotal#1455L, shuffleProduceBytesWrittenTotal#1456L, shuffleProduceRecordsWrittenTotal#1457L, shuffleProduceWriteTimeTotal#1458L, peakExecutionMemory#1460L, peakExecutionMemoryCliqueDuration#1461L, peakExecutionMemoryCliqueSize#1462L]
Arguments: [jobId#1469 ASC NULLS FIRST], false, 0
(17) LocalTableScan
Output [6]: [jobId#1463, rddStorageDiskSizeTotal#1464L, rddStorageMemSizeTotal#1465L, rddNumCachedPartitionsTotal#1466, rddNumPartitionsTotal#1467, numberOfExecutors#1468]
Arguments: [jobId#1463, rddStorageDiskSizeTotal#1464L, rddStorageMemSizeTotal#1465L, rddNumCachedPartitionsTotal#1466, rddNumPartitionsTotal#1467, numberOfExecutors#1468]
(18) Exchange
Input [6]: [jobId#1463, rddStorageDiskSizeTotal#1464L, rddStorageMemSizeTotal#1465L, rddNumCachedPartitionsTotal#1466, rddNumPartitionsTotal#1467, numberOfExecutors#1468]
Arguments: hashpartitioning(jobId#1463, 25), ENSURE_REQUIREMENTS, [plan_id=907]
(19) ShuffleQueryStage
Output [6]: [jobId#1463, rddStorageDiskSizeTotal#1464L, rddStorageMemSizeTotal#1465L, rddNumCachedPartitionsTotal#1466, rddNumPartitionsTotal#1467, numberOfExecutors#1468]
Arguments: 2
(20) AQEShuffleRead
Input [6]: [jobId#1463, rddStorageDiskSizeTotal#1464L, rddStorageMemSizeTotal#1465L, rddNumCachedPartitionsTotal#1466, rddNumPartitionsTotal#1467, numberOfExecutors#1468]
Arguments: coalesced
(21) Sort [codegen id : 5]
Input [6]: [jobId#1463, rddStorageDiskSizeTotal#1464L, rddStorageMemSizeTotal#1465L, rddNumCachedPartitionsTotal#1466, rddNumPartitionsTotal#1467, numberOfExecutors#1468]
Arguments: [jobId#1463 ASC NULLS FIRST], false, 0
(22) SortMergeJoin [codegen id : 6]
Left keys [1]: [jobId#1469]
Right keys [1]: [jobId#1463]
Join type: FullOuter
Join condition: None
(23) Project [codegen id : 6]
Output [92]: [coalesce(jobId#1469, jobId#1463) AS jobId#1470, stageCount#1387L, totalTaskCount#1388L, minTaskCountPerStage#1389L, maxTaskCountPerStage#1390L, medianTaskCountPerStage#1391L, bytesSpilledToDiskSerializedTotal#1392L, bytesSpilledToDiskSerializedMin#1393L, bytesSpilledToDiskSerializedMax#1394L, bytesSpilledToDiskSerializedMedian#1395L, taskCpuTimeTotal#1396L, taskCpuTimeMin#1397L, taskCpuTimeMax#1398L, taskCpuTimeMedian#1399L, taskDeserializeCpuTimeTotal#1400L, taskDeserializeCpuTimeMin#1401L, taskDeserializeCpuTimeMax#1402L, taskDeserializeCpuTimeMedian#1403L, taskDeserializeTimeTotal#1404L, taskDeserializeTimeMin#1405L, taskDeserializeTimeMax#1406L, taskDeserializeTimeMedian#1407L, taskRunTimeTotal#1408L, taskRunTimeMin#1409L, taskRunTimeMax#1410L, taskRunTimeMedian#1411L, jvmGcTimeTotal#1412L, jvmGcTimeMin#1413L, jvmGcTimeMax#1414L, jvmGcTimeMedian#1415L, bytesSpilledToDiskRawTotal#1416L, bytesSpilledToDiskRawMin#1417L, bytesSpilledToDiskRawMax#1418L, bytesSpilledToDiskRawMedian#1419L, resultSerializationTimeTotal#1420L, resultSerializationTimeMin#1421L, resultSerializationTimeMax#1422L, resultSerializationTimeMedian#1423L, resultSizeToDriverTotal#1424L, resultSizeToDriverMin#1425L, resultSizeToDriverMax#1426L, resultSizeToDriverMedian#1427L, taskPeakExecutionMemoryMin#1428L, taskPeakExecutionMemoryMax#1429L, taskPeakExecutionMemoryMedian#1430L, persistencyBytesReadTotal#1431L, persistencyBytesReadMin#1432L, persistencyBytesReadMax#1433L, persistencyBytesReadMedian#1434L, persistencyRecordsReadTotal#1435L, persistencyRecordsReadMin#1436L, persistencyRecordsReadMax#1437L, persistencyRecordsReadMedian#1438L, persistencyBytesWrittenTotal#1439L, persistencyBytesWrittenMin#1440L, persistencyBytesWrittenMax#1441L, persistencyBytesWrittenMedian#1442L, persistencyRecordsWrittenTotal#1443L, persistencyRecordsWrittenMin#1444L, persistencyRecordsWrittenMax#1445L, persistencyRecordsWrittenMedian#1446L, shuffleConsumeRecordsReadTotal#1447L, shuffleConsumeRemoteBlocksFetchedTotal#1448L, shuffleConsumeLocalBlocksFetchedTotal#1449L, shuffleConsumeTotalBlocksFetchedTotal#1450L, shuffleConsumeRemoteBytesReadTotal#1451L, shuffleConsumeLocalBytesReadTotal#1452L, shuffleConsumeTotalBytesReadTotal#1453L, shuffleConsumeRemoteBytesReadToDiskTotal#1454L, shuffleConsumeFetchWaitTimeTotal#1455L, shuffleProduceBytesWrittenTotal#1456L, shuffleProduceRecordsWrittenTotal#1457L, shuffleProduceWriteTimeTotal#1458L, peakExecutionMemory#1460L, peakExecutionMemoryCliqueDuration#1461L, peakExecutionMemoryCliqueSize#1462L, rddStorageDiskSizeTotal#1464L, rddStorageMemSizeTotal#1465L, rddNumCachedPartitionsTotal#1466, rddNumPartitionsTotal#1467, numberOfExecutors#1468, 10000000120 AS replenishmentRunId#1471L, 6944346648028224943 AS tenantId#1472, 8378 AS cornerstoneTenantId#1473L, Daily_grocery AS marketUnit#1474, STANDARD AS scenario#1475, 0221f660-f20c-3ec8-a242-7de8ba8fb864 AS activityId#1476, PrepareStreams AS activityType#1477, CalculateOrderProposalsWorkflow AS workflowType#1478, 7421d6c7-702b-33bf-84ff-d21f3533b79c AS workflowId#1479, 1 AS activityAttempt#1480, AS gitCommitId#1482]
Input [82]: [jobId#1469, stageCount#1387L, totalTaskCount#1388L, minTaskCountPerStage#1389L, maxTaskCountPerStage#1390L, medianTaskCountPerStage#1391L, bytesSpilledToDiskSerializedTotal#1392L, bytesSpilledToDiskSerializedMin#1393L, bytesSpilledToDiskSerializedMax#1394L, bytesSpilledToDiskSerializedMedian#1395L, taskCpuTimeTotal#1396L, taskCpuTimeMin#1397L, taskCpuTimeMax#1398L, taskCpuTimeMedian#1399L, taskDeserializeCpuTimeTotal#1400L, taskDeserializeCpuTimeMin#1401L, taskDeserializeCpuTimeMax#1402L, taskDeserializeCpuTimeMedian#1403L, taskDeserializeTimeTotal#1404L, taskDeserializeTimeMin#1405L, taskDeserializeTimeMax#1406L, taskDeserializeTimeMedian#1407L, taskRunTimeTotal#1408L, taskRunTimeMin#1409L, taskRunTimeMax#1410L, taskRunTimeMedian#1411L, jvmGcTimeTotal#1412L, jvmGcTimeMin#1413L, jvmGcTimeMax#1414L, jvmGcTimeMedian#1415L, bytesSpilledToDiskRawTotal#1416L, bytesSpilledToDiskRawMin#1417L, bytesSpilledToDiskRawMax#1418L, bytesSpilledToDiskRawMedian#1419L, resultSerializationTimeTotal#1420L, resultSerializationTimeMin#1421L, resultSerializationTimeMax#1422L, resultSerializationTimeMedian#1423L, resultSizeToDriverTotal#1424L, resultSizeToDriverMin#1425L, resultSizeToDriverMax#1426L, resultSizeToDriverMedian#1427L, taskPeakExecutionMemoryMin#1428L, taskPeakExecutionMemoryMax#1429L, taskPeakExecutionMemoryMedian#1430L, persistencyBytesReadTotal#1431L, persistencyBytesReadMin#1432L, persistencyBytesReadMax#1433L, persistencyBytesReadMedian#1434L, persistencyRecordsReadTotal#1435L, persistencyRecordsReadMin#1436L, persistencyRecordsReadMax#1437L, persistencyRecordsReadMedian#1438L, persistencyBytesWrittenTotal#1439L, persistencyBytesWrittenMin#1440L, persistencyBytesWrittenMax#1441L, persistencyBytesWrittenMedian#1442L, persistencyRecordsWrittenTotal#1443L, persistencyRecordsWrittenMin#1444L, persistencyRecordsWrittenMax#1445L, persistencyRecordsWrittenMedian#1446L, shuffleConsumeRecordsReadTotal#1447L, shuffleConsumeRemoteBlocksFetchedTotal#1448L, shuffleConsumeLocalBlocksFetchedTotal#1449L, shuffleConsumeTotalBlocksFetchedTotal#1450L, shuffleConsumeRemoteBytesReadTotal#1451L, shuffleConsumeLocalBytesReadTotal#1452L, shuffleConsumeTotalBytesReadTotal#1453L, shuffleConsumeRemoteBytesReadToDiskTotal#1454L, shuffleConsumeFetchWaitTimeTotal#1455L, shuffleProduceBytesWrittenTotal#1456L, shuffleProduceRecordsWrittenTotal#1457L, shuffleProduceWriteTimeTotal#1458L, peakExecutionMemory#1460L, peakExecutionMemoryCliqueDuration#1461L, peakExecutionMemoryCliqueSize#1462L, jobId#1463, rddStorageDiskSizeTotal#1464L, rddStorageMemSizeTotal#1465L, rddNumCachedPartitionsTotal#1466, rddNumPartitionsTotal#1467, numberOfExecutors#1468]
(24) Sort [codegen id : 6]
Input [92]: [jobId#1470, stageCount#1387L, totalTaskCount#1388L, minTaskCountPerStage#1389L, maxTaskCountPerStage#1390L, medianTaskCountPerStage#1391L, bytesSpilledToDiskSerializedTotal#1392L, bytesSpilledToDiskSerializedMin#1393L, bytesSpilledToDiskSerializedMax#1394L, bytesSpilledToDiskSerializedMedian#1395L, taskCpuTimeTotal#1396L, taskCpuTimeMin#1397L, taskCpuTimeMax#1398L, taskCpuTimeMedian#1399L, taskDeserializeCpuTimeTotal#1400L, taskDeserializeCpuTimeMin#1401L, taskDeserializeCpuTimeMax#1402L, taskDeserializeCpuTimeMedian#1403L, taskDeserializeTimeTotal#1404L, taskDeserializeTimeMin#1405L, taskDeserializeTimeMax#1406L, taskDeserializeTimeMedian#1407L, taskRunTimeTotal#1408L, taskRunTimeMin#1409L, taskRunTimeMax#1410L, taskRunTimeMedian#1411L, jvmGcTimeTotal#1412L, jvmGcTimeMin#1413L, jvmGcTimeMax#1414L, jvmGcTimeMedian#1415L, bytesSpilledToDiskRawTotal#1416L, bytesSpilledToDiskRawMin#1417L, bytesSpilledToDiskRawMax#1418L, bytesSpilledToDiskRawMedian#1419L, resultSerializationTimeTotal#1420L, resultSerializationTimeMin#1421L, resultSerializationTimeMax#1422L, resultSerializationTimeMedian#1423L, resultSizeToDriverTotal#1424L, resultSizeToDriverMin#1425L, resultSizeToDriverMax#1426L, resultSizeToDriverMedian#1427L, taskPeakExecutionMemoryMin#1428L, taskPeakExecutionMemoryMax#1429L, taskPeakExecutionMemoryMedian#1430L, persistencyBytesReadTotal#1431L, persistencyBytesReadMin#1432L, persistencyBytesReadMax#1433L, persistencyBytesReadMedian#1434L, persistencyRecordsReadTotal#1435L, persistencyRecordsReadMin#1436L, persistencyRecordsReadMax#1437L, persistencyRecordsReadMedian#1438L, persistencyBytesWrittenTotal#1439L, persistencyBytesWrittenMin#1440L, persistencyBytesWrittenMax#1441L, persistencyBytesWrittenMedian#1442L, persistencyRecordsWrittenTotal#1443L, persistencyRecordsWrittenMin#1444L, persistencyRecordsWrittenMax#1445L, persistencyRecordsWrittenMedian#1446L, shuffleConsumeRecordsReadTotal#1447L, shuffleConsumeRemoteBlocksFetchedTotal#1448L, shuffleConsumeLocalBlocksFetchedTotal#1449L, shuffleConsumeTotalBlocksFetchedTotal#1450L, shuffleConsumeRemoteBytesReadTotal#1451L, shuffleConsumeLocalBytesReadTotal#1452L, shuffleConsumeTotalBytesReadTotal#1453L, shuffleConsumeRemoteBytesReadToDiskTotal#1454L, shuffleConsumeFetchWaitTimeTotal#1455L, shuffleProduceBytesWrittenTotal#1456L, shuffleProduceRecordsWrittenTotal#1457L, shuffleProduceWriteTimeTotal#1458L, peakExecutionMemory#1460L, peakExecutionMemoryCliqueDuration#1461L, peakExecutionMemoryCliqueSize#1462L, rddStorageDiskSizeTotal#1464L, rddStorageMemSizeTotal#1465L, rddNumCachedPartitionsTotal#1466, rddNumPartitionsTotal#1467, numberOfExecutors#1468, replenishmentRunId#1471L, tenantId#1472, cornerstoneTenantId#1473L, marketUnit#1474, scenario#1475, activityId#1476, activityType#1477, workflowType#1478, workflowId#1479, activityAttempt#1480, gitCommitId#1482]
Arguments: [activityType#1477 ASC NULLS FIRST], false, 0
(25) WriteFiles
Input [92]: [jobId#1470, stageCount#1387L, totalTaskCount#1388L, minTaskCountPerStage#1389L, maxTaskCountPerStage#1390L, medianTaskCountPerStage#1391L, bytesSpilledToDiskSerializedTotal#1392L, bytesSpilledToDiskSerializedMin#1393L, bytesSpilledToDiskSerializedMax#1394L, bytesSpilledToDiskSerializedMedian#1395L, taskCpuTimeTotal#1396L, taskCpuTimeMin#1397L, taskCpuTimeMax#1398L, taskCpuTimeMedian#1399L, taskDeserializeCpuTimeTotal#1400L, taskDeserializeCpuTimeMin#1401L, taskDeserializeCpuTimeMax#1402L, taskDeserializeCpuTimeMedian#1403L, taskDeserializeTimeTotal#1404L, taskDeserializeTimeMin#1405L, taskDeserializeTimeMax#1406L, taskDeserializeTimeMedian#1407L, taskRunTimeTotal#1408L, taskRunTimeMin#1409L, taskRunTimeMax#1410L, taskRunTimeMedian#1411L, jvmGcTimeTotal#1412L, jvmGcTimeMin#1413L, jvmGcTimeMax#1414L, jvmGcTimeMedian#1415L, bytesSpilledToDiskRawTotal#1416L, bytesSpilledToDiskRawMin#1417L, bytesSpilledToDiskRawMax#1418L, bytesSpilledToDiskRawMedian#1419L, resultSerializationTimeTotal#1420L, resultSerializationTimeMin#1421L, resultSerializationTimeMax#1422L, resultSerializationTimeMedian#1423L, resultSizeToDriverTotal#1424L, resultSizeToDriverMin#1425L, resultSizeToDriverMax#1426L, resultSizeToDriverMedian#1427L, taskPeakExecutionMemoryMin#1428L, taskPeakExecutionMemoryMax#1429L, taskPeakExecutionMemoryMedian#1430L, persistencyBytesReadTotal#1431L, persistencyBytesReadMin#1432L, persistencyBytesReadMax#1433L, persistencyBytesReadMedian#1434L, persistencyRecordsReadTotal#1435L, persistencyRecordsReadMin#1436L, persistencyRecordsReadMax#1437L, persistencyRecordsReadMedian#1438L, persistencyBytesWrittenTotal#1439L, persistencyBytesWrittenMin#1440L, persistencyBytesWrittenMax#1441L, persistencyBytesWrittenMedian#1442L, persistencyRecordsWrittenTotal#1443L, persistencyRecordsWrittenMin#1444L, persistencyRecordsWrittenMax#1445L, persistencyRecordsWrittenMedian#1446L, shuffleConsumeRecordsReadTotal#1447L, shuffleConsumeRemoteBlocksFetchedTotal#1448L, shuffleConsumeLocalBlocksFetchedTotal#1449L, shuffleConsumeTotalBlocksFetchedTotal#1450L, shuffleConsumeRemoteBytesReadTotal#1451L, shuffleConsumeLocalBytesReadTotal#1452L, shuffleConsumeTotalBytesReadTotal#1453L, shuffleConsumeRemoteBytesReadToDiskTotal#1454L, shuffleConsumeFetchWaitTimeTotal#1455L, shuffleProduceBytesWrittenTotal#1456L, shuffleProduceRecordsWrittenTotal#1457L, shuffleProduceWriteTimeTotal#1458L, peakExecutionMemory#1460L, peakExecutionMemoryCliqueDuration#1461L, peakExecutionMemoryCliqueSize#1462L, rddStorageDiskSizeTotal#1464L, rddStorageMemSizeTotal#1465L, rddNumCachedPartitionsTotal#1466, rddNumPartitionsTotal#1467, numberOfExecutors#1468, replenishmentRunId#1471L, tenantId#1472, cornerstoneTenantId#1473L, marketUnit#1474, scenario#1475, activityId#1476, activityType#1477, workflowType#1478, workflowId#1479, activityAttempt#1480, gitCommitId#1482]
(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/10000000120, false, [activityType#1477], 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/10000000120], 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#1386, stageCount#1387L, totalTaskCount#1388L, minTaskCountPerStage#1389L, maxTaskCountPerStage#1390L, medianTaskCountPerStage#1391L, bytesSpilledToDiskSerializedTotal#1392L, bytesSpilledToDiskSerializedMin#1393L, bytesSpilledToDiskSerializedMax#1394L, bytesSpilledToDiskSerializedMedian#1395L, taskCpuTimeTotal#1396L, taskCpuTimeMin#1397L, taskCpuTimeMax#1398L, taskCpuTimeMedian#1399L, taskDeserializeCpuTimeTotal#1400L, taskDeserializeCpuTimeMin#1401L, taskDeserializeCpuTimeMax#1402L, taskDeserializeCpuTimeMedian#1403L, taskDeserializeTimeTotal#1404L, taskDeserializeTimeMin#1405L, taskDeserializeTimeMax#1406L, taskDeserializeTimeMedian#1407L, taskRunTimeTotal#1408L, taskRunTimeMin#1409L, taskRunTimeMax#1410L, taskRunTimeMedian#1411L, jvmGcTimeTotal#1412L, jvmGcTimeMin#1413L, jvmGcTimeMax#1414L, jvmGcTimeMedian#1415L, bytesSpilledToDiskRawTotal#1416L, bytesSpilledToDiskRawMin#1417L, bytesSpilledToDiskRawMax#1418L, bytesSpilledToDiskRawMedian#1419L, resultSerializationTimeTotal#1420L, resultSerializationTimeMin#1421L, resultSerializationTimeMax#1422L, resultSerializationTimeMedian#1423L, resultSizeToDriverTotal#1424L, resultSizeToDriverMin#1425L, resultSizeToDriverMax#1426L, resultSizeToDriverMedian#1427L, taskPeakExecutionMemoryMin#1428L, taskPeakExecutionMemoryMax#1429L, taskPeakExecutionMemoryMedian#1430L, persistencyBytesReadTotal#1431L, persistencyBytesReadMin#1432L, persistencyBytesReadMax#1433L, persistencyBytesReadMedian#1434L, persistencyRecordsReadTotal#1435L, persistencyRecordsReadMin#1436L, persistencyRecordsReadMax#1437L, persistencyRecordsReadMedian#1438L, persistencyBytesWrittenTotal#1439L, persistencyBytesWrittenMin#1440L, persistencyBytesWrittenMax#1441L, persistencyBytesWrittenMedian#1442L, persistencyRecordsWrittenTotal#1443L, persistencyRecordsWrittenMin#1444L, persistencyRecordsWrittenMax#1445L, persistencyRecordsWrittenMedian#1446L, shuffleConsumeRecordsReadTotal#1447L, shuffleConsumeRemoteBlocksFetchedTotal#1448L, shuffleConsumeLocalBlocksFetchedTotal#1449L, shuffleConsumeTotalBlocksFetchedTotal#1450L, shuffleConsumeRemoteBytesReadTotal#1451L, shuffleConsumeLocalBytesReadTotal#1452L, shuffleConsumeTotalBytesReadTotal#1453L, shuffleConsumeRemoteBytesReadToDiskTotal#1454L, shuffleConsumeFetchWaitTimeTotal#1455L, shuffleProduceBytesWrittenTotal#1456L, shuffleProduceRecordsWrittenTotal#1457L, shuffleProduceWriteTimeTotal#1458L]
Arguments: [jobId#1386 ASC NULLS FIRST], false, 0
(29) Sort
Input [4]: [jobId#1459, peakExecutionMemory#1460L, peakExecutionMemoryCliqueDuration#1461L, peakExecutionMemoryCliqueSize#1462L]
Arguments: [jobId#1459 ASC NULLS FIRST], false, 0
(30) SortMergeJoin
Left keys [1]: [jobId#1386]
Right keys [1]: [jobId#1459]
Join type: FullOuter
Join condition: None
(31) Project
Output [76]: [coalesce(jobId#1386, jobId#1459) AS jobId#1469, stageCount#1387L, totalTaskCount#1388L, minTaskCountPerStage#1389L, maxTaskCountPerStage#1390L, medianTaskCountPerStage#1391L, bytesSpilledToDiskSerializedTotal#1392L, bytesSpilledToDiskSerializedMin#1393L, bytesSpilledToDiskSerializedMax#1394L, bytesSpilledToDiskSerializedMedian#1395L, taskCpuTimeTotal#1396L, taskCpuTimeMin#1397L, taskCpuTimeMax#1398L, taskCpuTimeMedian#1399L, taskDeserializeCpuTimeTotal#1400L, taskDeserializeCpuTimeMin#1401L, taskDeserializeCpuTimeMax#1402L, taskDeserializeCpuTimeMedian#1403L, taskDeserializeTimeTotal#1404L, taskDeserializeTimeMin#1405L, taskDeserializeTimeMax#1406L, taskDeserializeTimeMedian#1407L, taskRunTimeTotal#1408L, taskRunTimeMin#1409L, taskRunTimeMax#1410L, taskRunTimeMedian#1411L, jvmGcTimeTotal#1412L, jvmGcTimeMin#1413L, jvmGcTimeMax#1414L, jvmGcTimeMedian#1415L, bytesSpilledToDiskRawTotal#1416L, bytesSpilledToDiskRawMin#1417L, bytesSpilledToDiskRawMax#1418L, bytesSpilledToDiskRawMedian#1419L, resultSerializationTimeTotal#1420L, resultSerializationTimeMin#1421L, resultSerializationTimeMax#1422L, resultSerializationTimeMedian#1423L, resultSizeToDriverTotal#1424L, resultSizeToDriverMin#1425L, resultSizeToDriverMax#1426L, resultSizeToDriverMedian#1427L, taskPeakExecutionMemoryMin#1428L, taskPeakExecutionMemoryMax#1429L, taskPeakExecutionMemoryMedian#1430L, persistencyBytesReadTotal#1431L, persistencyBytesReadMin#1432L, persistencyBytesReadMax#1433L, persistencyBytesReadMedian#1434L, persistencyRecordsReadTotal#1435L, persistencyRecordsReadMin#1436L, persistencyRecordsReadMax#1437L, persistencyRecordsReadMedian#1438L, persistencyBytesWrittenTotal#1439L, persistencyBytesWrittenMin#1440L, persistencyBytesWrittenMax#1441L, persistencyBytesWrittenMedian#1442L, persistencyRecordsWrittenTotal#1443L, persistencyRecordsWrittenMin#1444L, persistencyRecordsWrittenMax#1445L, persistencyRecordsWrittenMedian#1446L, shuffleConsumeRecordsReadTotal#1447L, shuffleConsumeRemoteBlocksFetchedTotal#1448L, shuffleConsumeLocalBlocksFetchedTotal#1449L, shuffleConsumeTotalBlocksFetchedTotal#1450L, shuffleConsumeRemoteBytesReadTotal#1451L, shuffleConsumeLocalBytesReadTotal#1452L, shuffleConsumeTotalBytesReadTotal#1453L, shuffleConsumeRemoteBytesReadToDiskTotal#1454L, shuffleConsumeFetchWaitTimeTotal#1455L, shuffleProduceBytesWrittenTotal#1456L, shuffleProduceRecordsWrittenTotal#1457L, shuffleProduceWriteTimeTotal#1458L, peakExecutionMemory#1460L, peakExecutionMemoryCliqueDuration#1461L, peakExecutionMemoryCliqueSize#1462L]
Input [77]: [jobId#1386, stageCount#1387L, totalTaskCount#1388L, minTaskCountPerStage#1389L, maxTaskCountPerStage#1390L, medianTaskCountPerStage#1391L, bytesSpilledToDiskSerializedTotal#1392L, bytesSpilledToDiskSerializedMin#1393L, bytesSpilledToDiskSerializedMax#1394L, bytesSpilledToDiskSerializedMedian#1395L, taskCpuTimeTotal#1396L, taskCpuTimeMin#1397L, taskCpuTimeMax#1398L, taskCpuTimeMedian#1399L, taskDeserializeCpuTimeTotal#1400L, taskDeserializeCpuTimeMin#1401L, taskDeserializeCpuTimeMax#1402L, taskDeserializeCpuTimeMedian#1403L, taskDeserializeTimeTotal#1404L, taskDeserializeTimeMin#1405L, taskDeserializeTimeMax#1406L, taskDeserializeTimeMedian#1407L, taskRunTimeTotal#1408L, taskRunTimeMin#1409L, taskRunTimeMax#1410L, taskRunTimeMedian#1411L, jvmGcTimeTotal#1412L, jvmGcTimeMin#1413L, jvmGcTimeMax#1414L, jvmGcTimeMedian#1415L, bytesSpilledToDiskRawTotal#1416L, bytesSpilledToDiskRawMin#1417L, bytesSpilledToDiskRawMax#1418L, bytesSpilledToDiskRawMedian#1419L, resultSerializationTimeTotal#1420L, resultSerializationTimeMin#1421L, resultSerializationTimeMax#1422L, resultSerializationTimeMedian#1423L, resultSizeToDriverTotal#1424L, resultSizeToDriverMin#1425L, resultSizeToDriverMax#1426L, resultSizeToDriverMedian#1427L, taskPeakExecutionMemoryMin#1428L, taskPeakExecutionMemoryMax#1429L, taskPeakExecutionMemoryMedian#1430L, persistencyBytesReadTotal#1431L, persistencyBytesReadMin#1432L, persistencyBytesReadMax#1433L, persistencyBytesReadMedian#1434L, persistencyRecordsReadTotal#1435L, persistencyRecordsReadMin#1436L, persistencyRecordsReadMax#1437L, persistencyRecordsReadMedian#1438L, persistencyBytesWrittenTotal#1439L, persistencyBytesWrittenMin#1440L, persistencyBytesWrittenMax#1441L, persistencyBytesWrittenMedian#1442L, persistencyRecordsWrittenTotal#1443L, persistencyRecordsWrittenMin#1444L, persistencyRecordsWrittenMax#1445L, persistencyRecordsWrittenMedian#1446L, shuffleConsumeRecordsReadTotal#1447L, shuffleConsumeRemoteBlocksFetchedTotal#1448L, shuffleConsumeLocalBlocksFetchedTotal#1449L, shuffleConsumeTotalBlocksFetchedTotal#1450L, shuffleConsumeRemoteBytesReadTotal#1451L, shuffleConsumeLocalBytesReadTotal#1452L, shuffleConsumeTotalBytesReadTotal#1453L, shuffleConsumeRemoteBytesReadToDiskTotal#1454L, shuffleConsumeFetchWaitTimeTotal#1455L, shuffleProduceBytesWrittenTotal#1456L, shuffleProduceRecordsWrittenTotal#1457L, shuffleProduceWriteTimeTotal#1458L, jobId#1459, peakExecutionMemory#1460L, peakExecutionMemoryCliqueDuration#1461L, peakExecutionMemoryCliqueSize#1462L]
(32) Exchange
Input [76]: [jobId#1469, stageCount#1387L, totalTaskCount#1388L, minTaskCountPerStage#1389L, maxTaskCountPerStage#1390L, medianTaskCountPerStage#1391L, bytesSpilledToDiskSerializedTotal#1392L, bytesSpilledToDiskSerializedMin#1393L, bytesSpilledToDiskSerializedMax#1394L, bytesSpilledToDiskSerializedMedian#1395L, taskCpuTimeTotal#1396L, taskCpuTimeMin#1397L, taskCpuTimeMax#1398L, taskCpuTimeMedian#1399L, taskDeserializeCpuTimeTotal#1400L, taskDeserializeCpuTimeMin#1401L, taskDeserializeCpuTimeMax#1402L, taskDeserializeCpuTimeMedian#1403L, taskDeserializeTimeTotal#1404L, taskDeserializeTimeMin#1405L, taskDeserializeTimeMax#1406L, taskDeserializeTimeMedian#1407L, taskRunTimeTotal#1408L, taskRunTimeMin#1409L, taskRunTimeMax#1410L, taskRunTimeMedian#1411L, jvmGcTimeTotal#1412L, jvmGcTimeMin#1413L, jvmGcTimeMax#1414L, jvmGcTimeMedian#1415L, bytesSpilledToDiskRawTotal#1416L, bytesSpilledToDiskRawMin#1417L, bytesSpilledToDiskRawMax#1418L, bytesSpilledToDiskRawMedian#1419L, resultSerializationTimeTotal#1420L, resultSerializationTimeMin#1421L, resultSerializationTimeMax#1422L, resultSerializationTimeMedian#1423L, resultSizeToDriverTotal#1424L, resultSizeToDriverMin#1425L, resultSizeToDriverMax#1426L, resultSizeToDriverMedian#1427L, taskPeakExecutionMemoryMin#1428L, taskPeakExecutionMemoryMax#1429L, taskPeakExecutionMemoryMedian#1430L, persistencyBytesReadTotal#1431L, persistencyBytesReadMin#1432L, persistencyBytesReadMax#1433L, persistencyBytesReadMedian#1434L, persistencyRecordsReadTotal#1435L, persistencyRecordsReadMin#1436L, persistencyRecordsReadMax#1437L, persistencyRecordsReadMedian#1438L, persistencyBytesWrittenTotal#1439L, persistencyBytesWrittenMin#1440L, persistencyBytesWrittenMax#1441L, persistencyBytesWrittenMedian#1442L, persistencyRecordsWrittenTotal#1443L, persistencyRecordsWrittenMin#1444L, persistencyRecordsWrittenMax#1445L, persistencyRecordsWrittenMedian#1446L, shuffleConsumeRecordsReadTotal#1447L, shuffleConsumeRemoteBlocksFetchedTotal#1448L, shuffleConsumeLocalBlocksFetchedTotal#1449L, shuffleConsumeTotalBlocksFetchedTotal#1450L, shuffleConsumeRemoteBytesReadTotal#1451L, shuffleConsumeLocalBytesReadTotal#1452L, shuffleConsumeTotalBytesReadTotal#1453L, shuffleConsumeRemoteBytesReadToDiskTotal#1454L, shuffleConsumeFetchWaitTimeTotal#1455L, shuffleProduceBytesWrittenTotal#1456L, shuffleProduceRecordsWrittenTotal#1457L, shuffleProduceWriteTimeTotal#1458L, peakExecutionMemory#1460L, peakExecutionMemoryCliqueDuration#1461L, peakExecutionMemoryCliqueSize#1462L]
Arguments: hashpartitioning(jobId#1469, 25), ENSURE_REQUIREMENTS, [plan_id=906]
(33) Sort
Input [76]: [jobId#1469, stageCount#1387L, totalTaskCount#1388L, minTaskCountPerStage#1389L, maxTaskCountPerStage#1390L, medianTaskCountPerStage#1391L, bytesSpilledToDiskSerializedTotal#1392L, bytesSpilledToDiskSerializedMin#1393L, bytesSpilledToDiskSerializedMax#1394L, bytesSpilledToDiskSerializedMedian#1395L, taskCpuTimeTotal#1396L, taskCpuTimeMin#1397L, taskCpuTimeMax#1398L, taskCpuTimeMedian#1399L, taskDeserializeCpuTimeTotal#1400L, taskDeserializeCpuTimeMin#1401L, taskDeserializeCpuTimeMax#1402L, taskDeserializeCpuTimeMedian#1403L, taskDeserializeTimeTotal#1404L, taskDeserializeTimeMin#1405L, taskDeserializeTimeMax#1406L, taskDeserializeTimeMedian#1407L, taskRunTimeTotal#1408L, taskRunTimeMin#1409L, taskRunTimeMax#1410L, taskRunTimeMedian#1411L, jvmGcTimeTotal#1412L, jvmGcTimeMin#1413L, jvmGcTimeMax#1414L, jvmGcTimeMedian#1415L, bytesSpilledToDiskRawTotal#1416L, bytesSpilledToDiskRawMin#1417L, bytesSpilledToDiskRawMax#1418L, bytesSpilledToDiskRawMedian#1419L, resultSerializationTimeTotal#1420L, resultSerializationTimeMin#1421L, resultSerializationTimeMax#1422L, resultSerializationTimeMedian#1423L, resultSizeToDriverTotal#1424L, resultSizeToDriverMin#1425L, resultSizeToDriverMax#1426L, resultSizeToDriverMedian#1427L, taskPeakExecutionMemoryMin#1428L, taskPeakExecutionMemoryMax#1429L, taskPeakExecutionMemoryMedian#1430L, persistencyBytesReadTotal#1431L, persistencyBytesReadMin#1432L, persistencyBytesReadMax#1433L, persistencyBytesReadMedian#1434L, persistencyRecordsReadTotal#1435L, persistencyRecordsReadMin#1436L, persistencyRecordsReadMax#1437L, persistencyRecordsReadMedian#1438L, persistencyBytesWrittenTotal#1439L, persistencyBytesWrittenMin#1440L, persistencyBytesWrittenMax#1441L, persistencyBytesWrittenMedian#1442L, persistencyRecordsWrittenTotal#1443L, persistencyRecordsWrittenMin#1444L, persistencyRecordsWrittenMax#1445L, persistencyRecordsWrittenMedian#1446L, shuffleConsumeRecordsReadTotal#1447L, shuffleConsumeRemoteBlocksFetchedTotal#1448L, shuffleConsumeLocalBlocksFetchedTotal#1449L, shuffleConsumeTotalBlocksFetchedTotal#1450L, shuffleConsumeRemoteBytesReadTotal#1451L, shuffleConsumeLocalBytesReadTotal#1452L, shuffleConsumeTotalBytesReadTotal#1453L, shuffleConsumeRemoteBytesReadToDiskTotal#1454L, shuffleConsumeFetchWaitTimeTotal#1455L, shuffleProduceBytesWrittenTotal#1456L, shuffleProduceRecordsWrittenTotal#1457L, shuffleProduceWriteTimeTotal#1458L, peakExecutionMemory#1460L, peakExecutionMemoryCliqueDuration#1461L, peakExecutionMemoryCliqueSize#1462L]
Arguments: [jobId#1469 ASC NULLS FIRST], false, 0
(34) Sort
Input [6]: [jobId#1463, rddStorageDiskSizeTotal#1464L, rddStorageMemSizeTotal#1465L, rddNumCachedPartitionsTotal#1466, rddNumPartitionsTotal#1467, numberOfExecutors#1468]
Arguments: [jobId#1463 ASC NULLS FIRST], false, 0
(35) SortMergeJoin
Left keys [1]: [jobId#1469]
Right keys [1]: [jobId#1463]
Join type: FullOuter
Join condition: None
(36) Project
Output [92]: [coalesce(jobId#1469, jobId#1463) AS jobId#1470, stageCount#1387L, totalTaskCount#1388L, minTaskCountPerStage#1389L, maxTaskCountPerStage#1390L, medianTaskCountPerStage#1391L, bytesSpilledToDiskSerializedTotal#1392L, bytesSpilledToDiskSerializedMin#1393L, bytesSpilledToDiskSerializedMax#1394L, bytesSpilledToDiskSerializedMedian#1395L, taskCpuTimeTotal#1396L, taskCpuTimeMin#1397L, taskCpuTimeMax#1398L, taskCpuTimeMedian#1399L, taskDeserializeCpuTimeTotal#1400L, taskDeserializeCpuTimeMin#1401L, taskDeserializeCpuTimeMax#1402L, taskDeserializeCpuTimeMedian#1403L, taskDeserializeTimeTotal#1404L, taskDeserializeTimeMin#1405L, taskDeserializeTimeMax#1406L, taskDeserializeTimeMedian#1407L, taskRunTimeTotal#1408L, taskRunTimeMin#1409L, taskRunTimeMax#1410L, taskRunTimeMedian#1411L, jvmGcTimeTotal#1412L, jvmGcTimeMin#1413L, jvmGcTimeMax#1414L, jvmGcTimeMedian#1415L, bytesSpilledToDiskRawTotal#1416L, bytesSpilledToDiskRawMin#1417L, bytesSpilledToDiskRawMax#1418L, bytesSpilledToDiskRawMedian#1419L, resultSerializationTimeTotal#1420L, resultSerializationTimeMin#1421L, resultSerializationTimeMax#1422L, resultSerializationTimeMedian#1423L, resultSizeToDriverTotal#1424L, resultSizeToDriverMin#1425L, resultSizeToDriverMax#1426L, resultSizeToDriverMedian#1427L, taskPeakExecutionMemoryMin#1428L, taskPeakExecutionMemoryMax#1429L, taskPeakExecutionMemoryMedian#1430L, persistencyBytesReadTotal#1431L, persistencyBytesReadMin#1432L, persistencyBytesReadMax#1433L, persistencyBytesReadMedian#1434L, persistencyRecordsReadTotal#1435L, persistencyRecordsReadMin#1436L, persistencyRecordsReadMax#1437L, persistencyRecordsReadMedian#1438L, persistencyBytesWrittenTotal#1439L, persistencyBytesWrittenMin#1440L, persistencyBytesWrittenMax#1441L, persistencyBytesWrittenMedian#1442L, persistencyRecordsWrittenTotal#1443L, persistencyRecordsWrittenMin#1444L, persistencyRecordsWrittenMax#1445L, persistencyRecordsWrittenMedian#1446L, shuffleConsumeRecordsReadTotal#1447L, shuffleConsumeRemoteBlocksFetchedTotal#1448L, shuffleConsumeLocalBlocksFetchedTotal#1449L, shuffleConsumeTotalBlocksFetchedTotal#1450L, shuffleConsumeRemoteBytesReadTotal#1451L, shuffleConsumeLocalBytesReadTotal#1452L, shuffleConsumeTotalBytesReadTotal#1453L, shuffleConsumeRemoteBytesReadToDiskTotal#1454L, shuffleConsumeFetchWaitTimeTotal#1455L, shuffleProduceBytesWrittenTotal#1456L, shuffleProduceRecordsWrittenTotal#1457L, shuffleProduceWriteTimeTotal#1458L, peakExecutionMemory#1460L, peakExecutionMemoryCliqueDuration#1461L, peakExecutionMemoryCliqueSize#1462L, rddStorageDiskSizeTotal#1464L, rddStorageMemSizeTotal#1465L, rddNumCachedPartitionsTotal#1466, rddNumPartitionsTotal#1467, numberOfExecutors#1468, 10000000120 AS replenishmentRunId#1471L, 6944346648028224943 AS tenantId#1472, 8378 AS cornerstoneTenantId#1473L, Daily_grocery AS marketUnit#1474, STANDARD AS scenario#1475, 0221f660-f20c-3ec8-a242-7de8ba8fb864 AS activityId#1476, PrepareStreams AS activityType#1477, CalculateOrderProposalsWorkflow AS workflowType#1478, 7421d6c7-702b-33bf-84ff-d21f3533b79c AS workflowId#1479, 1 AS activityAttempt#1480, AS gitCommitId#1482]
Input [82]: [jobId#1469, stageCount#1387L, totalTaskCount#1388L, minTaskCountPerStage#1389L, maxTaskCountPerStage#1390L, medianTaskCountPerStage#1391L, bytesSpilledToDiskSerializedTotal#1392L, bytesSpilledToDiskSerializedMin#1393L, bytesSpilledToDiskSerializedMax#1394L, bytesSpilledToDiskSerializedMedian#1395L, taskCpuTimeTotal#1396L, taskCpuTimeMin#1397L, taskCpuTimeMax#1398L, taskCpuTimeMedian#1399L, taskDeserializeCpuTimeTotal#1400L, taskDeserializeCpuTimeMin#1401L, taskDeserializeCpuTimeMax#1402L, taskDeserializeCpuTimeMedian#1403L, taskDeserializeTimeTotal#1404L, taskDeserializeTimeMin#1405L, taskDeserializeTimeMax#1406L, taskDeserializeTimeMedian#1407L, taskRunTimeTotal#1408L, taskRunTimeMin#1409L, taskRunTimeMax#1410L, taskRunTimeMedian#1411L, jvmGcTimeTotal#1412L, jvmGcTimeMin#1413L, jvmGcTimeMax#1414L, jvmGcTimeMedian#1415L, bytesSpilledToDiskRawTotal#1416L, bytesSpilledToDiskRawMin#1417L, bytesSpilledToDiskRawMax#1418L, bytesSpilledToDiskRawMedian#1419L, resultSerializationTimeTotal#1420L, resultSerializationTimeMin#1421L, resultSerializationTimeMax#1422L, resultSerializationTimeMedian#1423L, resultSizeToDriverTotal#1424L, resultSizeToDriverMin#1425L, resultSizeToDriverMax#1426L, resultSizeToDriverMedian#1427L, taskPeakExecutionMemoryMin#1428L, taskPeakExecutionMemoryMax#1429L, taskPeakExecutionMemoryMedian#1430L, persistencyBytesReadTotal#1431L, persistencyBytesReadMin#1432L, persistencyBytesReadMax#1433L, persistencyBytesReadMedian#1434L, persistencyRecordsReadTotal#1435L, persistencyRecordsReadMin#1436L, persistencyRecordsReadMax#1437L, persistencyRecordsReadMedian#1438L, persistencyBytesWrittenTotal#1439L, persistencyBytesWrittenMin#1440L, persistencyBytesWrittenMax#1441L, persistencyBytesWrittenMedian#1442L, persistencyRecordsWrittenTotal#1443L, persistencyRecordsWrittenMin#1444L, persistencyRecordsWrittenMax#1445L, persistencyRecordsWrittenMedian#1446L, shuffleConsumeRecordsReadTotal#1447L, shuffleConsumeRemoteBlocksFetchedTotal#1448L, shuffleConsumeLocalBlocksFetchedTotal#1449L, shuffleConsumeTotalBlocksFetchedTotal#1450L, shuffleConsumeRemoteBytesReadTotal#1451L, shuffleConsumeLocalBytesReadTotal#1452L, shuffleConsumeTotalBytesReadTotal#1453L, shuffleConsumeRemoteBytesReadToDiskTotal#1454L, shuffleConsumeFetchWaitTimeTotal#1455L, shuffleProduceBytesWrittenTotal#1456L, shuffleProduceRecordsWrittenTotal#1457L, shuffleProduceWriteTimeTotal#1458L, peakExecutionMemory#1460L, peakExecutionMemoryCliqueDuration#1461L, peakExecutionMemoryCliqueSize#1462L, jobId#1463, rddStorageDiskSizeTotal#1464L, rddStorageMemSizeTotal#1465L, rddNumCachedPartitionsTotal#1466, rddNumPartitionsTotal#1467, numberOfExecutors#1468]
(37) Sort
Input [92]: [jobId#1470, stageCount#1387L, totalTaskCount#1388L, minTaskCountPerStage#1389L, maxTaskCountPerStage#1390L, medianTaskCountPerStage#1391L, bytesSpilledToDiskSerializedTotal#1392L, bytesSpilledToDiskSerializedMin#1393L, bytesSpilledToDiskSerializedMax#1394L, bytesSpilledToDiskSerializedMedian#1395L, taskCpuTimeTotal#1396L, taskCpuTimeMin#1397L, taskCpuTimeMax#1398L, taskCpuTimeMedian#1399L, taskDeserializeCpuTimeTotal#1400L, taskDeserializeCpuTimeMin#1401L, taskDeserializeCpuTimeMax#1402L, taskDeserializeCpuTimeMedian#1403L, taskDeserializeTimeTotal#1404L, taskDeserializeTimeMin#1405L, taskDeserializeTimeMax#1406L, taskDeserializeTimeMedian#1407L, taskRunTimeTotal#1408L, taskRunTimeMin#1409L, taskRunTimeMax#1410L, taskRunTimeMedian#1411L, jvmGcTimeTotal#1412L, jvmGcTimeMin#1413L, jvmGcTimeMax#1414L, jvmGcTimeMedian#1415L, bytesSpilledToDiskRawTotal#1416L, bytesSpilledToDiskRawMin#1417L, bytesSpilledToDiskRawMax#1418L, bytesSpilledToDiskRawMedian#1419L, resultSerializationTimeTotal#1420L, resultSerializationTimeMin#1421L, resultSerializationTimeMax#1422L, resultSerializationTimeMedian#1423L, resultSizeToDriverTotal#1424L, resultSizeToDriverMin#1425L, resultSizeToDriverMax#1426L, resultSizeToDriverMedian#1427L, taskPeakExecutionMemoryMin#1428L, taskPeakExecutionMemoryMax#1429L, taskPeakExecutionMemoryMedian#1430L, persistencyBytesReadTotal#1431L, persistencyBytesReadMin#1432L, persistencyBytesReadMax#1433L, persistencyBytesReadMedian#1434L, persistencyRecordsReadTotal#1435L, persistencyRecordsReadMin#1436L, persistencyRecordsReadMax#1437L, persistencyRecordsReadMedian#1438L, persistencyBytesWrittenTotal#1439L, persistencyBytesWrittenMin#1440L, persistencyBytesWrittenMax#1441L, persistencyBytesWrittenMedian#1442L, persistencyRecordsWrittenTotal#1443L, persistencyRecordsWrittenMin#1444L, persistencyRecordsWrittenMax#1445L, persistencyRecordsWrittenMedian#1446L, shuffleConsumeRecordsReadTotal#1447L, shuffleConsumeRemoteBlocksFetchedTotal#1448L, shuffleConsumeLocalBlocksFetchedTotal#1449L, shuffleConsumeTotalBlocksFetchedTotal#1450L, shuffleConsumeRemoteBytesReadTotal#1451L, shuffleConsumeLocalBytesReadTotal#1452L, shuffleConsumeTotalBytesReadTotal#1453L, shuffleConsumeRemoteBytesReadToDiskTotal#1454L, shuffleConsumeFetchWaitTimeTotal#1455L, shuffleProduceBytesWrittenTotal#1456L, shuffleProduceRecordsWrittenTotal#1457L, shuffleProduceWriteTimeTotal#1458L, peakExecutionMemory#1460L, peakExecutionMemoryCliqueDuration#1461L, peakExecutionMemoryCliqueSize#1462L, rddStorageDiskSizeTotal#1464L, rddStorageMemSizeTotal#1465L, rddNumCachedPartitionsTotal#1466, rddNumPartitionsTotal#1467, numberOfExecutors#1468, replenishmentRunId#1471L, tenantId#1472, cornerstoneTenantId#1473L, marketUnit#1474, scenario#1475, activityId#1476, activityType#1477, workflowType#1478, workflowId#1479, activityAttempt#1480, gitCommitId#1482]
Arguments: [activityType#1477 ASC NULLS FIRST], false, 0
(38) WriteFiles
Input [92]: [jobId#1470, stageCount#1387L, totalTaskCount#1388L, minTaskCountPerStage#1389L, maxTaskCountPerStage#1390L, medianTaskCountPerStage#1391L, bytesSpilledToDiskSerializedTotal#1392L, bytesSpilledToDiskSerializedMin#1393L, bytesSpilledToDiskSerializedMax#1394L, bytesSpilledToDiskSerializedMedian#1395L, taskCpuTimeTotal#1396L, taskCpuTimeMin#1397L, taskCpuTimeMax#1398L, taskCpuTimeMedian#1399L, taskDeserializeCpuTimeTotal#1400L, taskDeserializeCpuTimeMin#1401L, taskDeserializeCpuTimeMax#1402L, taskDeserializeCpuTimeMedian#1403L, taskDeserializeTimeTotal#1404L, taskDeserializeTimeMin#1405L, taskDeserializeTimeMax#1406L, taskDeserializeTimeMedian#1407L, taskRunTimeTotal#1408L, taskRunTimeMin#1409L, taskRunTimeMax#1410L, taskRunTimeMedian#1411L, jvmGcTimeTotal#1412L, jvmGcTimeMin#1413L, jvmGcTimeMax#1414L, jvmGcTimeMedian#1415L, bytesSpilledToDiskRawTotal#1416L, bytesSpilledToDiskRawMin#1417L, bytesSpilledToDiskRawMax#1418L, bytesSpilledToDiskRawMedian#1419L, resultSerializationTimeTotal#1420L, resultSerializationTimeMin#1421L, resultSerializationTimeMax#1422L, resultSerializationTimeMedian#1423L, resultSizeToDriverTotal#1424L, resultSizeToDriverMin#1425L, resultSizeToDriverMax#1426L, resultSizeToDriverMedian#1427L, taskPeakExecutionMemoryMin#1428L, taskPeakExecutionMemoryMax#1429L, taskPeakExecutionMemoryMedian#1430L, persistencyBytesReadTotal#1431L, persistencyBytesReadMin#1432L, persistencyBytesReadMax#1433L, persistencyBytesReadMedian#1434L, persistencyRecordsReadTotal#1435L, persistencyRecordsReadMin#1436L, persistencyRecordsReadMax#1437L, persistencyRecordsReadMedian#1438L, persistencyBytesWrittenTotal#1439L, persistencyBytesWrittenMin#1440L, persistencyBytesWrittenMax#1441L, persistencyBytesWrittenMedian#1442L, persistencyRecordsWrittenTotal#1443L, persistencyRecordsWrittenMin#1444L, persistencyRecordsWrittenMax#1445L, persistencyRecordsWrittenMedian#1446L, shuffleConsumeRecordsReadTotal#1447L, shuffleConsumeRemoteBlocksFetchedTotal#1448L, shuffleConsumeLocalBlocksFetchedTotal#1449L, shuffleConsumeTotalBlocksFetchedTotal#1450L, shuffleConsumeRemoteBytesReadTotal#1451L, shuffleConsumeLocalBytesReadTotal#1452L, shuffleConsumeTotalBytesReadTotal#1453L, shuffleConsumeRemoteBytesReadToDiskTotal#1454L, shuffleConsumeFetchWaitTimeTotal#1455L, shuffleProduceBytesWrittenTotal#1456L, shuffleProduceRecordsWrittenTotal#1457L, shuffleProduceWriteTimeTotal#1458L, peakExecutionMemory#1460L, peakExecutionMemoryCliqueDuration#1461L, peakExecutionMemoryCliqueSize#1462L, rddStorageDiskSizeTotal#1464L, rddStorageMemSizeTotal#1465L, rddNumCachedPartitionsTotal#1466, rddNumPartitionsTotal#1467, numberOfExecutors#1468, replenishmentRunId#1471L, tenantId#1472, cornerstoneTenantId#1473L, marketUnit#1474, scenario#1475, activityId#1476, activityType#1477, workflowType#1478, workflowId#1479, activityAttempt#1480, gitCommitId#1482]
(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/10000000120, false, [activityType#1477], 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/10000000120], 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