Расследование аварии JVM-приложения на Scala

val lock = new Object
val worker = new Thread(
  () => lock.synchronized(Thread.sleep(5000)),
  "worker"
)
worker.start()
Thread.sleep(20)
println(worker.getName -> worker.getState)

// Дополнительный контекст: После увеличения памяти авария стала происходить реже, но паузы и удержание объектов выросли.
val lock = new Object
val worker = new Thread(
  () => lock.synchronized(Thread.sleep(5000)),
  "worker"
)
worker.start()
Thread.sleep(20)
println(worker.getName -> worker.getState)

val lock = new Object
val worker = new Thread(
  () => lock.synchronized(Thread.sleep(5000)),
  "worker"
)
worker.start()
Thread.sleep(20)
println(worker.getName -> worker.getState)
// На ревью требуется устранить причину дефекта, не скрывая её приведением типа или значением по умолчанию.

import scala.collection.mutable.ArrayBuffer
val cache = ArrayBuffer.empty[Array[Byte]]
for _ <- 1 to 100 do
  cache += Array.ofDim[Byte](1024 * 1024)
val retained = cache.iterator.map(_.length.toLong).sum
println(cache.size -> retained)

// Дополнительный контекст: Процесс перезапустили, и часть доказательств исчезла до начала расследования.
import scala.collection.mutable.ArrayBuffer
val cache = ArrayBuffer.empty[Array[Byte]]
for _ <- 1 to 100 do
  cache += Array.ofDim[Byte](1024 * 1024)
val retained = cache.iterator.map(_.length.toLong).sum
println(cache.size -> retained)

import scala.collection.mutable.ArrayBuffer
val cache = ArrayBuffer.empty[Array[Byte]]
for _ <- 1 to 100 do
  cache += Array.ofDim[Byte](1024 * 1024)
val retained = cache.iterator.map(_.length.toLong).sum
println(cache.size -> retained)
// На ревью требуется устранить причину дефекта, не скрывая её приведением типа или значением по умолчанию.

val batches = Vector.fill(200)(Array.ofDim[Byte](256 * 1024))
val allocated = batches.iterator.map(_.length.toLong).sum
println(s"allocated=$allocated")

// Дополнительный контекст: После увеличения памяти авария стала происходить реже, но паузы и удержание объектов выросли.
val batches = Vector.fill(200)(Array.ofDim[Byte](256 * 1024))
val allocated = batches.iterator.map(_.length.toLong).sum
println(s"allocated=$allocated")

val batches = Vector.fill(200)(Array.ofDim[Byte](256 * 1024))
val allocated = batches.iterator.map(_.length.toLong).sum
println(s"allocated=$allocated")
// На ревью требуется устранить причину дефекта, не скрывая её приведением типа или значением по умолчанию.

case class RecoveryStep(action: String, successMetric: String, rollback: String)

// Дополнительный контекст: После увеличения памяти авария стала происходить реже, но паузы и удержание объектов выросли.
case class RecoveryStep(action: String, successMetric: String, rollback: String)

case class RecoveryStep(action: String, successMetric: String, rollback: String)
// На ревью требуется устранить причину дефекта, не скрывая её приведением типа или значением по умолчанию.

case class FollowUp(owner: String, due: java.time.LocalDate, evidence: String)

// Дополнительный контекст: Сбой воспроизвёлся под нагрузкой, но единичный снимок показал только один симптом.
case class FollowUp(owner: String, due: java.time.LocalDate, evidence: String)

case class FollowUp(owner: String, due: java.time.LocalDate, evidence: String)
// На ревью требуется устранить причину дефекта, не скрывая её приведением типа или значением по умолчанию.

import java.util.UUID
import java.util.concurrent.ArrayBlockingQueue
case class Command(id: UUID, payload: String)
val queue = ArrayBlockingQueue[Command](1024)
val accepted = queue.offer(Command(UUID.randomUUID(), "rebuild"))
println(accepted -> queue.remainingCapacity())

// Дополнительный контекст: После увеличения памяти авария стала происходить реже, но паузы и удержание объектов выросли.
import java.util.UUID
import java.util.concurrent.ArrayBlockingQueue
case class Command(id: UUID, payload: String)
val queue = ArrayBlockingQueue[Command](1024)
val accepted = queue.offer(Command(UUID.randomUUID(), "rebuild"))
println(accepted -> queue.remainingCapacity())

import java.util.UUID
import java.util.concurrent.ArrayBlockingQueue
case class Command(id: UUID, payload: String)
val queue = ArrayBlockingQueue[Command](1024)
val accepted = queue.offer(Command(UUID.randomUUID(), "rebuild"))
println(accepted -> queue.remainingCapacity())
// На ревью требуется устранить причину дефекта, не скрывая её приведением типа или значением по умолчанию.