最新消息:雨落星辰是一个专注网站SEO优化、网站SEO诊断、搜索引擎研究、网络营销推广、网站策划运营及站长类的自媒体原创博客

Druid Sequence iterator timed out - Stack Overflow

programmeradmin3浏览0评论

We're running our queries on Druid. We're getting following error:

2023-12-05T15:31:32,643 ERROR [qtp1537436803-164] .apache.druid.sql.avatica.DruidMeta - Sequence iterator timed out waiting for data .apache.druid.query.QueryTimeoutException: Sequence iterator timed out waiting for data at .apache.druid.java.utilmon.guava.ParallelMergeCombiningSequence$1$1.hasNext(ParallelMergeCombiningSequence.java:205) ~[druid-core-25.0.0.jar:25.0.0] at .apache.druid.java.utilmon.guava.BaseSequence.toYielder(BaseSequence.java:70) ~[druid-core-25.0.0.jar:25.0.0] at .apache.druid.java.utilmon.guava.WrappingSequence$2.get(WrappingSequence.java:88) ~[druid-core-25.0.0.jar:25.0.0] at .apache.druid.java.utilmon.guava.WrappingSequence$2.get(WrappingSequence.java:84) ~[druid-core-25.0.0.jar:25.0.0] at .apache.druid.java.utilmon.guava.SequenceWrapper.wrap(SequenceWrapper.java:55) ~[druid-core-25.0.0.jar:25.0.0] at .apache.druid.java.utilmon.guava.WrappingSequence.toYielder(WrappingSequence.java:83) ~[druid-core-25.0.0.jar:25.0.0] at .apache.druid.java.utilmon.guava.ParallelMergeCombiningSequence.toYielder(ParallelMergeCombiningSequence.java:153) ~[druid-core-25.0.0.jar:25.0.0] at .apache.druid.java.utilmon.guava.LazySequence.toYielder(LazySequence.java:46) ~[druid-core-25.0.0.jar:25.0.0] at .apache.druid.java.utilmon.guava.WrappingSequence$2.get(WrappingSequence.java:88) ~[druid-core-25.0.0.jar:25.0.0] at .apache.druid.java.utilmon.guava.WrappingSequence$2.get(WrappingSequence.java:84) ~[druid-core-25.0.0.jar:25.0.0] at .apache.druid.java.utilmon.guava.SequenceWrapper.wrap(SequenceWrapper.java:55) ~[druid-core-25.0.0.jar:25.0.0] at .apache.druid.java.utilmon.guava.WrappingSequence.toYielder(WrappingSequence.java:83) ~[druid-core-25.0.0.jar:25.0.0] at .apache.druid.java.utilmon.guava.MergeSequence.lambda$toYielder$1(MergeSequence.java:66) ~[druid-core-25.0.0.jar:25.0.0] at .apache.druid.java.utilmon.guava.BaseSequence.accumulate(BaseSequence.java:44) ~[druid-core-25.0.0.jar:25.0.0] at .apache.druid.java.utilmon.guava.MergeSequence.toYielder(MergeSequence.java:63) ~[druid-core-25.0.0.jar:25.0.0] at .apache.druid.query.RetryQueryRunner$1.toYielder(RetryQueryRunner.java:133) ~[druid-server-25.0.0.jar:25.0.0] at .apache.druid.java.utilmon.guava.YieldingSequenceBase.accumulate(YieldingSequenceBase.java:35) ~[druid-core-25.0.0.jar:25.0.0] at .apache.druidmon.guava.CombiningSequence.accumulate(CombiningSequence.java:62) ~[druid-core-25.0.0.jar:25.0.0] at .apache.druid.java.utilmon.guava.MappedSequence.accumulate(MappedSequence.java:43) ~[druid-core-25.0.0.jar:25.0.0] at .apache.druid.java.utilmon.guava.WrappingSequence$1.get(WrappingSequence.java:50) ~[druid-core-25.0.0.jar:25.0.0] at .apache.druid.java.utilmon.guava.SequenceWrapper.wrap(SequenceWrapper.java:55) ~[druid-core-25.0.0.jar:25.0.0] at .apache.druid.java.utilmon.guava.WrappingSequence.accumulate(WrappingSequence.java:45) ~[druid-core-25.0.0.jar:25.0.0] at .apache.druid.java.utilmon.guava.MappedSequence.accumulate(MappedSequence.java:43) ~[druid-core-25.0.0.jar:25.0.0] at .apache.druid.java.utilmon.guava.WrappingSequence$1.get(WrappingSequence.java:50) ~[druid-core-25.0.0.jar:25.0.0] at .apache.druid.query.CPUTimeMetricQueryRunner$1.wrap(CPUTimeMetricQueryRunner.java:77) ~[druid-processing-25.0.0.jar:25.0.0] at .apache.druid.java.utilmon.guava.WrappingSequence.accumulate(WrappingSequence.java:45) ~[druid-core-25.0.0.jar:25.0.0] at .apache.druid.java.utilmon.guava.MappedSequence.accumulate(MappedSequence.java:43) ~[druid-core-25.0.0.jar:25.0.0] at .apache.druid.server.ClientQuerySegmentWalker.toInlineDataSource(ClientQuerySegmentWalker.java:577) ~[druid-server-25.0.0.jar:25.0.0] at .apache.druid.server.ClientQuerySegmentWalker.inlineIfNecessary(ClientQuerySegmentWalker.java:365) ~[druid-server-25.0.0.jar:25.0.0] at .apache.druid.server.ClientQuerySegmentWalker.inlineIfNecessary(ClientQuerySegmentWalker.java:374) ~[druid-server-25.0.0.jar:25.0.0] at .apache.druid.server.ClientQuerySegmentWalker.lambda$inlineIfNecessary$0(ClientQuerySegmentWalker.java:397) ~[druid-server-25.0.0.jar:25.0.0] at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:195) ~[?:?] at java.util.AbstractList$RandomAccessSpliterator.forEachRemaining(AbstractList.java:720) ~[?:?] at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:484) ~[?:?] at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:474) ~[?:?] at java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:913) ~[?:?] at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234) ~[?:?] at java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:578) ~[?:?] at .apache.druid.server.ClientQuerySegmentWalker.inlineIfNecessary(ClientQuerySegmentWalker.java:398) ~[druid-server-25.0.0.jar:25.0.0] at .apache.druid.server.ClientQuerySegmentWalker.getQueryRunnerForIntervals(ClientQuerySegmentWalker.java:183) ~[druid-server-25.0.0.jar:25.0.0] at .apache.druid.query.spec.MultipleIntervalSegmentSpec.lookup(MultipleIntervalSegmentSpec.java:57) ~[druid-processing-25.0.0.jar:25.0.0] at .apache.druid.query.BaseQuery.getRunner(BaseQuery.java:120) ~[druid-processing-25.0.0.jar:25.0.0] at .apache.druid.query.QueryPlus.run(QueryPlus.java:149) ~[druid-processing-25.0.0.jar:25.0.0] at .apache.druid.server.QueryLifecycle.execute(QueryLifecycle.java:285) ~[druid-server-25.0.0.jar:25.0.0] at .apache.druid.server.QueryLifecycle.runSimple(QueryLifecycle.java:163) ~[druid-server-25.0.0.jar:25.0.0] at .apache.druid.sql.calcite.run.NativeQueryMaker.execute(NativeQueryMaker.java:199) ~[druid-sql-25.0.0.jar:25.0.0] at .apache.druid.sql.calcite.run.NativeQueryMaker.runQuery(NativeQueryMaker.java:161) ~[druid-sql-25.0.0.jar:25.0.0] at .apache.druid.sql.calcite.rel.DruidRel.runQuery(DruidRel.java:54) ~[druid-sql-25.0.0.jar:25.0.0] at .apache.druid.sql.calcite.planner.QueryHandler.lambda$planWithDruidConvention$5(QueryHandler.java:517) ~[druid-sql-25.0.0.jar:25.0.0] at .apache.druid.sql.calcite.planner.PlannerResult.run(PlannerResult.java:62) ~[druid-sql-25.0.0.jar:25.0.0] at .apache.druid.sql.DirectStatement$ResultSet.run(DirectStatement.java:106) ~[druid-sql-25.0.0.jar:25.0.0] at .apache.druid.sql.DirectStatement.execute(DirectStatement.java:181) ~[druid-sql-25.0.0.jar:25.0.0] at .apache.druid.sql.avatica.DruidJdbcResultSet.lambda$execute$0(DruidJdbcResultSet.java:239) ~[druid-sql-25.0.0.jar:25.0.0] at java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[?:?] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) ~[?:?] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) ~[?:?] at java.lang.Thread.run(Thread.java:829) ~[?:?] Suppressed: java.lang.NullPointerException

This issue is occurring once every couple of months. The fix we have to do to resolve this is delete the druid-druid-cluster-brokers-0 & druid-druid-cluster-brokers-1 pods. New pods will be recreated automatically. But this looks like a workaround. Is there any way we can fix the issue instead of just deleting pods.

发布评论

评论列表(0)

  1. 暂无评论