diff --git a/processing/src/main/java/org/apache/druid/frame/processor/FrameProcessorExecutor.java b/processing/src/main/java/org/apache/druid/frame/processor/FrameProcessorExecutor.java index ba0ab18f97e4..02161d5ad5ad 100644 --- a/processing/src/main/java/org/apache/druid/frame/processor/FrameProcessorExecutor.java +++ b/processing/src/main/java/org/apache/druid/frame/processor/FrameProcessorExecutor.java @@ -38,7 +38,6 @@ import org.apache.druid.frame.processor.manager.ProcessorManager; import org.apache.druid.java.util.common.Either; import org.apache.druid.java.util.common.StringUtils; -import org.apache.druid.java.util.common.Unit; import org.apache.druid.java.util.common.concurrent.Execs; import org.apache.druid.java.util.common.logger.Logger; diff --git a/processing/src/test/java/org/apache/druid/frame/processor/RunAllFullyWidgetTest.java b/processing/src/test/java/org/apache/druid/frame/processor/RunAllFullyWidgetTest.java index b434b28fe0d8..b82aed94ef81 100644 --- a/processing/src/test/java/org/apache/druid/frame/processor/RunAllFullyWidgetTest.java +++ b/processing/src/test/java/org/apache/druid/frame/processor/RunAllFullyWidgetTest.java @@ -244,7 +244,12 @@ public void test_runAllFully_errorAccumulateFn() IntStream.range(0, 100)::iterator, i -> new ChompingFrameProcessor(Collections.emptyList()) ) - ).withAccumulation(0L, (x, y) -> {throw new ISE("error!");}) + ).withAccumulation( + 0L, + (x, y) -> { + throw new ISE("error!"); + } + ) ) ), maxOutstandingProcessors,