Skip to content

Commit 3bbc14d

Browse files
Jeremy BeardGitHub Enterprise
authored andcommitted
[ENV-451] Close Spark session at pipeline finish (#310)
1 parent 764da1a commit 3bbc14d

File tree

1 file changed

+1
-0
lines changed
  • core/src/main/java/com/cloudera/labs/envelope/run

1 file changed

+1
-0
lines changed

core/src/main/java/com/cloudera/labs/envelope/run/Runner.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -135,6 +135,7 @@ public void run(Config config) throws Exception {
135135
finally {
136136
shutdownThreadPool();
137137
shutdownSecurity();
138+
Contexts.closeSparkSession();
138139
}
139140

140141
notifyPipelineFinished();

0 commit comments

Comments
 (0)