This is an automated email from the ASF dual-hosted git repository.
orpiske pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/master by this push:
new b727649 Fix not waiting for the compaction completeness on Pulsar
tests (#4713)
b727649 is described below
commit b7276494a13f13635084f24bc9bb4b996d0c3cb1
Author: Otavio Rodolfo Piske <[email protected]>
AuthorDate: Thu Dec 3 12:01:52 2020 +0100
Fix not waiting for the compaction completeness on Pulsar tests (#4713)
---
.../apache/camel/component/pulsar/PulsarConsumerReadCompactedTest.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/PulsarConsumerReadCompactedTest.java
b/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/PulsarConsumerReadCompactedTest.java
index e80e64a..39be95e 100644
---
a/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/PulsarConsumerReadCompactedTest.java
+++
b/components/camel-pulsar/src/test/java/org/apache/camel/component/pulsar/PulsarConsumerReadCompactedTest.java
@@ -99,7 +99,7 @@ public class PulsarConsumerReadCompactedTest extends
PulsarTestSupport {
final Topics topics = givenPulsarAdmin().topics();
topics.triggerCompaction(TOPIC_URI);
- while
(!topics.compactionStatus(TOPIC_URI).status.equals(LongRunningProcessStatus.Status.RUNNING))
{
+ while
(topics.compactionStatus(TOPIC_URI).status.equals(LongRunningProcessStatus.Status.RUNNING))
{
LOGGER.info("Waiting for compaction completeness...");
Uninterruptibles.sleepUninterruptibly(1, TimeUnit.SECONDS);
}