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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
