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

scala.StreamExecutionEnvironment Doesn't set return type upon adding source

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Open
    • Priority: Major
    • Resolution: Unresolved
    • Affects Version/s: 1.9.0, 1.9.1
    • Fix Version/s: None
    • Component/s: API / Scala
    • Labels:
      None

      Description

      This line in StreamExecutionEnvironment.scala was changed to remove the `returns` call starting in version 1.9.0. This causes subsequent transformations on the stream to fail since the return TypeInformation isn't set anymore.

       

      Looks like the change was made in this pr. Guessing it was a mistake unless there's some reason to do this that I'm not understanding.

       

      I'm willing to make the PR to fix it, just need it changed so we can start upgrading our microservices to 1.9.

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                Unassigned
                Reporter:
                tdbgamer Tim Bess
              • Votes:
                0 Vote for this issue
                Watchers:
                3 Start watching this issue

                Dates

                • Created:
                  Updated: