[FLINK-22487] Support `print` to print logs in PyFlink

• Type: New Feature
• Status: Resolved
• Priority: Major
• Resolution: Done
• Affects Version/s: 1.14.0
• Fix Version/s: 1.14.0
• Component/s: API / Python
• Labels: pull-request-available
• Assignee: Huang Xingbo
• Reporter: Huang Xingbo
• Created: 27/Apr/21 04:02
• Updated: 28/Aug/21 12:10
• Resolved: 19/May/21 01:59

Description

Currently, if users want to print logs, they need to use logging module.

@udf(result_type=DataTypes.BIGINT())
def add(i, j):
    import logging
    logging.info("debug")
    return i + j

It will be more convenient to use `print` to print logs.

Unable to find source-code formatter for language: python. Available languages are: actionscript, ada, applescript, bash, c, c#, c++, cpp, css, erlang, go, groovy, haskell, html, java, javascript, js, json, lua, none, nyan, objc, perl, php, python, r, rainbow, ruby, scala, sh, sql, swift, visualbasic, xml, yaml

@udf(result_type=DataTypes.BIGINT())
def add(i, j):
    print("debug")
    return i + j

Issue Links

• links to: GitHub Pull Request #15780