因为print sink数据输出为info日志,所以如果您需要查看print结果表的结果数据,则需要将日志级别调至info。否则,会查不到结果数据。
应安全部门要求,系统对taskmanager.log日志展示数据条数进行了限制。如果您有排查脏数据或特定数据等需求,建议在Where条件中指定业务场景相关条件后,进行print操作,以避免因为2000条的数据条数限制导致无法排查。
DDL定义文章来源:https://www.toymoban.com/news/detail-555343.html
CREATE TABLE print_table (
a INT,
b varchar
) WITH (
'connector'='print',
'logger'='true'
);
WITH参数文章来源地址https://www.toymoban.com/news/detail-555343.html
- connector 结果表类型 是 固定值为print。
- logger 控制台是否显示数据结果 否 取值如下:
false(默认值):不显示。 true:显示。 print-identifier 数据结果标识 否 在日志中通过数据结果标识检索信息。 - sink.parallelism 结果表并行度 否 默认与上游并行度一致。
到了这里,关于Flink SQL Print的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!