{"action":"created","issue":{"url":"https://api.github.com/repos/mattf/spark-streaming-jms/issues/1","labels_url":"https://api.github.com/repos/mattf/spark-streaming-jms/issues/1/labels{/name}","comments_url":"https://api.github.com/repos/mattf/spark-streaming-jms/issues/1/comments","events_url":"https://api.github.com/repos/mattf/spark-streaming-jms/issues/1/events","html_url":"https://github.com/mattf/spark-streaming-jms/issues/1","id":72857029,"number":1,"title":"serialization error w/ JMSEvent","user":{"login":"mattf","id":112653,"avatar_url":"https://avatars.githubusercontent.com/u/112653?v=3","gravatar_id":"","url":"https://api.github.com/users/mattf","html_url":"https://github.com/mattf","followers_url":"https://api.github.com/users/mattf/followers","following_url":"https://api.github.com/users/mattf/following{/other_user}","gists_url":"https://api.github.com/users/mattf/gists{/gist_id}","starred_url":"https://api.github.com/users/mattf/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/mattf/subscriptions","organizations_url":"https://api.github.com/users/mattf/orgs","repos_url":"https://api.github.com/users/mattf/repos","events_url":"https://api.github.com/users/mattf/events{/privacy}","received_events_url":"https://api.github.com/users/mattf/received_events","type":"User","site_admin":false},"labels":[],"state":"open","locked":false,"assignee":null,"milestone":null,"comments":2,"created_at":"2015-05-03T20:00:58Z","updated_at":"2015-05-10T15:28:39Z","closed_at":null,"body":"```\r\n$ spark-submit --jars target/scala-2.10/spark-streaming-jms-assembly-0.0.1.jar example.py\r\n...\r\n15/05/03 19:55:44 WARN NativeCodeLoader: Unable to load native-hadoop library for your platform... using builtin-java classes where applicable\r\n15/05/03 19:55:57 WARN BlockManager: Block input-0-1430682957000 replicated to only 0 peer(s) instead of 1 peers\r\n15/05/03 19:55:57 WARN BlockManager: Block input-0-1430682957200 replicated to only 0 peer(s) instead of 1 peers\r\n15/05/03 19:55:57 WARN BlockManager: Block input-0-1430682957400 replicated to only 0 peer(s) instead of 1 peers\r\n15/05/03 19:56:02 ERROR PythonRDD: Python worker exited unexpectedly (crashed)\r\norg.apache.spark.api.python.PythonException: Traceback (most recent call last):\r\n  File \"/usr/share/spark/python/pyspark/worker.py\", line 90, in main\r\n    command = pickleSer._read_with_length(infile)\r\n  File \"/usr/share/spark/python/pyspark/serializers.py\", line 145, in _read_with_length\r\n    length = read_int(stream)\r\n  File \"/usr/share/spark/python/pyspark/serializers.py\", line 521, in read_int\r\n    raise EOFError\r\nEOFError\r\n\r\n\tat org.apache.spark.api.python.PythonRDD$$anon$1.read(PythonRDD.scala:137)\r\n\tat org.apache.spark.api.python.PythonRDD$$anon$1.<init>(PythonRDD.scala:174)\r\n\tat org.apache.spark.api.python.PythonRDD.compute(PythonRDD.scala:96)\r\n\tat org.apache.spark.rdd.RDD.computeOrReadCheckpoint(RDD.scala:280)\r\n\tat org.apache.spark.rdd.RDD.iterator(RDD.scala:247)\r\n\tat org.apache.spark.api.python.PythonRDD$WriterThread$$anonfun$run$1.apply$mcV$sp(PythonRDD.scala:242)\r\n\tat org.apache.spark.api.python.PythonRDD$WriterThread$$anonfun$run$1.apply(PythonRDD.scala:204)\r\n\tat org.apache.spark.api.python.PythonRDD$WriterThread$$anonfun$run$1.apply(PythonRDD.scala:204)\r\n\tat org.apache.spark.util.Utils$.logUncaughtExceptions(Utils.scala:1550)\r\n\tat org.apache.spark.api.python.PythonRDD$WriterThread.run(PythonRDD.scala:203)\r\nCaused by: org.apache.spark.SparkException: Unexpected element type class com.redhat.spark.streaming.jms.JMSEvent\r\n\tat org.apache.spark.api.python.PythonRDD$.writeIteratorToStream(PythonRDD.scala:420)\r\n\t... 5 more\r\n15/05/03 19:56:02 ERROR PythonRDD: This may have been caused by a prior exception:\r\norg.apache.spark.SparkException: Unexpected element type class com.redhat.spark.streaming.jms.JMSEvent\r\n\tat org.apache.spark.api.python.PythonRDD$.writeIteratorToStream(PythonRDD.scala:420)\r\n\tat org.apache.spark.api.python.PythonRDD$WriterThread$$anonfun$run$1.apply$mcV$sp(PythonRDD.scala:242)\r\n\tat org.apache.spark.api.python.PythonRDD$WriterThread$$anonfun$run$1.apply(PythonRDD.scala:204)\r\n\tat org.apache.spark.api.python.PythonRDD$WriterThread$$anonfun$run$1.apply(PythonRDD.scala:204)\r\n\tat org.apache.spark.util.Utils$.logUncaughtExceptions(Utils.scala:1550)\r\n\tat org.apache.spark.api.python.PythonRDD$WriterThread.run(PythonRDD.scala:203)\r\n```"},"comment":{"url":"https://api.github.com/repos/mattf/spark-streaming-jms/issues/comments/100655764","html_url":"https://github.com/mattf/spark-streaming-jms/issues/1#issuecomment-100655764","issue_url":"https://api.github.com/repos/mattf/spark-streaming-jms/issues/1","id":100655764,"user":{"login":"mattf","id":112653,"avatar_url":"https://avatars.githubusercontent.com/u/112653?v=3","gravatar_id":"","url":"https://api.github.com/users/mattf","html_url":"https://github.com/mattf","followers_url":"https://api.github.com/users/mattf/followers","following_url":"https://api.github.com/users/mattf/following{/other_user}","gists_url":"https://api.github.com/users/mattf/gists{/gist_id}","starred_url":"https://api.github.com/users/mattf/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/mattf/subscriptions","organizations_url":"https://api.github.com/users/mattf/orgs","repos_url":"https://api.github.com/users/mattf/repos","events_url":"https://api.github.com/users/mattf/events{/privacy}","received_events_url":"https://api.github.com/users/mattf/received_events","type":"User","site_admin":false},"created_at":"2015-05-10T15:28:39Z","updated_at":"2015-05-10T15:28:39Z","body":"@andrewor14 do you have any suggestions?"}}