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

Python UDTF doesn't work well when the return type isn't generator

    XMLWordPrintableJSON

    Details

      Description

      For the following Python UDTF which return type is not a generator:

      # test specify the input_types
      @udtf(input_types=[DataTypes.BIGINT()],
                 result_types=[DataTypes.BIGINT(), DataTypes.BIGINT(), DataTypes.BIGINT()])
      def split(x):
          return Row(10, 10, 10)
      

      When used in a job, the operator containing the UDTF will not emit data to the downstream operator and there is also no exception thrown. The job just finished without any result.

      We should properly handle this case: either support this use case or throw a proper exception if we don't want to support this case.

        Attachments

          Activity

            People

            • Assignee:
              hxbks2ks Huang Xingbo
              Reporter:
              dian.fu Dian Fu
            • Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: