This is an automated email from the ASF dual-hosted git repository. yhu pushed a commit to branch revert-26554-bumpMore in repository https://gitbox.apache.org/repos/asf/beam.git
commit 8b58497d6bd8786456a8ff229f129c7c3d16d1d4 Author: Yi Hu <[email protected]> AuthorDate: Tue May 16 12:41:38 2023 -0400 Revert "Increase streaming wordcount IT timeout again (#26554)" This reverts commit fdc489f2f09cc2f2865f50ea8c886a98da2e32fc. --- sdks/python/apache_beam/examples/streaming_wordcount_it_test.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/sdks/python/apache_beam/examples/streaming_wordcount_it_test.py b/sdks/python/apache_beam/examples/streaming_wordcount_it_test.py index 492b3ca02eb..3a2938e20cd 100644 --- a/sdks/python/apache_beam/examples/streaming_wordcount_it_test.py +++ b/sdks/python/apache_beam/examples/streaming_wordcount_it_test.py @@ -53,7 +53,7 @@ INPUT_SUB = 'wc_subscription_input' OUTPUT_SUB = 'wc_subscription_output' DEFAULT_INPUT_NUMBERS = 500 -WAIT_UNTIL_FINISH_DURATION = 15 * 60 * 1000 # in milliseconds +WAIT_UNTIL_FINISH_DURATION = 10 * 60 * 1000 # in milliseconds class StreamingWordCountIT(unittest.TestCase):
