diff --git a/examples/10-cycle-to-prev.yaml b/examples/10-cycle-to-prev.yaml index 4fa1578ec1..ee0e9e557e 100644 --- a/examples/10-cycle-to-prev.yaml +++ b/examples/10-cycle-to-prev.yaml @@ -19,7 +19,7 @@ spec: 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 # (a more realistic example might retry only on failure) - image: quay.io/numaio/numaflow-go/map-retry:v0.7.0 + image: quay.io/numaio/numaflow-go/map-retry:stable - name: out scale: min: 1 diff --git a/examples/10-cycle-to-self.yaml b/examples/10-cycle-to-self.yaml index 01e4376e81..48b51d7610 100644 --- a/examples/10-cycle-to-self.yaml +++ b/examples/10-cycle-to-self.yaml @@ -15,7 +15,7 @@ spec: 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 # (a more realistic example might retry only on failure) - image: quay.io/numaio/numaflow-go/map-retry:v0.7.0 + image: quay.io/numaio/numaflow-go/map-retry:stable - name: out scale: min: 1 diff --git a/examples/11-join-on-reduce.yaml b/examples/11-join-on-reduce.yaml index b8626161db..a6f5ccc04f 100644 --- a/examples/11-join-on-reduce.yaml +++ b/examples/11-join-on-reduce.yaml @@ -20,7 +20,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.7.0 + image: quay.io/numaio/numaflow-go/reduce-sum:stable groupBy: window: fixed: diff --git a/examples/11-join-on-sink.yaml b/examples/11-join-on-sink.yaml index 80c01fe445..d5afcec5ef 100644 --- a/examples/11-join-on-sink.yaml +++ b/examples/11-join-on-sink.yaml @@ -13,7 +13,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.7.0 + image: quay.io/numaio/numaflow-go/map-even-odd:stable - name: even-cat udf: builtin: diff --git a/examples/12-simple-session-pipeline.yaml b/examples/12-simple-session-pipeline.yaml index 1b286e3a59..c981c66705 100644 --- a/examples/12-simple-session-pipeline.yaml +++ b/examples/12-simple-session-pipeline.yaml @@ -16,7 +16,7 @@ spec: min: 1 udf: container: - image: quay.io/numaio/numaflow-go/map-even-odd:v0.7.0-rc1 + image: quay.io/numaio/numaflow-go/map-even-odd:stable imagePullPolicy: Always - name: compute-count partitions: 1 @@ -24,7 +24,7 @@ spec: container: # see https://github.com/numaproj/numaflow-go/tree/main/pkg/sessionreducer/examples/counter # computes the count of even numbers and odd numbers in a session - image: quay.io/numaio/numaflow-go/session-counter:v0.7.0-rc1 + image: quay.io/numaio/numaflow-go/session-counter:stable imagePullPolicy: Always groupBy: window: diff --git a/examples/13-streaming-reduce-pipeline.yaml b/examples/13-streaming-reduce-pipeline.yaml index bdd6811888..9a03c3b454 100644 --- a/examples/13-streaming-reduce-pipeline.yaml +++ b/examples/13-streaming-reduce-pipeline.yaml @@ -15,7 +15,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.7.0-rc1 + image: quay.io/numaio/numaflow-go/map-even-odd:stable imagePullPolicy: Always - name: compute-sum partitions: 2 @@ -23,7 +23,7 @@ spec: container: # compute the sum, see https://github.com/numaproj/numaflow-go/tree/main/pkg/reducestreamer/examples/sum # Writes output to next vertex if the sum is greater than 100, does not wait for the window to close. - image: quay.io/numaio/numaflow-go/reduce-stream-sum:v0.7.0-rc1 + image: quay.io/numaio/numaflow-go/reduce-stream-sum:stable imagePullPolicy: Always groupBy: window: diff --git a/examples/14-simple-fallback-pipeline.yaml b/examples/14-simple-fallback-pipeline.yaml index 9687f83fea..efcc88f6e5 100644 --- a/examples/14-simple-fallback-pipeline.yaml +++ b/examples/14-simple-fallback-pipeline.yaml @@ -22,12 +22,12 @@ spec: sink: udsink: container: - image: quay.io/numaio/numaflow-go/fb-sink-log:v0.7.0 + image: quay.io/numaio/numaflow-go/fb-sink-log:stable imagePullPolicy: Always fallback: udsink: container: - image: quay.io/numaio/numaflow-go/fb-sink-log:v0.7.0 + image: quay.io/numaio/numaflow-go/fb-sink-log:stable edges: - from: in to: cat diff --git a/examples/2-even-odd-pipeline.yaml b/examples/2-even-odd-pipeline.yaml index 8f235e5564..81bd1a996d 100644 --- a/examples/2-even-odd-pipeline.yaml +++ b/examples/2-even-odd-pipeline.yaml @@ -13,7 +13,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.7.0 + image: quay.io/numaio/numaflow-go/map-even-odd:stable - name: even-sink scale: min: 1 diff --git a/examples/6-reduce-fixed-window-with-pvc.yaml b/examples/6-reduce-fixed-window-with-pvc.yaml index 4d3776f850..3d027dc8f9 100644 --- a/examples/6-reduce-fixed-window-with-pvc.yaml +++ b/examples/6-reduce-fixed-window-with-pvc.yaml @@ -15,12 +15,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.7.0 + image: quay.io/numaio/numaflow-go/map-even-odd:stable - name: compute-sum udf: container: # compute the sum - image: quay.io/numaio/numaflow-go/reduce-sum:v0.7.0 + image: quay.io/numaio/numaflow-go/reduce-sum:stable groupBy: window: fixed: diff --git a/examples/6-reduce-fixed-window.yaml b/examples/6-reduce-fixed-window.yaml index d14023835f..2a46c7a1fb 100644 --- a/examples/6-reduce-fixed-window.yaml +++ b/examples/6-reduce-fixed-window.yaml @@ -13,12 +13,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.7.0 + image: quay.io/numaio/numaflow-go/map-even-odd:stable - name: compute-sum udf: container: # compute the sum - image: quay.io/numaio/numaflow-go/reduce-sum:v0.7.0 + image: quay.io/numaio/numaflow-go/reduce-sum:stable groupBy: window: fixed: diff --git a/examples/7-reduce-sliding-window.yaml b/examples/7-reduce-sliding-window.yaml index d46840fc12..d0d05f8eb1 100644 --- a/examples/7-reduce-sliding-window.yaml +++ b/examples/7-reduce-sliding-window.yaml @@ -24,13 +24,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.7.0 + image: quay.io/numaio/numaflow-go/map-even-odd:stable - name: reduce-sliding partitions: 2 udf: container: # compute the sum - image: quay.io/numaio/numaflow-go/reduce-sum:v0.7.0 + image: quay.io/numaio/numaflow-go/reduce-sum:stable groupBy: window: sliding: @@ -57,4 +57,4 @@ spec: - from: map to: reduce-sliding - from: reduce-sliding - to: sink \ No newline at end of file + to: sink diff --git a/examples/8-reduce-complex-pipeline.yaml b/examples/8-reduce-complex-pipeline.yaml index 7ff9eb4731..0d77c5088b 100644 --- a/examples/8-reduce-complex-pipeline.yaml +++ b/examples/8-reduce-complex-pipeline.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/function/examples/evenodd - image: quay.io/numaio/numaflow-go/map-even-odd:v0.7.0 + image: quay.io/numaio/numaflow-go/map-even-odd:stable - name: keyed-fixed-sum partitions: 2 udf: container: # compute the sum - image: quay.io/numaio/numaflow-go/reduce-sum:v0.7.0 + image: quay.io/numaio/numaflow-go/reduce-sum:stable groupBy: window: fixed: @@ -37,7 +37,7 @@ spec: udf: container: # compute the sum - image: quay.io/numaio/numaflow-go/reduce-sum:v0.7.0 + image: quay.io/numaio/numaflow-go/reduce-sum:stable groupBy: window: fixed: @@ -51,7 +51,7 @@ spec: udf: container: # compute the sum - image: quay.io/numaio/numaflow-go/reduce-sum:v0.7.0 + image: quay.io/numaio/numaflow-go/reduce-sum:stable groupBy: window: sliding: