diff --git a/src/main/scala/beam/sim/BeamHelper.scala b/src/main/scala/beam/sim/BeamHelper.scala index 06175702191..4762958e4ce 100755 --- a/src/main/scala/beam/sim/BeamHelper.scala +++ b/src/main/scala/beam/sim/BeamHelper.scala @@ -2,6 +2,7 @@ package beam.sim import java.io.FileOutputStream import java.nio.file.{Files, Paths, StandardCopyOption} +import java.util import java.util.Properties import beam.agentsim.agents.ridehail.RideHailSurgePricingManager @@ -266,7 +267,11 @@ trait BeamHelper extends LazyLogging { ) ) } - Files.copy(Paths.get(configLocation), Paths.get(outputDirectory, "beam.conf"), StandardCopyOption.REPLACE_EXISTING) + Files.copy( + Paths.get(configLocation), + Paths.get(outputDirectory, "beam.conf"), + StandardCopyOption.REPLACE_EXISTING + ) } } @@ -291,7 +296,12 @@ trait BeamHelper extends LazyLogging { if (isMetricsEnable) Kamon.start(clusterConfig.withFallback(ConfigFactory.defaultReference())) import akka.actor.{ActorSystem, DeadLetter, PoisonPill, Props} - import akka.cluster.singleton.{ClusterSingletonManager, ClusterSingletonManagerSettings, ClusterSingletonProxy, ClusterSingletonProxySettings} + import akka.cluster.singleton.{ + ClusterSingletonManager, + ClusterSingletonManagerSettings, + ClusterSingletonProxy, + ClusterSingletonProxySettings + } import beam.router.ClusterWorkerRouter import beam.sim.monitoring.DeadLetterReplayer @@ -414,7 +424,6 @@ trait BeamHelper extends LazyLogging { } } - } case class MapStringDouble(data: Map[String, Double]) diff --git a/src/main/scala/beam/utils/BashUtils.scala b/src/main/scala/beam/utils/BashUtils.scala index 0cf3b1956e3..b33bd0a0c92 100644 --- a/src/main/scala/beam/utils/BashUtils.scala +++ b/src/main/scala/beam/utils/BashUtils.scala @@ -32,16 +32,12 @@ object BashUtils { val runtime = Runtime.getRuntime try { val process = runtime.exec(command) - try { - val reader = new BufferedReader(new InputStreamReader(process.getInputStream)) - try - reader.readLine - finally if (reader != null) reader.close() - } + val reader = new BufferedReader(new InputStreamReader(process.getInputStream)) + try reader.readLine + finally if (reader != null) reader.close() } catch { case _: Exception => null //for the env where command is not recognized - } } }