Skip to content

Commit 8763d57

Browse files
authored
Fix RPROperator blocking behavior
1 parent f7992dd commit 8763d57

1 file changed

Lines changed: 6 additions & 0 deletions

File tree

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/PatternRecognitionOperator.java

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -33,6 +33,7 @@
3333
import org.apache.iotdb.db.queryengine.plan.relational.planner.node.SkipToPosition;
3434

3535
import com.google.common.collect.ImmutableList;
36+
import com.google.common.util.concurrent.ListenableFuture;
3637
import org.apache.tsfile.block.column.Column;
3738
import org.apache.tsfile.common.conf.TSFileDescriptor;
3839
import org.apache.tsfile.enums.TSDataType;
@@ -152,6 +153,11 @@ public OperatorContext getOperatorContext() {
152153
return operatorContext;
153154
}
154155

156+
@Override
157+
public ListenableFuture<?> isBlocked() {
158+
return child.isBlocked();
159+
}
160+
155161
@Override
156162
public TsBlock next() throws Exception {
157163
long startTime = System.nanoTime();

0 commit comments

Comments
 (0)