diff --git a/engine/env/spark/src/main/java/org/datacleaner/spark/SparkAnalysisRunner.java b/engine/env/spark/src/main/java/org/datacleaner/spark/SparkAnalysisRunner.java
index <HASH>..<HASH> 100644
--- a/engine/env/spark/src/main/java/org/datacleaner/spark/SparkAnalysisRunner.java
+++ b/engine/env/spark/src/main/java/org/datacleaner/spark/SparkAnalysisRunner.java
@@ -86,8 +86,6 @@ public class SparkAnalysisRunner implements AnalysisRunner {
 
     @Override
     public AnalysisResultFuture run(AnalysisJob job) {
-        assert job == _sparkJobContext.getAnalysisJob();
-
         final AnalysisJob analysisJob = _sparkJobContext.getAnalysisJob();
         final Datastore datastore = analysisJob.getDatastore();
Issue #<I>: Removed assertion which is no longer valid