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

ContinuousMemoryStream throws error on String type

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Resolved
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: 3.0.0
    • Fix Version/s: 3.0.0
    • Component/s: Structured Streaming
    • Labels:
      None

      Description

      While we can set String as a generic type of ContinuousMemoryStream, it doesn't work really because it doesn't convert String to UTFString and accessing it from Row interface would throw error.

      We should encode the input and convert the input to Row properly.

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                kabhwan Jungtaek Lim
                Reporter:
                kabhwan Jungtaek Lim
              • Votes:
                0 Vote for this issue
                Watchers:
                2 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: