You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@metron.apache.org by ni...@apache.org on 2019/09/12 13:58:14 UTC
[metron] branch feature/METRON-2088-support-hdp-3.1 updated:
METRON-2252 PcapTopologyIntegrationTest Intermittent Failures (nickwallen)
closes apache/metron#1508
This is an automated email from the ASF dual-hosted git repository.
nickallen pushed a commit to branch feature/METRON-2088-support-hdp-3.1
in repository https://gitbox.apache.org/repos/asf/metron.git
The following commit(s) were added to refs/heads/feature/METRON-2088-support-hdp-3.1 by this push:
new b25f9a5 METRON-2252 PcapTopologyIntegrationTest Intermittent Failures (nickwallen) closes apache/metron#1508
b25f9a5 is described below
commit b25f9a52d3186d72d1e3000f1e608e57b294c10a
Author: nickwallen <ni...@nickallen.org>
AuthorDate: Thu Sep 12 09:57:22 2019 -0400
METRON-2252 PcapTopologyIntegrationTest Intermittent Failures (nickwallen) closes apache/metron#1508
---
.../src/main/java/org/apache/metron/integration/utils/KafkaUtil.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git a/metron-platform/metron-integration-test/src/main/java/org/apache/metron/integration/utils/KafkaUtil.java b/metron-platform/metron-integration-test/src/main/java/org/apache/metron/integration/utils/KafkaUtil.java
index 0292808..f9271aa 100644
--- a/metron-platform/metron-integration-test/src/main/java/org/apache/metron/integration/utils/KafkaUtil.java
+++ b/metron-platform/metron-integration-test/src/main/java/org/apache/metron/integration/utils/KafkaUtil.java
@@ -36,6 +36,7 @@ public class KafkaUtil {
Thread.sleep(sleepBetween);
}
}
+ // wait for all messages to be sent
+ producer.flush();
}
-
}