开发者社区> 问答> 正文

PyFlink 作业中自定义日志的示例是什么?

PyFlink 作业中自定义日志的示例是什么?

展开
收起
游客qzzytmszf3zhq 2021-12-07 15:21:37 380 0
1 条回答
写回答
取消 提交回答
  • 有时候,异常日志的内容并不足以帮助我们定位问题,此时可以考虑在 Python 自定义函数中打印一些日志信息。PyFlink 支持用户在 Python 自定义函数中通过 logging 的方式输出 log,比如:
    
    def split(s):
        import logging
        logging.info("s: " + str(s))
        splits = s[1].split("|")
        for sp in splits:
            yield s[0], sp
    通过上述方式,split 函数的输入参数,会打印到 TaskManager 的日志文件中。
    
    2021-12-07 15:21:55
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
PostgresChina2018_赖思超_PostgreSQL10_hash索引的WAL日志修改版final 立即下载
Kubernetes下日志实时采集、存储与计算实践 立即下载
日志数据采集与分析对接 立即下载