diff --git a/.ci/tests/integration/cases/logging-window-function/manifests.yaml b/.ci/tests/integration/cases/logging-window-function/manifests.yaml index 0d6b77f8..d030c826 100644 --- a/.ci/tests/integration/cases/logging-window-function/manifests.yaml +++ b/.ci/tests/integration/cases/logging-window-function/manifests.yaml @@ -36,7 +36,7 @@ spec: windowConfig: windowLengthCount: 10 slidingIntervalCount: 5 - processingGuarantee: ATLEAST_ONCE + processingGuarantees: ATLEAST_ONCE # the processingGuarantee should be manual for window function # see: https://github.com/apache/pulsar/pull/16279/files#diff-c77c024ccb31c94a7aa80cb8e96d7e370709157bdc104a1be7867fb6c7aa0586R318-R319 processingGuarantee: manual diff --git a/.ci/tests/integration/cases/logging-window-function/verify.sh b/.ci/tests/integration/cases/logging-window-function/verify.sh index a302342e..e31286cf 100644 --- a/.ci/tests/integration/cases/logging-window-function/verify.sh +++ b/.ci/tests/integration/cases/logging-window-function/verify.sh @@ -44,7 +44,7 @@ if [ $? -ne 0 ]; then fi # verify the `processingGuarantees` config -kubectl logs window-function-sample | grep processingGuarantees=ATLEAST_ONCE +kubectl logs window-function-sample-function-0 | grep processingGuarantees=ATLEAST_ONCE if [ $? -ne 0 ]; then kubectl delete -f "${manifests_file}" > /dev/null 2>&1 || true exit 1