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 01a8743dd86..4e28edc3ac1 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 @@ -60,6 +60,7 @@ import org.apache.druid.msq.indexing.error.TooManyClusteredByColumnsFault; import org.apache.druid.msq.indexing.error.TooManyColumnsFault; import org.apache.druid.msq.indexing.error.TooManyInputFilesFault; import org.apache.druid.msq.indexing.error.TooManyPartitionsFault; +import org.apache.druid.msq.indexing.error.TooManyRowsInAWindowFault; import org.apache.druid.msq.indexing.error.TooManyRowsWithSameKeyFault; import org.apache.druid.msq.indexing.error.TooManySegmentsInTimeChunkFault; import org.apache.druid.msq.indexing.error.TooManyWarningsFault; @@ -128,6 +129,7 @@ public class MSQIndexingModule implements DruidModule TooManyColumnsFault.class, TooManyInputFilesFault.class, TooManyPartitionsFault.class, + TooManyRowsInAWindowFault.class, TooManyRowsWithSameKeyFault.class, TooManySegmentsInTimeChunkFault.class, TooManyWarningsFault.class, diff --git a/extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/indexing/error/MSQFaultSerdeTest.java b/extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/indexing/error/MSQFaultSerdeTest.java index cffc0f78a49..0c16ae08af5 100644 --- a/extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/indexing/error/MSQFaultSerdeTest.java +++ b/extensions-core/multi-stage-query/src/test/java/org/apache/druid/msq/indexing/error/MSQFaultSerdeTest.java @@ -85,6 +85,7 @@ public class MSQFaultSerdeTest assertFaultSerde(new TooManyClusteredByColumnsFault(10, 8, 1)); assertFaultSerde(new TooManyInputFilesFault(15, 10, 5)); assertFaultSerde(new TooManyPartitionsFault(10)); + assertFaultSerde(new TooManyRowsInAWindowFault(10, 20)); assertFaultSerde(new TooManyRowsWithSameKeyFault(Arrays.asList("foo", 123), 1, 2)); assertFaultSerde(new TooManySegmentsInTimeChunkFault(DateTimes.nowUtc(), 10, 1, Granularities.ALL)); assertFaultSerde(new TooManyWarningsFault(10, "the error"));