Move numReferenceOfSparkContext.incrementAndGet() to the end of open() method

This commit is contained in:
Lee moon soo 2016-02-23 23:01:03 -08:00
parent 4d2533f0e0
commit b091b7efed

View file

@ -488,8 +488,6 @@ public class SparkInterpreter extends Interpreter {
intp.setContextClassLoader();
intp.initializeSynchronous();
numReferenceOfSparkContext.incrementAndGet();
synchronized (sharedInterpreterLock) {
if (classOutputDir == null) {
classOutputDir = settings.outputDirs().getSingleOutput().get();
@ -614,6 +612,8 @@ public class SparkInterpreter extends Interpreter {
}
}
}
numReferenceOfSparkContext.incrementAndGet();
}
private List<File> currentClassPath() {