[
https://issues.apache.org/jira/browse/SPARK-4631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14296232#comment-14296232
]
Ye Xianjin commented on SPARK-4631:
-----------------------------------
Hi [~dragos], I have the same issue here. I'd like to copy the email I sent to
Sean here, which may help.
{quote}
Hi Sean:
I enabled the debug flag in log4j. I believe the MQRRStreamSuite failure is
more likely due to some weird network issue. However I cannot understand why
this exception will be thrown.
what I saw in the unit-tests.log is below:
15/01/28 23:41:37.390 ActiveMQ Transport: tcp:///127.0.0.1:53845@23456 DEBUG
Transport: Transport Connection to: tcp://127.0.0.1:53845 failed:
java.net.ProtocolException: Invalid CONNECT encoding
java.net.ProtocolException: Invalid CONNECT encoding
at org.fusesource.mqtt.codec.CONNECT.decode(CONNECT.java:77)
at
org.apache.activemq.transport.mqtt.MQTTProtocolConverter.onMQTTCommand(MQTTProtocolConverter.java:118)
at
org.apache.activemq.transport.mqtt.MQTTTransportFilter.onCommand(MQTTTransportFilter.java:74)
at
org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83)
at
org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:222)
at
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:204)
at java.lang.Thread.run(Thread.java:695)
However when I looked at the code
http://grepcode.com/file/repo1.maven.org/maven2/org.fusesource.mqtt-client/mqtt-client/1.3/org/fusesource/mqtt/codec/CONNECT.java#76
, I don’t quite understand why that would happen.
I am not familiar with activemq, maybe you can look at this and figure what
really happened.
{quote}
The possible cause for that failure is that maybe org.eclipse.paho.mqtt-client
don't write PROTOCOL_NAME in the mqtt frame with a quick look at the
paho.mqtt-client code. But it don't make sense as the Jenkins run test
successfully and I am not sure.
> Add real unit test for MQTT
> ----------------------------
>
> Key: SPARK-4631
> URL: https://issues.apache.org/jira/browse/SPARK-4631
> Project: Spark
> Issue Type: Test
> Components: Streaming
> Reporter: Tathagata Das
> Priority: Critical
> Fix For: 1.3.0
>
>
> A real unit test that actually transfers data to ensure that the MQTTUtil is
> functional
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscr...@spark.apache.org
For additional commands, e-mail: issues-h...@spark.apache.org
