Uploaded image for project: 'Spark'
  1. Spark
  2. SPARK-3449

Akka-based receiver can't find messages defined in uploaded jar

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Closed
    • Priority: Major
    • Resolution: Won't Fix
    • Affects Version/s: 1.0.0, 1.0.2
    • Fix Version/s: None
    • Component/s: DStreams
    • Labels:
      None

      Description

      Custom akka-based receiver built after the shipped example doesn't work if custom akka messages are defined in the uploaded jar (ssc.setJars). ClassNotFoundException thrown on the executors side.
      Modified version of example is attached.

        Attachments

        1. customMessage.zip
          5 kB
          Anton B

          Issue Links

            Activity

              People

              • Assignee:
                Unassigned
                Reporter:
                darkace Anton B
                Shepherd:
                Tathagata Das
              • Votes:
                0 Vote for this issue
                Watchers:
                5 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: