Skip to content

Commit

Permalink
Minor update to RunOSCOmmandPlugin
Browse files Browse the repository at this point in the history
  • Loading branch information
LucaCanali committed Mar 14, 2022
1 parent c1a7858 commit 5f79a9a
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion src/main/scala/ch/cern/RunOSCommandPlugin.scala
Original file line number Diff line number Diff line change
Expand Up @@ -27,7 +27,7 @@ class RunOSCommandPlugin extends SparkPlugin {
// Run the OS command, this is an example, customize and add error and stdout management as needed
val command = myContext.conf.get("spark.cernSparkPlugin.command", defaultCommand)
val process = Process(command).lineStream
DemoPlugin.numSuccessfulPlugins += 1
RunOSCommandPlugin.numSuccessfulPlugins += 1
}

override def shutdown(): Unit = {
Expand Down

0 comments on commit 5f79a9a

Please sign in to comment.