Skip to content

Commit

Permalink
chore: update java e2e test images (#1360)
Browse files Browse the repository at this point in the history
Signed-off-by: Keran Yang <[email protected]>
  • Loading branch information
KeranYang authored Nov 15, 2023
1 parent 691d3a4 commit d39d749
Show file tree
Hide file tree
Showing 4 changed files with 8 additions and 8 deletions.
4 changes: 2 additions & 2 deletions test/sdks-e2e/testdata/flatmap-stream.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -76,15 +76,15 @@ 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.5.2
image: quay.io/numaio/numaflow-java/flat-map-stream:v0.5.6
- name: java-udsink
scale:
min: 1
sink:
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.5.2
image: quay.io/numaio/numaflow-java/simple-sink:v0.5.6
edges:
- from: in
to: go-split
Expand Down
4 changes: 2 additions & 2 deletions test/sdks-e2e/testdata/flatmap.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -50,15 +50,15 @@ 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/map/flatmap
image: quay.io/numaio/numaflow-java/map-flatmap:v0.5.2
image: quay.io/numaio/numaflow-java/map-flatmap:v0.5.6
- name: java-udsink
scale:
min: 1
sink:
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.5.2
image: quay.io/numaio/numaflow-java/simple-sink:v0.5.6
edges:
- from: in
to: go-split
Expand Down
6 changes: 3 additions & 3 deletions test/sdks-e2e/testdata/simple-keyed-reduce-pipeline.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -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.5.2
image: quay.io/numaio/numaflow-java/even-odd:v0.5.6
- 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.5.2
image: quay.io/numaio/numaflow-java/reduce-sum:v0.5.6
groupBy:
window:
fixed:
Expand All @@ -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.5.2
image: quay.io/numaio/numaflow-java/simple-sink:v0.5.6
edges:
- from: in
to: atoi
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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.5.2
image: quay.io/numaio/numaflow-java/mapt-event-time-filter-function:v0.5.6
- name: sink-within-2022
scale:
min: 1
Expand Down

0 comments on commit d39d749

Please sign in to comment.