在Flink SQL中,可以通过以下方式打印日志:
使用set log.level
命令设置日志级别。例如,将日志级别设置为DEBUG:
SET log.level = 'DEBUG';
这将打印出更详细的日志信息。
使用show source
命令查看源表的详细信息。例如,查看名为my_source_table
的源表的详细信息:
SHOW SOURCE my_source_table;
这将显示与该源表相关的日志信息。
使用EXPLAIN
命令查看查询计划和执行计划。例如,查看名为my_query
的查询的执行计划:
EXPLAIN my_query;
这将显示与该查询相关的日志信息,包括执行计划、资源消耗等。
使用SET table.exec.result.log.enabled
命令启用结果集日志记录。例如,启用名为my_sink_table
的目标表的结果集日志记录:
SET table.exec.result.log.enabled=true;
这将打印出目标表的结果集日志信息。
请注意,以上方法适用于Flink SQL CLI或IDE中执行的SQL语句。如果你使用的是其他方式(如提交作业到Flink集群),则需要在相应的配置中设置日志级别或启用日志记录功能。
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。