You are viewing a plain text version of this content. The canonical link for it is here.
Posted to github@beam.apache.org by GitBox <gi...@apache.org> on 2022/12/07 03:16:47 UTC
[GitHub] [beam] Darkells opened a new issue, #24556: [Failing Test]: Access to the PUBSUB unit test error
Darkells opened a new issue, #24556:
URL: https://github.com/apache/beam/issues/24556
### What happened?
My scene is to access PUBSUB as data source
`
pipeline.apply("readpubsub", PubsubIO.readMessageWithMessageId().fromSubscription(sriptionid))...
`
Just as the unit test case is written, it is also injected into the Pubsubmessage object, but an error is reported
junit test code:
`
PubsubMessage pubsubMessage = Mockito.mock(PubsubMessage.class);
....
PCollection<String> out = pipeline.apply("input", Create.of(pubsubMessage)).apply(....)
`
error: Unable to infer a coder and no Coder was specified.
I want to know how to set the coder about how to set the custom object pipeline
### Issue Failure
Failure: Test is flaky
### Issue Priority
Priority: 3
### Issue Component
Component: beam-community
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: github-unsubscribe@beam.apache.org.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [beam] kennknowles commented on issue #24556: [Failing Test]: Access to the PUBSUB unit test error
Posted by GitBox <gi...@apache.org>.
kennknowles commented on issue #24556:
URL: https://github.com/apache/beam/issues/24556#issuecomment-1343182440
Can you provide more information about which coder failed to be inferred? From what you have provided, I cannot guess at the problem.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: github-unsubscribe@beam.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [beam] Darkells commented on issue #24556: [Failing Test]: Access to the PUBSUB unit test error
Posted by GitBox <gi...@apache.org>.
Darkells commented on issue #24556:
URL: https://github.com/apache/beam/issues/24556#issuecomment-1340463592
Maybe I don't need to mock the pubsubMessage object, but there is a new bug, I found that the messageId will be lost during the corresponding processing, even though I have initialized the messageId, it is still null
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: github-unsubscribe@beam.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org