added check before setting checkpoint directory

Nitish1814 · Nitish1814 · commit ecfc4e781c17 · 2024-12-10T21:01:14.000+05:30
diff --git a/spark/core/src/main/java/zingg/spark/core/executor/ZinggSparkContext.java b/spark/core/src/main/java/zingg/spark/core/executor/ZinggSparkContext.java
@@ -75,7 +75,9 @@ public void init(IZinggLicense license)
 				JavaSparkContext.jarOfClass(IZingg.class);
 				LOG.debug("Context " + ctx.toString());
 				//initHashFns();
-				ctx.setCheckpointDir("/tmp/checkpoint");
+                if (!ctx.getCheckpointDir().isPresent()) {
+                    ctx.setCheckpointDir("/tmp/checkpoint");
+                }
 				setUtils();
 			}
         }

Original file line number	Diff line number	Diff line change
`@@ -75,7 +75,9 @@ public void init(IZinggLicense license)`
`75`	`75`	`JavaSparkContext.jarOfClass(IZingg.class);`
`76`	`76`	`LOG.debug("Context " + ctx.toString());`
`77`	`77`	`//initHashFns();`
`78`		`- ctx.setCheckpointDir("/tmp/checkpoint");`
	`78`	`+ if (!ctx.getCheckpointDir().isPresent()) {`
	`79`	`+ ctx.setCheckpointDir("/tmp/checkpoint");`
	`80`	`+ }`
`79`	`81`	`setUtils();`
`80`	`82`	`}`
`81`	`83`	`}`