[
https://issues.apache.org/jira/browse/BEAM-10752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17180165#comment-17180165
]
Brian Hulette commented on BEAM-10752:
--------------------------------------
Spoke with Luke about this offline. He pointed out that with the deprecated
reader, the DirectRunner would setup the unbounded reader so this race
condition wasn't a problem. This is no longer the case with SDF, so we'll need
to either reference pubsub subscriptions in our tests (not possible in SQL
yet), or use a TestPubsubSignal to make sure the pipeline has started before
injecting data.
> [beam_PostCommit_SQL] PubsubToBigqueryIT.testSimpleInsert failed
> ----------------------------------------------------------------
>
> Key: BEAM-10752
> URL: https://issues.apache.org/jira/browse/BEAM-10752
> Project: Beam
> Issue Type: Bug
> Components: dsl-sql, test-failures
> Reporter: Robin Qiu
> Assignee: Brian Hulette
> Priority: P1
> Labels: currently-failing
> Time Spent: 50m
> Remaining Estimate: 0h
>
> java.lang.AssertionError: Expected: iterable with items [<Row:[3, foo]>,
> <Row:[5, bar]>, <Row:[7, baz]>] in any order but: no item matches: <Row:[3,
> foo]>, <Row:[5, bar]>, <Row:[7, baz]> in []
> [https://ci-beam.apache.org/job/beam_PostCommit_SQL/5208/testReport/junit/org.apache.beam.sdk.extensions.sql/PubsubToBigqueryIT/testSimpleInsert/]
>
> This happened after https://issues.apache.org/jira/browse/BEAM-10716
> Maybe the pubsub subscription is accidentally deleted? Brian could you please
> take a look?
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
