mirror of https://github.com/apache/druid.git
fix context on CQE
This commit is contained in:
parent
bae0fdf936
commit
6a26f7684f
|
@ -83,7 +83,7 @@ public class ChainedExecutionQueryRunner<T> implements QueryRunner<T>
|
|||
@Override
|
||||
public Sequence<T> run(final Query<T> query)
|
||||
{
|
||||
final int priority = query.getContextValue("priority", 0);
|
||||
final int priority = query.getContextPriority(0);
|
||||
|
||||
return new BaseSequence<T, Iterator<T>>(
|
||||
new BaseSequence.IteratorMaker<T, Iterator<T>>()
|
||||
|
|
Loading…
Reference in New Issue