From 6a26f7684fd0e59ceaadc1b83c85fd8b8da46dd7 Mon Sep 17 00:00:00 2001 From: fjy Date: Mon, 7 Apr 2014 14:36:13 -0700 Subject: [PATCH] fix context on CQE --- .../main/java/io/druid/query/ChainedExecutionQueryRunner.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/processing/src/main/java/io/druid/query/ChainedExecutionQueryRunner.java b/processing/src/main/java/io/druid/query/ChainedExecutionQueryRunner.java index 3e3e6b03243..776276415a2 100644 --- a/processing/src/main/java/io/druid/query/ChainedExecutionQueryRunner.java +++ b/processing/src/main/java/io/druid/query/ChainedExecutionQueryRunner.java @@ -83,7 +83,7 @@ public class ChainedExecutionQueryRunner implements QueryRunner @Override public Sequence run(final Query query) { - final int priority = query.getContextValue("priority", 0); + final int priority = query.getContextPriority(0); return new BaseSequence>( new BaseSequence.IteratorMaker>()