at org.apache.beam.runners.dataflow.repackaged.com.google.common.util.concurrent.TrustedListenableFutureTask$TrustedFutureInterruptibleTask.runInterruptibly(TrustedListenableFutureTask.java:111) ...
at com.linkedin.pinot.core.operator.CombineOperator.getNextBlock(CombineOperator.java:164) at com.linkedin.pinot.core.operator.CombineOperator.getNextBlock ...