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

Java doc of PulsarSourceBuilder was not updated in time

    XMLWordPrintableJSON

Details

    Description

      The java doc of `PulsarSourceBuilder` was not updated in time.

      IIUC, 

      setDeserializationSchema(PulsarDeserializationSchema.flinkSchema(new SimpleStringSchema())) 

      should be replaced by

      setDeserializationSchema(new SimpleStringSchema()) 

      BTW, I also checked `pulsar.md` and luckily it was correct.

      Attachments

        Issue Links

          Activity

            People

              Weijie Guo Weijie Guo
              Weijie Guo Weijie Guo
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: