Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-11727

JSON row format is not serializable

    XMLWordPrintableJSON

Details

    Description

      JsonRowSerializationSchema and JsonRowDeserializationSchema use reference comparisons for more efficient execution, however, these do not work after serialization of the class when shipping it to a cluster. This error was not immediately visible as the logic in the else clause was also able to partially do the correct logic.

      Attachments

        Issue Links

          Activity

            People

              twalthr Timo Walther
              twalthr Timo Walther
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved:

                Time Tracking

                  Estimated:
                  Original Estimate - Not Specified
                  Not Specified
                  Remaining:
                  Remaining Estimate - 0h
                  0h
                  Logged:
                  Time Spent - 20m
                  20m