fix e2e

Signed-off-by: Yashash H L <[email protected]>
numaproj · Dec 8, 2023 · 5760015 · 5760015
1 parent da3d38c
commit 5760015
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/pkg/udf/reduce_udf.go b/pkg/udf/reduce_udf.go
@@ -49,6 +49,7 @@ import (
 	"github.com/numaproj/numaflow/pkg/window"
 	"github.com/numaproj/numaflow/pkg/window/strategy/fixed"
 	"github.com/numaproj/numaflow/pkg/window/strategy/session"
+	"github.com/numaproj/numaflow/pkg/window/strategy/sliding"
 )
 
 type ReduceUDFProcessor struct {
@@ -142,7 +143,7 @@ func (u *ReduceUDFProcessor) Start(ctx context.Context) error {
 	if windowType.Fixed != nil {
 		windower = fixed.NewWindower(windowType.Fixed.Length.Duration)
 	} else if windowType.Sliding != nil {
-		windower = fixed.NewWindower(windowType.Sliding.Length.Duration)
+		windower = sliding.NewWindower(windowType.Sliding.Length.Duration, windowType.Sliding.Slide.Duration)
 	} else if windowType.Session != nil {
 		windower = session.NewWindower(windowType.Session.Timeout.Duration)
 	} else {

diff --git a/test/reduce-e2e/testdata/complex-sliding-window-pipeline.yaml b/test/reduce-e2e/testdata/complex-sliding-window-pipeline.yaml
@@ -57,7 +57,6 @@ spec:
           storage:
             emptyDir: {}
     - name: sink
-      partitions: 2
       scale:
         min: 1
       sink:

diff --git a/test/sideinputs-e2e/testdata/reduce-sideinput-pipeline.yaml b/test/sideinputs-e2e/testdata/reduce-sideinput-pipeline.yaml
@@ -27,7 +27,7 @@ spec:
       udf:
         container:
           # A reduce side input udf, see https://github.com/numaproj-contrib/e2e-tests-go/tree/main/reduce-side-input/udf
-          image: "quay.io/numaio/numaproj-contrib/e2e-reduce-sideinput-example:dev"
+          image: "quay.io/numaio/numaproj-contrib/e2e-reduce-sideinput-udf:dev"
           imagePullPolicy: Always
         groupBy:
           window: