Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-12308 Support python language in Flink Table API
  3. FLINK-12327

Add simplicity support for submitting Python Table API job in CliFrontend, i.e. `flink run -py wordcount.py` can be work(with simple test).

Agile BoardRank to TopRank to BottomAttach filesAttach ScreenshotBulk Copy AttachmentsBulk Move AttachmentsVotersWatch issueWatchersConvert to IssueLinkCloneLabelsUpdate Comment AuthorReplace String in CommentUpdate Comment VisibilityDelete Comments
    XMLWordPrintableJSON

Details

    Description

      Add simplicity support for submitting Python Table API job in CliFrontend, i.e. `flink run -py wordcount.py` can be work(with simple test).

      Support for submitting Python Table API job in CliFrontend´╝îAnd using `flink run` submit Python Table API job. The current `flink` command command line syntax is as follows:

      flink <ACTION> [OPTIONS] [ARGUMENTS]

      On the basis of the current `run` ACTION, we add to Python Table API support, specific OPTIONS are as follows:

      -py --python <python-file-name>
      Python script with the program entry point. We can configure dependent resources with the `--py-files` option.

      • -pyfs --py-files <python-files>
        Attach custom python files for job. Comma can be used as the separator to specify multiple files. The standard python resource file suffixes such as .py/.egg/.zip all also supported.
      • -pym --py-module <python-module> Python module with the program entry point. This option must be used in conjunction with ` --py-files`.

      For more details, please refer to FLIP-38

      NOTE: In this JIRA we only need to implement the basic options, without fully implementing the parameters related to UDFs in FLIP-38.

      Attachments

        Activity

          This comment will be Viewable by All Users Viewable by All Users
          Cancel

          People

            hxbks2ks Huang Xingbo
            sunjincheng121 sunjincheng
            Votes:
            0 Vote for this issue
            Watchers:
            1 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

              Slack

                Issue deployment