Description
Testing a pipeline with MQTT Publisher transform.
When I do a preview, the Hop hangs and I have to terminate it.
The error message in the terminal:
2021/03/13 18:01:09 - publish - Executing this pipeline using the Local Pipeline Engine with run configuration 'local'
2021/03/13 18:01:09 - publish - Execution started for pipeline [publish]
2021/03/13 18:01:09 - Generate rows.0 - Finished processing (I=0, O=0, R=0, W=1, U=0, E=0)
2021/03/13 18:01:09 - MQTT Publisher.0 - Connecting to MQTT broker: tcp://localhost:1883 as client 'client_test'
org.apache.hop.core.exception.HopException:
Error connecting to MQTT broker!
Unable to connect to server
at org.apache.hop.pipeline.transforms.mqtt.publisher.MQTTPublisher.configureConnection(MQTTPublisher.java:98)
at org.apache.hop.pipeline.transforms.mqtt.publisher.MQTTPublisher.processRow(MQTTPublisher.java:117)
at org.apache.hop.pipeline.transform.RunThread.run(RunThread.java:60)
at java.lang.Thread.run(Thread.java:748)
Caused by: Unable to connect to server (32103) - java.net.ConnectException: Connection refused (Connection refused)
at org.eclipse.paho.client.mqttv3.internal.TCPNetworkModule.start(TCPNetworkModule.java:79)
at org.eclipse.paho.client.mqttv3.internal.ClientComms$ConnectBG.run(ClientComms.java:650)
... 1 more
Caused by: java.net.ConnectException: Connection refused (Connection refused)
at java.net.PlainSocketImpl.socketConnect(Native Method)
at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:350)
at java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:206)
at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:188)
at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
at java.net.Socket.connect(Socket.java:607)
at org.eclipse.paho.client.mqttv3.internal.TCPNetworkModule.start(TCPNetworkModule.java:70)
... 2 more
2021/03/13 18:01:09 - MQTT Publisher.0 - ERROR: Unexpected error
log4j:WARN No appenders could be found for logger (org.apache.hop.pipeline.Pipeline).
log4j:WARN Please initialize the log4j system properly.
log4j:WARN See http://logging.apache.org/log4j/1.2/faq.html#noconfig for more info.
2021/03/13 18:01:09 - MQTT Publisher.0 - ERROR: org.apache.hop.core.exception.HopException:
2021/03/13 18:01:09 - MQTT Publisher.0 - Error connecting to MQTT broker!
2021/03/13 18:01:09 - MQTT Publisher.0 - Unable to connect to server
2021/03/13 18:01:09 - MQTT Publisher.0 -
2021/03/13 18:01:09 - MQTT Publisher.0 - at org.apache.hop.pipeline.transforms.mqtt.publisher.MQTTPublisher.configureConnection(MQTTPublisher.java:98)
2021/03/13 18:01:09 - MQTT Publisher.0 - at org.apache.hop.pipeline.transforms.mqtt.publisher.MQTTPublisher.processRow(MQTTPublisher.java:117)
2021/03/13 18:01:09 - MQTT Publisher.0 - at org.apache.hop.pipeline.transform.RunThread.run(RunThread.java:60)
2021/03/13 18:01:09 - MQTT Publisher.0 - at java.lang.Thread.run(Thread.java:748)
2021/03/13 18:01:09 - MQTT Publisher.0 - Caused by: Unable to connect to server (32103) - java.net.ConnectException: Connection refused (Connection refused)
2021/03/13 18:01:09 - MQTT Publisher.0 - at org.eclipse.paho.client.mqttv3.internal.TCPNetworkModule.start(TCPNetworkModule.java:79)
2021/03/13 18:01:09 - MQTT Publisher.0 - at org.eclipse.paho.client.mqttv3.internal.ClientComms$ConnectBG.run(ClientComms.java:650)
2021/03/13 18:01:09 - MQTT Publisher.0 - ... 1 more
2021/03/13 18:01:09 - MQTT Publisher.0 - Caused by: java.net.ConnectException: Connection refused (Connection refused)
2021/03/13 18:01:09 - MQTT Publisher.0 - at java.net.PlainSocketImpl.socketConnect(Native Method)
2021/03/13 18:01:09 - MQTT Publisher.0 - at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:350)
2021/03/13 18:01:09 - MQTT Publisher.0 - at java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:206)
2021/03/13 18:01:09 - MQTT Publisher.0 - at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:188)
2021/03/13 18:01:09 - MQTT Publisher.0 - at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
2021/03/13 18:01:09 - MQTT Publisher.0 - at java.net.Socket.connect(Socket.java:607)
2021/03/13 18:01:09 - MQTT Publisher.0 - at org.eclipse.paho.client.mqttv3.internal.TCPNetworkModule.start(TCPNetworkModule.java:70)
2021/03/13 18:01:09 - MQTT Publisher.0 - ... 2 more
2021/03/13 18:01:09 - MQTT Publisher.0 - Finished processing (I=0, O=0, R=1, W=0, U=0, E=1)
2021/03/13 18:01:09 - publish - Pipeline duration : 0.045 seconds [ 0.045" ]
2021/03/13 18:01:09 - publish - ERROR: Errors detected!
I have tested this with:
commit cbf2a306970f27c7fde72e24b053098d7d36aab8
and built it with "mvn clean install"