diff --git a/src/main/scala/AssignTraceIds.scala b/src/main/scala/AssignTraceIds.scala index 7c1625fb..9e4e7ab9 100644 --- a/src/main/scala/AssignTraceIds.scala +++ b/src/main/scala/AssignTraceIds.scala @@ -321,7 +321,7 @@ object AssignTraceIds extends ScoptCliReaders, StrictLogging: SpotChannelColumnName.toNamedEncoder logger.info(s"Writing output file: $outputFile") fs2.Stream - .emits(records.toList) + .emits(records.sortBy(_._1.index).toList) .through(writeCaseClassesToCsv[OutputRecord](outputFile)) .compile .drain