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

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

Attach filesAttach ScreenshotVotersWatch issueWatchersCreate sub-taskLinkCloneUpdate Comment AuthorReplace String in CommentUpdate Comment VisibilityDelete Comments
    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

        Issue Links

          Activity

            People

            • Assignee:
              Unassigned
              Reporter:
              darkace Anton B
              Shepherd:
              Tathagata Das

              Dates

              • Created:
                Updated:
                Resolved:

                Issue deployment