lhotari opened a new pull request, #15851:
URL: https://github.com/apache/pulsar/pull/15851
Fixes #15850
### Motivation
See #15850 for details.
MultiTopicsConsumerImplTest.testParallelSubscribeAsync is flaky and several
problems were observed in the test. This PR attempts to fix the issues.
### Modifications
- add preProcessSchemaBeforeSubscribe mocking to prevent
`java.lang.NullPointerException: Cannot invoke
"org.apache.pulsar.client.api.Schema.getSchemaInfo()" because "this.schema" is
null` NPEs.
- the timeout in testParallelSubscribeAsync method seems to happen because
testGetStats continues asynchronously in the background. To fix this issue:
- use arbitrary local ip + port for testGetStats (the test doesn't require
a real connection, this should be improved)
- close the resources synchronously in testGetStats method
--
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]
