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 会有如下四种可能的输出格式:

Print 条件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

Flink SQL 自定义 redis connector

Flink 自定义 SQL Connector

Flink SQL --JDBC connector

Flink SQL实战演练之自定义Clickhouse Connector

Flink Table API & SQL DataGen Connector