Flink SQL Print Connector
Posted @SmartSi
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了Flink SQL Print Connector相关的知识,希望对你有一定的参考价值。
Flink 版本:1.13
1. 简介
Print Connector 可以将每一行数据输出到标准输出流以及标准错误流中。它是专门为如下场景设计的:
- 在流式作业中进行简单测试。
- 在生产环境进行调试。
Print Connector 只能作为 Sink 输出表,不能作为 Source 输入表。Print Connector 会有如下四种可能的输出格式:
条件1 | 条件2 | |
---|---|---|
PRINT_IDENTIFIER:taskId> output | 设置 print-identifier 参数选项 | parallelism > 1 |
PRINT_IDENTIFIER> output | 设置 print-identifier 参数选项 | parallelism == 1 |
taskId> output | 未设置 print-identifier 参数选项 | parallelism > 1 |
output | 未设置 print-identifier 参数选项 | parallelism == 1 |
以上是关于Flink SQL Print Connector的主要内容,如果未能解决你的问题,请参考以下文章
Flink: FlieSystem SQL Connector