Skip to content

Commit

Permalink
Style.
Browse files Browse the repository at this point in the history
  • Loading branch information
gianm committed Sep 19, 2023
1 parent c1600e8 commit 292be52
Show file tree
Hide file tree
Showing 2 changed files with 6 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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;

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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,
Expand Down

0 comments on commit 292be52

Please sign in to comment.