This is an automated email from the ASF dual-hosted git repository.
asalamon74 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/oozie.git
The following commit(s) were added to refs/heads/master by this push:
new fe85373 OOZIE-3658 Fix TestJMSJobEventListener#testConnectionDrop
flakiness again (dionusos via asalamon74)
fe85373 is described below
commit fe85373744db0a056af4db1aa6faf99e257314aa
Author: Andras Salamon <[email protected]>
AuthorDate: Thu Feb 17 12:13:32 2022 +0100
OOZIE-3658 Fix TestJMSJobEventListener#testConnectionDrop flakiness again
(dionusos via asalamon74)
---
.../apache/oozie/jms/TestJMSJobEventListener.java | 24 +++++++++++-----------
release-log.txt | 1 +
2 files changed, 13 insertions(+), 12 deletions(-)
diff --git
a/core/src/test/java/org/apache/oozie/jms/TestJMSJobEventListener.java
b/core/src/test/java/org/apache/oozie/jms/TestJMSJobEventListener.java
index 77be04f..6049990 100644
--- a/core/src/test/java/org/apache/oozie/jms/TestJMSJobEventListener.java
+++ b/core/src/test/java/org/apache/oozie/jms/TestJMSJobEventListener.java
@@ -19,7 +19,6 @@
package org.apache.oozie.jms;
import java.util.Date;
-import java.util.Random;
import javax.jms.MessageConsumer;
import javax.jms.Session;
@@ -36,10 +35,8 @@ import org.apache.oozie.client.event.jms.JMSMessagingUtils;
import org.apache.oozie.client.event.jms.JMSHeaderConstants;
import org.apache.oozie.client.event.message.CoordinatorActionMessage;
import org.apache.oozie.client.event.message.WorkflowJobMessage;
-import org.apache.oozie.event.*;
-import org.apache.oozie.jms.ConnectionContext;
-import org.apache.oozie.jms.JMSConnectionInfo;
-import org.apache.oozie.jms.JMSJobEventListener;
+import org.apache.oozie.event.CoordinatorActionEvent;
+import org.apache.oozie.event.WorkflowJobEvent;
import org.apache.oozie.service.JMSAccessorService;
import org.apache.oozie.service.JMSTopicService;
import org.apache.oozie.service.Services;
@@ -269,7 +266,6 @@ public class TestJMSJobEventListener extends XTestCase {
@Test
public void testConnectionDrop() throws Exception {
- Random random = new Random();
BrokerService broker = null;
try {
services.destroy();
@@ -277,17 +273,18 @@ public class TestJMSJobEventListener extends XTestCase {
Configuration conf = services.getConf();
conf.set(Services.CONF_SERVICE_EXT_CLASSES,
JMSAccessorService.class.getName() + ","
+ JMSTopicService.class.getName());
- int randomPort = 30000 + random.nextInt(10000);
- String brokerURl = "tcp://localhost:" + randomPort;
+ services.init();
+ broker = new BrokerService();
+ broker.setDataDirectory(getTestCaseDir());
+ broker.addConnector("tcp://localhost:0");
+ assertFalse("There must be at least one transport connector
initialised.",
+ broker.getTransportConnectors().isEmpty());
+ String brokerURl =
broker.getTransportConnectors().get(0).getConnectUri().toString();
conf.set(JMSJobEventListener.JMS_CONNECTION_PROPERTIES,
"java.naming.factory.initial#"
+ ActiveMQConnFactory + ";" + "java.naming.provider.url#"
+ brokerURl + ";connectionFactoryNames#"
+ "ConnectionFactory");
- services.init();
JMSJobEventListener wfEventListener = new JMSJobEventListener();
wfEventListener.init(conf);
- broker = new BrokerService();
- broker.setDataDirectory(getTestCaseDir());
- broker.addConnector(brokerURl);
broker.setUseJmx(false);
broker.start();
ConnectionContext jmsContext = getConnectionContext();
@@ -296,11 +293,14 @@ public class TestJMSJobEventListener extends XTestCase {
jmsContext = getConnectionContext();
// Exception Listener should have removed the old conn context
assertNull(jmsContext);
+
+ // Re-start broker using the former endpoint
broker = new BrokerService();
broker.setDataDirectory(getTestCaseDir());
broker.addConnector(brokerURl);
broker.setUseJmx(false);
broker.start();
+
WorkflowJobEvent wfe = new WorkflowJobEvent("wfId1", "caId1",
WorkflowJob.Status.FAILED, "user1",
"wf-app-name1", new Date(), new Date());
diff --git a/release-log.txt b/release-log.txt
index 220f21c..db84383 100644
--- a/release-log.txt
+++ b/release-log.txt
@@ -1,5 +1,6 @@
-- Oozie 5.3.0 release (trunk - unreleased)
+OOZIE-3658 Fix TestJMSJobEventListener#testConnectionDrop flakiness again
(dionusos via asalamon74)
OOZIE-3646 Possible dead-lock in SignalXCommand (zuston via dionusos)
OOZIE-3652 Oozie launcher should retry directory listing when
NoSuchFileException occurs (aajisaka via dionusos)
OOZIE-3655 upgrade jdom to jdom2 2.0.6.1 (pj.fanning via dionusos)
