Merge pull request #5524 from gchq/5522-Aggregator-Not-Allowed-When-Specified

Issue 5522: DefaultCompactionRunnerFactory doesn't allow java compactions with aggregators specified

Author: rtjd6554

java/compaction/compaction-job-execution/src/main/java/sleeper/compaction/job/execution/DefaultCompactionRunnerFactory.java

@@ -51,14 +51,6 @@ public DefaultCompactionRunnerFactory(ObjectFactory objectFactory, Configuration
     public CompactionRunner createCompactor(CompactionJob job, TableProperties tableProperties) {
         DataEngine engine = tableProperties.getEnumValue(DATA_ENGINE, DataEngine.class);
         CompactionRunner runner = createRunnerForEngine(engine);
-
-        // Has an experimental DataFusion only iterator been specified? If so, make sure
-        // we are using the DataFusion compactor
-        if (DataEngine.AGGREGATION_ITERATOR_NAME.equals(job.getIteratorClassName()) && !(runner instanceof DataFusionCompactionRunner)) {
-            throw new IllegalStateException("DataFusion-only iterator specified, but DataFusion compactor not selected for job ID "
-                    + job.getId() + " table ID " + job.getTableId());
-        }
-
         LOGGER.info("Selecting {} compactor (language {}) for job ID {} table ID {}", runner.getClass().getSimpleName(), runner.implementationLanguage(), job.getId(), job.getTableId());
         return runner;
     }