From fc303d616c3abb778e0d0d16ae43cd72769c2c4b Mon Sep 17 00:00:00 2001 From: a3hadi Date: Fri, 22 Mar 2024 17:22:49 -0400 Subject: [PATCH 1/2] update example image tags to use stable Signed-off-by: a3hadi --- test/diamond-e2e/testdata/cycle-backward.yaml | 2 +- test/diamond-e2e/testdata/cycle-to-self.yaml | 2 +- .../testdata/join-on-reduce-pipeline.yaml | 6 +++--- test/diamond-e2e/testdata/join-on-sink.yaml | 2 +- test/e2e/testdata/even-odd.yaml | 2 +- .../testdata/idle-source-reduce-pipeline.yaml | 4 ++-- test/idle-source-e2e/testdata/kafka-pipeline.yaml | 2 +- .../testdata/complex-reduce-pipeline.yaml | 6 +++--- .../testdata/complex-sliding-window-pipeline.yaml | 8 ++++---- .../testdata/simple-keyed-reduce-pipeline.yaml | 4 ++-- .../testdata/simple-non-keyed-reduce-pipeline.yaml | 4 ++-- .../testdata/simple-reduce-pipeline-wal.yaml | 4 ++-- .../testdata/reduce-stream/reduce-stream-go.yaml | 4 ++-- .../testdata/reduce-stream/reduce-stream-java.yaml | 4 ++-- .../simple-session-keyed-counter-pipeline-go.yaml | 4 ++-- ...simple-session-keyed-counter-pipeline-java.yaml | 2 +- .../simple-session-sum-pipeline.yaml | 2 +- test/sdks-e2e/testdata/flatmap-stream.yaml | 14 +++++++------- test/sdks-e2e/testdata/flatmap.yaml | 12 ++++++------ .../testdata/simple-keyed-reduce-pipeline.yaml | 6 +++--- .../testdata/transformer/event-time-filter-go.yaml | 2 +- .../transformer/event-time-filter-java.yaml | 2 +- .../transformer/event-time-filter-python.yaml | 2 +- .../testdata/reduce-sideinput-pipeline.yaml | 2 +- test/udsource-e2e/testdata/simple-source-go.yaml | 2 +- test/udsource-e2e/testdata/simple-source-java.yaml | 2 +- .../testdata/simple-source-python.yaml | 2 +- 27 files changed, 54 insertions(+), 54 deletions(-) diff --git a/test/diamond-e2e/testdata/cycle-backward.yaml b/test/diamond-e2e/testdata/cycle-backward.yaml index 2126013a44..f90b9e617f 100644 --- a/test/diamond-e2e/testdata/cycle-backward.yaml +++ b/test/diamond-e2e/testdata/cycle-backward.yaml @@ -17,7 +17,7 @@ spec: udf: container: # This will try each message up to 3 times before continuing, see https://github.com/numaproj/numaflow-go/tree/main/pkg/mapper/examples/retry - image: quay.io/numaio/numaflow-go/map-retry:v0.6.1 + image: quay.io/numaio/numaflow-go/map-retry:stable - name: out sink: udsink: diff --git a/test/diamond-e2e/testdata/cycle-to-self.yaml b/test/diamond-e2e/testdata/cycle-to-self.yaml index ec02e3805d..0b10c708b7 100644 --- a/test/diamond-e2e/testdata/cycle-to-self.yaml +++ b/test/diamond-e2e/testdata/cycle-to-self.yaml @@ -13,7 +13,7 @@ spec: udf: container: # This will try each message up to 3 times before continuing, see https://github.com/numaproj/numaflow-go/tree/main/pkg/mapper/examples/retry - image: quay.io/numaio/numaflow-go/map-retry:v0.6.1 + image: quay.io/numaio/numaflow-go/map-retry:stable - name: out sink: udsink: diff --git a/test/diamond-e2e/testdata/join-on-reduce-pipeline.yaml b/test/diamond-e2e/testdata/join-on-reduce-pipeline.yaml index 5b9cabbe7d..4ecafa90df 100644 --- a/test/diamond-e2e/testdata/join-on-reduce-pipeline.yaml +++ b/test/diamond-e2e/testdata/join-on-reduce-pipeline.yaml @@ -17,7 +17,7 @@ spec: udf: container: # Tell the input number is even or odd, see https://github.com/numaproj/numaflow-go/tree/main/pkg/mapper/examples/even_odd - image: quay.io/numaio/numaflow-go/map-even-odd:v0.6.1 + image: quay.io/numaio/numaflow-go/map-even-odd:stable - name: atoi-1 partitions: 2 scale: @@ -25,13 +25,13 @@ spec: udf: container: # Tell the input number is even or odd, see https://github.com/numaproj/numaflow-go/tree/main/pkg/mapper/examples/even_odd - image: quay.io/numaio/numaflow-go/map-even-odd:v0.6.1 + image: quay.io/numaio/numaflow-go/map-even-odd:stable - name: compute-sum partitions: 2 udf: container: # Compute the sum, see https://github.com/numaproj/numaflow-go/tree/main/pkg/reducer/examples/sum - image: quay.io/numaio/numaflow-go/reduce-sum:v0.6.1 + image: quay.io/numaio/numaflow-go/reduce-sum:stable groupBy: window: fixed: diff --git a/test/diamond-e2e/testdata/join-on-sink.yaml b/test/diamond-e2e/testdata/join-on-sink.yaml index 6601a1463d..c90c7160af 100644 --- a/test/diamond-e2e/testdata/join-on-sink.yaml +++ b/test/diamond-e2e/testdata/join-on-sink.yaml @@ -11,7 +11,7 @@ spec: udf: container: # Tell the input number is even or odd, see https://github.com/numaproj/numaflow-go/tree/main/pkg/mapper/examples/even_odd - image: quay.io/numaio/numaflow-go/map-even-odd:v0.6.1 + image: quay.io/numaio/numaflow-go/map-even-odd:stable - name: even-cat udf: builtin: diff --git a/test/e2e/testdata/even-odd.yaml b/test/e2e/testdata/even-odd.yaml index 23ebfb2807..2462e788d8 100644 --- a/test/e2e/testdata/even-odd.yaml +++ b/test/e2e/testdata/even-odd.yaml @@ -12,7 +12,7 @@ spec: udf: container: # Tell the input number is even or odd, see https://github.com/numaproj/numaflow-go/tree/main/pkg/mapper/examples/even_odd - image: quay.io/numaio/numaflow-go/map-even-odd:v0.6.1 + image: quay.io/numaio/numaflow-go/map-even-odd:stable - name: even-sink partitions: 2 sink: diff --git a/test/idle-source-e2e/testdata/idle-source-reduce-pipeline.yaml b/test/idle-source-e2e/testdata/idle-source-reduce-pipeline.yaml index ad67ff8a27..80b0184d7d 100644 --- a/test/idle-source-e2e/testdata/idle-source-reduce-pipeline.yaml +++ b/test/idle-source-e2e/testdata/idle-source-reduce-pipeline.yaml @@ -23,13 +23,13 @@ spec: udf: container: # Tell the input number is even or odd, see https://github.com/numaproj/numaflow-go/tree/main/pkg/mapper/examples/even_odd - image: quay.io/numaio/numaflow-go/map-even-odd:v0.6.1 + image: quay.io/numaio/numaflow-go/map-even-odd:stable - name: compute-sum partitions: 2 udf: container: # Compute the sum, see https://github.com/numaproj/numaflow-go/tree/main/pkg/reducer/examples/sum - image: quay.io/numaio/numaflow-go/reduce-sum:v0.6.1 + image: quay.io/numaio/numaflow-go/reduce-sum:stable groupBy: window: fixed: diff --git a/test/idle-source-e2e/testdata/kafka-pipeline.yaml b/test/idle-source-e2e/testdata/kafka-pipeline.yaml index a99fec169d..fbffe2b6c0 100644 --- a/test/idle-source-e2e/testdata/kafka-pipeline.yaml +++ b/test/idle-source-e2e/testdata/kafka-pipeline.yaml @@ -29,7 +29,7 @@ spec: - name: count-event udf: container: - image: quay.io/numaio/numaflow-go/reduce-counter:v0.6.1 + image: quay.io/numaio/numaflow-go/reduce-counter:stable groupBy: window: fixed: diff --git a/test/reduce-one-e2e/testdata/complex-reduce-pipeline.yaml b/test/reduce-one-e2e/testdata/complex-reduce-pipeline.yaml index 2b7a45dc5a..123f2fe777 100644 --- a/test/reduce-one-e2e/testdata/complex-reduce-pipeline.yaml +++ b/test/reduce-one-e2e/testdata/complex-reduce-pipeline.yaml @@ -19,13 +19,13 @@ spec: udf: container: # Tell the input number is even or odd, see https://github.com/numaproj/numaflow-go/tree/main/pkg/mapper/examples/even_odd - image: quay.io/numaio/numaflow-go/map-even-odd:v0.6.1 + image: quay.io/numaio/numaflow-go/map-even-odd:stable - name: keyed-fixed-sum partitions: 1 udf: container: # Compute the sum, see https://github.com/numaproj/numaflow-go/tree/main/pkg/reducer/examples/sum - image: quay.io/numaio/numaflow-go/reduce-sum:v0.6.1 + image: quay.io/numaio/numaflow-go/reduce-sum:stable groupBy: window: fixed: @@ -37,7 +37,7 @@ spec: udf: container: # Compute the sum, see https://github.com/numaproj/numaflow-go/tree/main/pkg/reducer/examples/sum - image: quay.io/numaio/numaflow-go/reduce-sum:v0.6.1 + image: quay.io/numaio/numaflow-go/reduce-sum:stable groupBy: window: fixed: diff --git a/test/reduce-one-e2e/testdata/complex-sliding-window-pipeline.yaml b/test/reduce-one-e2e/testdata/complex-sliding-window-pipeline.yaml index 1e2cfb736f..b1eb36b2d2 100644 --- a/test/reduce-one-e2e/testdata/complex-sliding-window-pipeline.yaml +++ b/test/reduce-one-e2e/testdata/complex-sliding-window-pipeline.yaml @@ -19,13 +19,13 @@ spec: udf: container: # Tell the input number is even or odd, see https://github.com/numaproj/numaflow-go/tree/main/pkg/mapper/examples/even_odd - image: quay.io/numaio/numaflow-go/map-even-odd:v0.6.1 + image: quay.io/numaio/numaflow-go/map-even-odd:stable - name: keyed-fixed-sum partitions: 2 udf: container: # Compute the sum, see https://github.com/numaproj/numaflow-go/tree/main/pkg/reducer/examples/sum - image: quay.io/numaio/numaflow-go/reduce-sum:v0.6.1 + image: quay.io/numaio/numaflow-go/reduce-sum:stable groupBy: window: fixed: @@ -37,7 +37,7 @@ spec: udf: container: # Compute the sum, see https://github.com/numaproj/numaflow-go/tree/main/pkg/reducer/examples/sum - image: quay.io/numaio/numaflow-go/reduce-sum:v0.6.1 + image: quay.io/numaio/numaflow-go/reduce-sum:stable groupBy: window: fixed: @@ -49,7 +49,7 @@ spec: udf: container: # Compute the sum, see https://github.com/numaproj/numaflow-go/tree/main/pkg/reducer/examples/sum - image: quay.io/numaio/numaflow-go/reduce-sum:v0.6.1 + image: quay.io/numaio/numaflow-go/reduce-sum:stable groupBy: window: sliding: diff --git a/test/reduce-one-e2e/testdata/simple-keyed-reduce-pipeline.yaml b/test/reduce-one-e2e/testdata/simple-keyed-reduce-pipeline.yaml index 4cae0ec9de..ea2bf228f2 100644 --- a/test/reduce-one-e2e/testdata/simple-keyed-reduce-pipeline.yaml +++ b/test/reduce-one-e2e/testdata/simple-keyed-reduce-pipeline.yaml @@ -19,13 +19,13 @@ spec: udf: container: # Tell the input number is even or odd, see https://github.com/numaproj/numaflow-go/tree/main/pkg/mapper/examples/even_odd - image: quay.io/numaio/numaflow-go/map-even-odd:v0.6.1 + image: quay.io/numaio/numaflow-go/map-even-odd:stable - name: compute-sum partitions: 1 udf: container: # Compute the sum, see https://github.com/numaproj/numaflow-go/tree/main/pkg/reducer/examples/sum - image: quay.io/numaio/numaflow-go/reduce-sum:v0.6.1 + image: quay.io/numaio/numaflow-go/reduce-sum:stable groupBy: window: fixed: diff --git a/test/reduce-one-e2e/testdata/simple-non-keyed-reduce-pipeline.yaml b/test/reduce-one-e2e/testdata/simple-non-keyed-reduce-pipeline.yaml index f637372b58..502de2dd82 100644 --- a/test/reduce-one-e2e/testdata/simple-non-keyed-reduce-pipeline.yaml +++ b/test/reduce-one-e2e/testdata/simple-non-keyed-reduce-pipeline.yaml @@ -19,12 +19,12 @@ spec: udf: container: # Tell the input number is even or odd, see https://github.com/numaproj/numaflow-go/tree/main/pkg/mapper/examples/even_odd - image: quay.io/numaio/numaflow-go/map-even-odd:v0.6.1 + image: quay.io/numaio/numaflow-go/map-even-odd:stable - name: compute-sum udf: container: # Compute the sum, see https://github.com/numaproj/numaflow-go/tree/main/pkg/reducer/examples/sum - image: quay.io/numaio/numaflow-go/reduce-sum:v0.6.1 + image: quay.io/numaio/numaflow-go/reduce-sum:stable groupBy: window: fixed: diff --git a/test/reduce-one-e2e/testdata/simple-reduce-pipeline-wal.yaml b/test/reduce-one-e2e/testdata/simple-reduce-pipeline-wal.yaml index ae543f3480..8efff22e41 100644 --- a/test/reduce-one-e2e/testdata/simple-reduce-pipeline-wal.yaml +++ b/test/reduce-one-e2e/testdata/simple-reduce-pipeline-wal.yaml @@ -17,13 +17,13 @@ spec: udf: container: # Tell the input number is even or odd, see https://github.com/numaproj/numaflow-go/tree/main/pkg/mapper/examples/even_odd - image: quay.io/numaio/numaflow-go/map-even-odd:v0.6.1 + image: quay.io/numaio/numaflow-go/map-even-odd:stable - name: compute-sum partitions: 2 udf: container: # Compute the sum, see https://github.com/numaproj/numaflow-go/tree/main/pkg/reducer/examples/sum - image: quay.io/numaio/numaflow-go/reduce-sum:v0.6.1 + image: quay.io/numaio/numaflow-go/reduce-sum:stable groupBy: window: fixed: diff --git a/test/reduce-two-e2e/testdata/reduce-stream/reduce-stream-go.yaml b/test/reduce-two-e2e/testdata/reduce-stream/reduce-stream-go.yaml index f567b70774..671ebf6946 100644 --- a/test/reduce-two-e2e/testdata/reduce-stream/reduce-stream-go.yaml +++ b/test/reduce-two-e2e/testdata/reduce-stream/reduce-stream-go.yaml @@ -15,13 +15,13 @@ spec: udf: container: # Tell the input number is even or odd, see https://github.com/numaproj/numaflow-go/tree/main/pkg/mapper/examples/even_odd - image: quay.io/numaio/numaflow-go/map-even-odd:v0.6.1 + image: quay.io/numaio/numaflow-go/map-even-odd:stable - name: compute-sum partitions: 2 udf: container: # compute the sum, see https://github.com/numaproj/numaflow-go/tree/main/pkg/reducestreamer/examples/sum - image: quay.io/numaio/numaflow-go/reduce-stream-sum:v0.6.1 + image: quay.io/numaio/numaflow-go/reduce-stream-sum:stable groupBy: window: fixed: diff --git a/test/reduce-two-e2e/testdata/reduce-stream/reduce-stream-java.yaml b/test/reduce-two-e2e/testdata/reduce-stream/reduce-stream-java.yaml index 476ad996cf..78fb650d2d 100644 --- a/test/reduce-two-e2e/testdata/reduce-stream/reduce-stream-java.yaml +++ b/test/reduce-two-e2e/testdata/reduce-stream/reduce-stream-java.yaml @@ -15,13 +15,13 @@ spec: udf: container: # Tell the input number is even or odd, see https://github.com/numaproj/numaflow-go/tree/main/pkg/mapper/examples/even_odd - image: quay.io/numaio/numaflow-go/map-even-odd:v0.6.1 + image: quay.io/numaio/numaflow-go/map-even-odd:stable - name: compute-sum partitions: 2 udf: container: # compute the sum, see https://github.com/numaproj/numaflow-java/tree/main/examples/src/main/java/io/numaproj/numaflow/examples/reducestreamer/sum - image: quay.io/numaio/numaflow-java/reduce-stream-sum:v0.6.0 + image: quay.io/numaio/numaflow-java/reduce-stream-sum:stable groupBy: window: fixed: diff --git a/test/reduce-two-e2e/testdata/session-reduce/simple-session-keyed-counter-pipeline-go.yaml b/test/reduce-two-e2e/testdata/session-reduce/simple-session-keyed-counter-pipeline-go.yaml index a9709ce6c4..a0314a0ee9 100644 --- a/test/reduce-two-e2e/testdata/session-reduce/simple-session-keyed-counter-pipeline-go.yaml +++ b/test/reduce-two-e2e/testdata/session-reduce/simple-session-keyed-counter-pipeline-go.yaml @@ -16,13 +16,13 @@ spec: min: 1 udf: container: - image: quay.io/numaio/numaflow-go/map-even-odd:v0.6.1 + image: quay.io/numaio/numaflow-go/map-even-odd:stable - name: compute-count partitions: 1 udf: container: # see https://github.com/numaproj/numaflow-go/tree/main/pkg/sessionreducer/examples/counter - image: quay.io/numaio/numaflow-go/session-counter:v0.6.1 + image: quay.io/numaio/numaflow-go/session-counter:stable groupBy: window: session: diff --git a/test/reduce-two-e2e/testdata/session-reduce/simple-session-keyed-counter-pipeline-java.yaml b/test/reduce-two-e2e/testdata/session-reduce/simple-session-keyed-counter-pipeline-java.yaml index 2014b8d8e8..aae2e7d485 100644 --- a/test/reduce-two-e2e/testdata/session-reduce/simple-session-keyed-counter-pipeline-java.yaml +++ b/test/reduce-two-e2e/testdata/session-reduce/simple-session-keyed-counter-pipeline-java.yaml @@ -16,7 +16,7 @@ spec: min: 1 udf: container: - image: quay.io/numaio/numaflow-go/map-even-odd:v0.6.1 + image: quay.io/numaio/numaflow-go/map-even-odd:stable - name: compute-count partitions: 1 udf: diff --git a/test/reduce-two-e2e/testdata/session-reduce/simple-session-sum-pipeline.yaml b/test/reduce-two-e2e/testdata/session-reduce/simple-session-sum-pipeline.yaml index bc12c58fc4..b2cf0c560c 100644 --- a/test/reduce-two-e2e/testdata/session-reduce/simple-session-sum-pipeline.yaml +++ b/test/reduce-two-e2e/testdata/session-reduce/simple-session-sum-pipeline.yaml @@ -16,7 +16,7 @@ spec: udf: container: # see https://github.com/numaproj/numaflow-go/tree/main/pkg/sessionreducer/examples/counter - image: quay.io/numaio/numaflow-go/session-sum:v0.6.1 + image: quay.io/numaio/numaflow-go/session-counter:stable imagePullPolicy: Always groupBy: window: diff --git a/test/sdks-e2e/testdata/flatmap-stream.yaml b/test/sdks-e2e/testdata/flatmap-stream.yaml index 91341fccb5..c329012ce2 100644 --- a/test/sdks-e2e/testdata/flatmap-stream.yaml +++ b/test/sdks-e2e/testdata/flatmap-stream.yaml @@ -19,7 +19,7 @@ spec: udf: container: # Split input message into an array with comma, see https://github.com/numaproj/numaflow-go/tree/main/pkg/mapstreamer/examples/flatmap_stream - image: quay.io/numaio/numaflow-go/map-flatmap-stream:v0.6.1 + image: quay.io/numaio/numaflow-go/map-flatmap-stream:stable - name: go-udsink scale: min: 1 @@ -27,7 +27,7 @@ spec: udsink: container: # https://github.com/numaproj/numaflow-go/tree/main/pkg/sinker/examples/log - image: quay.io/numaio/numaflow-go/sink-log:v0.6.1 + image: quay.io/numaio/numaflow-go/sink-log:stable - name: go-udsink-2 scale: min: 1 @@ -35,7 +35,7 @@ spec: udsink: container: # https://github.com/numaproj/numaflow-go/tree/main/pkg/sinker/examples/log - image: quay.io/numaio/numaflow-go/sink-log:v0.6.1 + image: quay.io/numaio/numaflow-go/sink-log:stable - name: python-split partitions: 3 @@ -52,7 +52,7 @@ spec: - python - example.py # Split input message into an array with comma, https://github.com/numaproj/numaflow-python/tree/main/examples/mapstream/flatmap_stream - image: quay.io/numaio/numaflow-python/map-flatmap-stream:v0.6.0 + image: quay.io/numaio/numaflow-python/map-flatmap-stream:stable - name: python-udsink scale: min: 1 @@ -63,7 +63,7 @@ spec: - python - example.py # https://github.com/numaproj/numaflow-python/tree/main/examples/sink/log - image: quay.io/numaio/numaflow-python/sink-log:v0.6.0 + image: quay.io/numaio/numaflow-python/sink-log:stable - name: java-split partitions: 3 metadata: @@ -76,7 +76,7 @@ spec: udf: container: # Split input message into an array with comma, see https://github.com/numaproj/numaflow-java/tree/main/examples/src/main/java/io/numaproj/numaflow/examples/mapstream/flatmapstream - image: quay.io/numaio/numaflow-java/flat-map-stream:v0.6.0 + image: quay.io/numaio/numaflow-java/flat-map-stream:stable - name: java-udsink scale: min: 1 @@ -84,7 +84,7 @@ spec: udsink: container: # https://github.com/numaproj/numaflow-java/tree/main/examples/src/main/java/io/numaproj/numaflow/examples/sink/simple - image: quay.io/numaio/numaflow-java/simple-sink:v0.6.0 + image: quay.io/numaio/numaflow-java/simple-sink:stable edges: - from: in to: go-split diff --git a/test/sdks-e2e/testdata/flatmap.yaml b/test/sdks-e2e/testdata/flatmap.yaml index 8beb512b6f..7b9025c6d0 100644 --- a/test/sdks-e2e/testdata/flatmap.yaml +++ b/test/sdks-e2e/testdata/flatmap.yaml @@ -13,7 +13,7 @@ spec: udf: container: # Split input message into an array with comma, see https://github.com/numaproj/numaflow-go/tree/main/pkg/mapper/examples/flatmap - image: quay.io/numaio/numaflow-go/map-flatmap:v0.6.1 + image: quay.io/numaio/numaflow-go/map-flatmap:stable - name: go-udsink scale: min: 1 @@ -21,7 +21,7 @@ spec: udsink: container: # https://github.com/numaproj/numaflow-go/tree/main/pkg/sinker/examples/log - image: quay.io/numaio/numaflow-go/sink-log:v0.6.1 + image: quay.io/numaio/numaflow-go/sink-log:stable - name: python-split scale: @@ -32,7 +32,7 @@ spec: - python - example.py # Split input message into an array with comma, https://github.com/numaproj/numaflow-python/tree/main/examples/map/flatmap - image: quay.io/numaio/numaflow-python/map-flatmap:v0.6.0 + image: quay.io/numaio/numaflow-python/map-flatmap:stable - name: python-udsink scale: min: 1 @@ -43,14 +43,14 @@ spec: - python - example.py # https://github.com/numaproj/numaflow-python/tree/main/examples/sink/log - image: quay.io/numaio/numaflow-python/sink-log:v0.6.0 + image: quay.io/numaio/numaflow-python/sink-log:stable - name: java-split scale: min: 1 udf: container: # Split input message into an array with comma, see https://github.com/numaproj/numaflow-java/tree/main/examples/src/main/java/io/numaproj/numaflow/examples/map/flatmap - image: quay.io/numaio/numaflow-java/map-flatmap:v0.6.0 + image: quay.io/numaio/numaflow-java/map-flatmap:stable - name: java-udsink scale: min: 1 @@ -58,7 +58,7 @@ spec: udsink: container: # https://github.com/numaproj/numaflow-java/tree/main/examples/src/main/java/io/numaproj/numaflow/examples/sink/simple - image: quay.io/numaio/numaflow-java/simple-sink:v0.6.0 + image: quay.io/numaio/numaflow-java/simple-sink:stable edges: - from: in to: go-split diff --git a/test/sdks-e2e/testdata/simple-keyed-reduce-pipeline.yaml b/test/sdks-e2e/testdata/simple-keyed-reduce-pipeline.yaml index edf24176c6..be2808d085 100644 --- a/test/sdks-e2e/testdata/simple-keyed-reduce-pipeline.yaml +++ b/test/sdks-e2e/testdata/simple-keyed-reduce-pipeline.yaml @@ -13,13 +13,13 @@ spec: udf: container: # Tell the input number is even or odd, see https://github.com/numaproj/numaflow-java/tree/main/examples/src/main/java/io/numaproj/numaflow/examples/map/evenodd - image: quay.io/numaio/numaflow-java/even-odd:v0.6.0 + image: quay.io/numaio/numaflow-java/even-odd:stable - name: compute-sum partitions: 2 udf: container: # compute the sum, see https://github.com/numaproj/numaflow-java/tree/main/examples/src/main/java/io/numaproj/numaflow/examples/reduce/sum - image: quay.io/numaio/numaflow-java/reduce-sum:v0.6.0 + image: quay.io/numaio/numaflow-java/reduce-sum:stable groupBy: window: fixed: @@ -34,7 +34,7 @@ spec: udsink: container: # https://github.com/numaproj/numaflow-java/tree/main/examples/src/main/java/io/numaproj/numaflow/examples/sink/simple - image: quay.io/numaio/numaflow-java/simple-sink:v0.6.0 + image: quay.io/numaio/numaflow-java/simple-sink:stable edges: - from: in to: atoi diff --git a/test/sdks-e2e/testdata/transformer/event-time-filter-go.yaml b/test/sdks-e2e/testdata/transformer/event-time-filter-go.yaml index 745dd0923a..61b7df521e 100644 --- a/test/sdks-e2e/testdata/transformer/event-time-filter-go.yaml +++ b/test/sdks-e2e/testdata/transformer/event-time-filter-go.yaml @@ -10,7 +10,7 @@ spec: transformer: container: # Filter messages based on event time, see https://github.com/numaproj/numaflow-go/tree/main/pkg/sourcetransformer/examples/event_time_filter - image: quay.io/numaio/numaflow-go/mapt-event-time-filter:v0.6.1 + image: quay.io/numaio/numaflow-go/mapt-event-time-filter:stable - name: sink-within-2022 partitions: 2 scale: diff --git a/test/sdks-e2e/testdata/transformer/event-time-filter-java.yaml b/test/sdks-e2e/testdata/transformer/event-time-filter-java.yaml index bbb6d3ee18..e9f7bd0f5e 100644 --- a/test/sdks-e2e/testdata/transformer/event-time-filter-java.yaml +++ b/test/sdks-e2e/testdata/transformer/event-time-filter-java.yaml @@ -10,7 +10,7 @@ spec: transformer: container: # Filter messages based on event time, see https://github.com/numaproj/numaflow-java/tree/main/examples/src/main/java/io/numaproj/numaflow/examples/sourcetransformer/eventtimefilter - image: quay.io/numaio/numaflow-java/mapt-event-time-filter-function:v0.6.0 + image: quay.io/numaio/numaflow-java/mapt-event-time-filter-function:stable - name: sink-within-2022 scale: min: 1 diff --git a/test/sdks-e2e/testdata/transformer/event-time-filter-python.yaml b/test/sdks-e2e/testdata/transformer/event-time-filter-python.yaml index 7a95db01c0..832caf4e13 100644 --- a/test/sdks-e2e/testdata/transformer/event-time-filter-python.yaml +++ b/test/sdks-e2e/testdata/transformer/event-time-filter-python.yaml @@ -12,7 +12,7 @@ spec: transformer: container: # Filter messages based on event time, see https://github.com/numaproj/numaflow-python/tree/main/examples/sourcetransform/event_time_filter - image: quay.io/numaio/numaflow-python/mapt-event-time-filter:v0.6.0 + image: quay.io/numaio/numaflow-python/mapt-event-time-filter:stable - name: sink-within-2022 scale: min: 1 diff --git a/test/sideinputs-e2e/testdata/reduce-sideinput-pipeline.yaml b/test/sideinputs-e2e/testdata/reduce-sideinput-pipeline.yaml index 02299b79e8..689bbf11c3 100644 --- a/test/sideinputs-e2e/testdata/reduce-sideinput-pipeline.yaml +++ b/test/sideinputs-e2e/testdata/reduce-sideinput-pipeline.yaml @@ -21,7 +21,7 @@ spec: udf: container: # Tell the input number is even or odd, see https://github.com/numaproj/numaflow-go/tree/main/pkg/mapper/examples/even_odd - image: quay.io/numaio/numaflow-go/map-even-odd:v0.6.1 + image: quay.io/numaio/numaflow-go/map-even-odd:stable imagePullPolicy: Always - name: si-e2e udf: diff --git a/test/udsource-e2e/testdata/simple-source-go.yaml b/test/udsource-e2e/testdata/simple-source-go.yaml index d65b4a701e..b0f184916f 100644 --- a/test/udsource-e2e/testdata/simple-source-go.yaml +++ b/test/udsource-e2e/testdata/simple-source-go.yaml @@ -10,7 +10,7 @@ spec: container: # A simple user-defined source for e2e testing # See https://github.com/numaproj/numaflow-go/tree/main/pkg/sourcer/examples/simple_source - image: quay.io/numaio/numaflow-go/source-simple-source:v0.6.1 + image: quay.io/numaio/numaflow-go/source-simple-source:stable limits: readBatchSize: 500 - name: out diff --git a/test/udsource-e2e/testdata/simple-source-java.yaml b/test/udsource-e2e/testdata/simple-source-java.yaml index 5d6182c193..9d30d9413c 100644 --- a/test/udsource-e2e/testdata/simple-source-java.yaml +++ b/test/udsource-e2e/testdata/simple-source-java.yaml @@ -10,7 +10,7 @@ spec: container: # A simple user-defined source for e2e testing # See https://github.com/numaproj/numaflow-java/tree/main/examples/src/main/java/io/numaproj/numaflow/examples/source/simple - image: quay.io/numaio/numaflow-java/source-simple-source:v0.6.0 + image: quay.io/numaio/numaflow-java/source-simple-source:stable limits: readBatchSize: 500 - name: out diff --git a/test/udsource-e2e/testdata/simple-source-python.yaml b/test/udsource-e2e/testdata/simple-source-python.yaml index f0649d0f11..fc3d9f5c60 100644 --- a/test/udsource-e2e/testdata/simple-source-python.yaml +++ b/test/udsource-e2e/testdata/simple-source-python.yaml @@ -10,7 +10,7 @@ spec: container: # A simple user-defined source for e2e testing # See https://github.com/numaproj/numaflow-python/tree/main/examples/source/simple-source - image: quay.io/numaio/numaflow-python/simple-source:v0.6.0 + image: quay.io/numaio/numaflow-python/simple-source:stable imagePullPolicy: Always limits: readBatchSize: 500 From a90550d4d2b02b2dde64c778a0949ce9abcf38cc Mon Sep 17 00:00:00 2001 From: a3hadi Date: Fri, 22 Mar 2024 17:44:32 -0400 Subject: [PATCH 2/2] change back to session-sum Signed-off-by: a3hadi --- .../testdata/session-reduce/simple-session-sum-pipeline.yaml | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/test/reduce-two-e2e/testdata/session-reduce/simple-session-sum-pipeline.yaml b/test/reduce-two-e2e/testdata/session-reduce/simple-session-sum-pipeline.yaml index b2cf0c560c..3cb4b8eeaa 100644 --- a/test/reduce-two-e2e/testdata/session-reduce/simple-session-sum-pipeline.yaml +++ b/test/reduce-two-e2e/testdata/session-reduce/simple-session-sum-pipeline.yaml @@ -15,8 +15,8 @@ spec: partitions: 1 udf: container: - # see https://github.com/numaproj/numaflow-go/tree/main/pkg/sessionreducer/examples/counter - image: quay.io/numaio/numaflow-go/session-counter:stable + # TODO: Once the session-sum example is merged, add link to source code and change tag to stable + image: quay.io/numaio/numaflow-go/session-sum:v0.6.1 imagePullPolicy: Always groupBy: window: