[jira] [Resolved] (BEAM-7111) apache_beam.examples.wordcount_it_test.WordCountIT: failure in streaming mode (postcommit)

["Pablo Estrada (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/BEAM-7111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Pablo Estrada resolved BEAM-7111.
---------------------------------
       Resolution: Fixed
    Fix Version/s: 2.13.0

> apache_beam.examples.wordcount_it_test.WordCountIT: failure in streaming mode (postcommit)
> ------------------------------------------------------------------------------------------
>
>                 Key: BEAM-7111
>                 URL: https://issues.apache.org/jira/browse/BEAM-7111
>             Project: Beam
>          Issue Type: Bug
>          Components: sdk-py-core
>            Reporter: Udi Meiri
>            Assignee: Pablo Estrada
>            Priority: Major
>             Fix For: 2.13.0
>
>
> $ ./scripts/run_integration_test.sh --runner TestDirectRunner --streaming true --test_opts --tests=apache_beam.examples.wordcount_it_test:WordCountIT.test_wordcount_it
> /usr/local/google/home/ehudm/virtualenvs/beamenv/local/lib/python2.7/site-packages/setuptools/dist.py:475: UserWarning: Normalizing '2.13.0.dev' to '2.13.0.dev0'
>   normalized_version,
> warning: no files found matching 'README.md'
> warning: no files found matching 'NOTICE'
> warning: no files found matching 'LICENSE'
> warning: cmd: standard file not found: should have one of README, README.rst, README.txt, README.md
> >>> RUNNING integration tests with pipeline options: --runner=TestDirectRunner --project=apache-beam-testing --staging_location=gs://temp-storage-for-end-to-end-tests/staging-it --temp_location=gs://temp-storage-for-end-to-end-tests/temp-it --output=gs://temp-storage-for-end-to-end-tests/py-it-cloud/output --sdk_location=dist/apache-beam-2.13.0.dev0.tar.gz --requirements_file=postcommit_requirements.txt --num_workers=1 --sleep_secs=20 --streaming --kms_key_name=projects/apache-beam-testing/locations/global/keyRings/beam-it/cryptoKeys/test --dataflow_kms_key=projects/apache-beam-testing/locations/global/keyRings/beam-it/cryptoKeys/test
> >>>   test options: --tests=apache_beam.examples.wordcount_it_test:WordCountIT.test_wordcount_it
> /usr/local/google/home/ehudm/virtualenvs/beamenv/local/lib/python2.7/site-packages/setuptools/dist.py:475: UserWarning: Normalizing '2.13.0.dev' to '2.13.0.dev0'
>   normalized_version,
> running nosetests
> running egg_info
> writing requirements to apache_beam.egg-info/requires.txt
> writing apache_beam.egg-info/PKG-INFO
> writing top-level names to apache_beam.egg-info/top_level.txt
> writing dependency_links to apache_beam.egg-info/dependency_links.txt
> writing entry points to apache_beam.egg-info/entry_points.txt
> reading manifest file 'apache_beam.egg-info/SOURCES.txt'
> reading manifest template 'MANIFEST.in'
> warning: no files found matching 'README.md'
> warning: no files found matching 'NOTICE'
> warning: no files found matching 'LICENSE'
> writing manifest file 'apache_beam.egg-info/SOURCES.txt'
> test_wordcount_it (apache_beam.examples.wordcount_it_test.WordCountIT) ... FAIL
> ======================================================================
> FAIL: test_wordcount_it (apache_beam.examples.wordcount_it_test.WordCountIT)
> ----------------------------------------------------------------------
> Traceback (most recent call last):
>   File "/usr/local/google/home/ehudm/src/beam/sdks/python/apache_beam/examples/wordcount_it_test.py", line 47, in test_wordcount_it
>     self._run_wordcount_it(wordcount.run)
>   File "/usr/local/google/home/ehudm/src/beam/sdks/python/apache_beam/examples/wordcount_it_test.py", line 75, in _run_wordcount_it
>     run_wordcount(test_pipeline.get_full_options_as_args(**extra_opts))
>   File "/usr/local/google/home/ehudm/src/beam/sdks/python/apache_beam/examples/wordcount.py", line 114, in run
>     result = p.run()
>   File "/usr/local/google/home/ehudm/src/beam/sdks/python/apache_beam/pipeline.py", line 406, in run
>     self._options).run(False)
>   File "/usr/local/google/home/ehudm/src/beam/sdks/python/apache_beam/pipeline.py", line 419, in run
>     return self.runner.run_pipeline(self, self._options)
>   File "/usr/local/google/home/ehudm/src/beam/sdks/python/apache_beam/runners/direct/test_direct_runner.py", line 51, in run_pipeline
>     hc_assert_that(self.result, pickler.loads(on_success_matcher))
> AssertionError: 
> Expected: (Test pipeline expected terminated in state: DONE and Expected checksum is 33535a832b7db6d78389759577d4ff495980b9c0)
>      but: Test pipeline expected terminated in state: DONE Test pipeline job terminated in state: RUNNING
> -------------------- >> begin captured logging << --------------------
> root: INFO: Generating grammar tables from /usr/lib/python2.7/lib2to3/Grammar.txt
> root: INFO: Generating grammar tables from /usr/lib/python2.7/lib2to3/PatternGrammar.txt
> root: DEBUG: Connecting using Google Application Default Credentials.
> oauth2client.transport: INFO: Attempting refresh to obtain initial access_token
> oauth2client.client: INFO: Refreshing access_token
> root: DEBUG: Connecting using Google Application Default Credentials.
> oauth2client.transport: INFO: Attempting refresh to obtain initial access_token
> oauth2client.client: INFO: Refreshing access_token
> apache_beam.io.filesystem: DEBUG: translate_pattern: 'gs://dataflow-samples/shakespeare/kinglear.txt' -> 'gs\\:\\/\\/dataflow\\-samples\\/shakespeare\\/kinglear\\.txt'
> root: INFO: Running pipeline with DirectRunner.
> --------------------- >> end captured logging << ---------------------
> ----------------------------------------------------------------------
> XML: /usr/local/google/home/ehudm/src/beam/sdks/python/nosetests.xml
> ----------------------------------------------------------------------
> Ran 1 test in 1.069s
> FAILED (failures=1)



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)