Update RollupInterceptor.kt

uncommeneted rollup size check Signed-off-by: Ronnak Saxena <[email protected]>
opensearch-project · Aug 23, 2023 · c258896 · c258896
1 parent 6d82554
commit c258896
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/src/main/kotlin/org/opensearch/indexmanagement/rollup/interceptor/RollupInterceptor.kt b/src/main/kotlin/org/opensearch/indexmanagement/rollup/interceptor/RollupInterceptor.kt
@@ -85,9 +85,9 @@ class RollupInterceptor(
                     val index = request.shardId().indexName
                     val isRollupIndex = isRollupIndex(index, clusterService.state())
                     if (isRollupIndex) {
-//                        if (request.source().size() != 0) {
-//                            throw IllegalArgumentException("Rollup search must have size explicitly set to 0, but found ${request.source().size()}")
-//                        }
+                        if (request.source().size() != 0) {
+                            throw IllegalArgumentException("Rollup search must have size explicitly set to 0, but found ${request.source().size()}")
+                        }
 
                         val indices = request.indices().map { it.toString() }.toTypedArray()
                         val concreteIndices = indexNameExpressionResolver