From 40a18f10039d3bb68c5464e05535808fa630c6a0 Mon Sep 17 00:00:00 2001 From: Soumyava Das Date: Fri, 8 Dec 2023 12:30:31 -0800 Subject: [PATCH] Fixing running window function in console --- .../java/org/apache/druid/msq/guice/MSQIndexingModule.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/guice/MSQIndexingModule.java b/extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/guice/MSQIndexingModule.java index 4af832705c3f..8ab890dcd7a0 100644 --- a/extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/guice/MSQIndexingModule.java +++ b/extensions-core/multi-stage-query/src/main/java/org/apache/druid/msq/guice/MSQIndexingModule.java @@ -84,6 +84,7 @@ import org.apache.druid.msq.input.table.TableInputSpec; import org.apache.druid.msq.kernel.NilExtraInfoHolder; import org.apache.druid.msq.querykit.InputNumberDataSource; +import org.apache.druid.msq.querykit.WindowOperatorQueryFrameProcessorFactory; import org.apache.druid.msq.querykit.common.OffsetLimitFrameProcessorFactory; import org.apache.druid.msq.querykit.common.SortMergeJoinFrameProcessorFactory; import org.apache.druid.msq.querykit.groupby.GroupByPostShuffleFrameProcessorFactory; @@ -158,7 +159,7 @@ public List getJacksonModules() NilExtraInfoHolder.class, SortMergeJoinFrameProcessorFactory.class, QueryResultFrameProcessorFactory.class, - + WindowOperatorQueryFrameProcessorFactory.class, // DataSource classes (note: ExternalDataSource is in MSQSqlModule) InputNumberDataSource.class,