From 6b001224df98f6bd1e76029d347f85bff9da3354 Mon Sep 17 00:00:00 2001 From: Angie Zhang Date: Tue, 9 Aug 2022 18:43:27 -0700 Subject: [PATCH 1/2] Change test page size to avoid indexTimeInMillis < 1 issue. Signed-off-by: Angie Zhang --- .../indexmanagement/transform/TransformRunnerIT.kt | 14 +++++++------- 1 file changed, 7 insertions(+), 7 deletions(-) diff --git a/src/test/kotlin/org/opensearch/indexmanagement/transform/TransformRunnerIT.kt b/src/test/kotlin/org/opensearch/indexmanagement/transform/TransformRunnerIT.kt index f1fafb996..f9af3434b 100644 --- a/src/test/kotlin/org/opensearch/indexmanagement/transform/TransformRunnerIT.kt +++ b/src/test/kotlin/org/opensearch/indexmanagement/transform/TransformRunnerIT.kt @@ -84,7 +84,7 @@ class TransformRunnerIT : TransformRestTestCase() { sourceIndex = "transform-source-index", targetIndex = "transform-target-index", roles = emptyList(), - pageSize = 100, + pageSize = 10, groups = listOf( Terms(sourceField = "store_and_fwd_flag", targetField = "flag") ), @@ -350,7 +350,7 @@ class TransformRunnerIT : TransformRestTestCase() { sourceIndex = dataStreamName, targetIndex = "transform-target-index", roles = emptyList(), - pageSize = 100, + pageSize = 10, groups = listOf( Terms(sourceField = "store_and_fwd_flag", targetField = "flag") ) @@ -390,7 +390,7 @@ class TransformRunnerIT : TransformRestTestCase() { sourceIndex = "transform-no-op-source-index", targetIndex = "transform-no-op-target-index", roles = emptyList(), - pageSize = 100, + pageSize = 10, groups = listOf( Terms(sourceField = "store_and_fwd_flag", targetField = "flag"), Histogram(sourceField = "trip_distance", targetField = "distance", interval = 0.1) @@ -459,7 +459,7 @@ class TransformRunnerIT : TransformRestTestCase() { sourceIndex = "continuous-transform-source-index", targetIndex = "continuous-transform-target-index", roles = emptyList(), - pageSize = 100, + pageSize = 10, groups = listOf( Terms(sourceField = "store_and_fwd_flag", targetField = "flag") ), @@ -587,7 +587,7 @@ class TransformRunnerIT : TransformRestTestCase() { sourceIndex = sourceIndex, targetIndex = "modified-bucket-target-index", roles = emptyList(), - pageSize = 100, + pageSize = 10, groups = listOf( Histogram(sourceField = "iterating_id", targetField = "id_group", interval = 5.0) ), @@ -717,7 +717,7 @@ class TransformRunnerIT : TransformRestTestCase() { sourceIndex = "wildcard-s*e-*", targetIndex = "wildcard-target-index", roles = emptyList(), - pageSize = 100, + pageSize = 10, groups = listOf( Terms(sourceField = "store_and_fwd_flag", targetField = "flag") ), @@ -806,7 +806,7 @@ class TransformRunnerIT : TransformRestTestCase() { sourceIndex = sourceIndex, targetIndex = "null-bucket-target-index", roles = emptyList(), - pageSize = 100, + pageSize = 10, groups = listOf( Histogram(sourceField = "iterating_id", targetField = "id_group", interval = 5.0), Terms(sourceField = "term_id", targetField = "id_term") From 85b1f3b914c7cadff2fa86260c49aab3543ed4b3 Mon Sep 17 00:00:00 2001 From: Angie Zhang Date: Tue, 9 Aug 2022 19:30:11 -0700 Subject: [PATCH 2/2] Change test page size to avoid indexTimeInMillis < 1 issue. Signed-off-by: Angie Zhang --- .../indexmanagement/transform/TransformRunnerIT.kt | 14 +++++++------- 1 file changed, 7 insertions(+), 7 deletions(-) diff --git a/src/test/kotlin/org/opensearch/indexmanagement/transform/TransformRunnerIT.kt b/src/test/kotlin/org/opensearch/indexmanagement/transform/TransformRunnerIT.kt index f9af3434b..ee87be65f 100644 --- a/src/test/kotlin/org/opensearch/indexmanagement/transform/TransformRunnerIT.kt +++ b/src/test/kotlin/org/opensearch/indexmanagement/transform/TransformRunnerIT.kt @@ -44,7 +44,7 @@ class TransformRunnerIT : TransformRestTestCase() { sourceIndex = "transform-source-index", targetIndex = "transform-target-index", roles = emptyList(), - pageSize = 100, + pageSize = 10, groups = listOf( Terms(sourceField = "store_and_fwd_flag", targetField = "flag") ) @@ -350,7 +350,7 @@ class TransformRunnerIT : TransformRestTestCase() { sourceIndex = dataStreamName, targetIndex = "transform-target-index", roles = emptyList(), - pageSize = 10, + pageSize = 100, groups = listOf( Terms(sourceField = "store_and_fwd_flag", targetField = "flag") ) @@ -390,7 +390,7 @@ class TransformRunnerIT : TransformRestTestCase() { sourceIndex = "transform-no-op-source-index", targetIndex = "transform-no-op-target-index", roles = emptyList(), - pageSize = 10, + pageSize = 100, groups = listOf( Terms(sourceField = "store_and_fwd_flag", targetField = "flag"), Histogram(sourceField = "trip_distance", targetField = "distance", interval = 0.1) @@ -459,7 +459,7 @@ class TransformRunnerIT : TransformRestTestCase() { sourceIndex = "continuous-transform-source-index", targetIndex = "continuous-transform-target-index", roles = emptyList(), - pageSize = 10, + pageSize = 100, groups = listOf( Terms(sourceField = "store_and_fwd_flag", targetField = "flag") ), @@ -587,7 +587,7 @@ class TransformRunnerIT : TransformRestTestCase() { sourceIndex = sourceIndex, targetIndex = "modified-bucket-target-index", roles = emptyList(), - pageSize = 10, + pageSize = 100, groups = listOf( Histogram(sourceField = "iterating_id", targetField = "id_group", interval = 5.0) ), @@ -717,7 +717,7 @@ class TransformRunnerIT : TransformRestTestCase() { sourceIndex = "wildcard-s*e-*", targetIndex = "wildcard-target-index", roles = emptyList(), - pageSize = 10, + pageSize = 100, groups = listOf( Terms(sourceField = "store_and_fwd_flag", targetField = "flag") ), @@ -806,7 +806,7 @@ class TransformRunnerIT : TransformRestTestCase() { sourceIndex = sourceIndex, targetIndex = "null-bucket-target-index", roles = emptyList(), - pageSize = 10, + pageSize = 100, groups = listOf( Histogram(sourceField = "iterating_id", targetField = "id_group", interval = 5.0), Terms(sourceField = "term_id", targetField = "id_term")