[
https://issues.apache.org/jira/browse/BEAM-7181?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16830084#comment-16830084
]
Juta Staes commented on BEAM-7181:
----------------------------------
cc: [~tvalentyn] [~frederik]
> Python 3.6 IT tests: PubSub Expected 2 messages. Got 0 messages.
> ----------------------------------------------------------------
>
> Key: BEAM-7181
> URL: https://issues.apache.org/jira/browse/BEAM-7181
> Project: Beam
> Issue Type: Sub-task
> Components: sdk-py-core
> Reporter: Juta Staes
> Priority: Minor
>
> Several test fail in the
> beam-sdks-python-test-suites-dataflow-py36:postCommitIT with the following
> error
> *19:13:05*
> ======================================================================*19:13:05*
> FAIL: test_streaming_data_only
> (apache_beam.io.gcp.pubsub_integration_test.PubSubIntegrationTest)*19:13:05*
> ----------------------------------------------------------------------*19:13:05*
> Traceback (most recent call last):*19:13:05* File
> "/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Python3_Verify_PR/src/sdks/python/apache_beam/io/gcp/pubsub_integration_test.py",
> line 175, in test_streaming_data_only*19:13:05*
> self._test_streaming(with_attributes=False)*19:13:05* File
> "/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Python3_Verify_PR/src/sdks/python/apache_beam/io/gcp/pubsub_integration_test.py",
> line 171, in _test_streaming*19:13:05*
> timestamp_attribute=self.TIMESTAMP_ATTRIBUTE)*19:13:05* File
> "/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Python3_Verify_PR/src/sdks/python/apache_beam/io/gcp/pubsub_it_pipeline.py",
> line 91, in run_pipeline*19:13:05* result = p.run()*19:13:05* File
> "/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Python3_Verify_PR/src/sdks/python/apache_beam/pipeline.py",
> line 419, in run*19:13:05* return self.runner.run_pipeline(self,
> self._options)*19:13:05* File
> "/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Python3_Verify_PR/src/sdks/python/apache_beam/runners/dataflow/test_dataflow_runner.py",
> line 68, in run_pipeline*19:13:05* hc_assert_that(self.result,
> pickler.loads(on_success_matcher))*19:13:05* AssertionError: *19:13:05*
> Expected: (Test pipeline expected terminated in state: RUNNING and Expected 2
> messages.)*19:13:05* but: Expected 2 messages. Got 0 messages. Diffs
> (item, count):*19:13:05* Expected but not in actual:
> dict_items([('data001-seen', 1), ('data002-seen', 1)])*19:13:05*
> Unexpected: dict_items([])
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
