[
https://issues.apache.org/jira/browse/BEAM-10752?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17180712#comment-17180712
]
Luke Cwik commented on BEAM-10752:
----------------------------------
Brian updated the code to use a TestPubsubSignal which will work most of the
time but is still flawed since there is no guarantee that the SDF will have
executed once and created the subscription before the signal has been executed.
Moving to a model where we only publish messages once a subscriber has been
detected would solve this problem for good and simplify the implementation.
> [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: 2h 20m
> 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)
