更新时间:2024-04-19 GMT+08:00
BlackHole
功能描述
BlackHole Connector允许接收所有输入记录,常用于高性能测试和UDF输出,其不是实质性Sink。Blackhole结果表是系统内置的Connector。
例如,如果您在注册其他类型的Connector结果表时报错,但您不确定是系统问题还是结果表WITH参数错误,您可以将WITH参数修改为'connector' = 'blackhole'后,单击运行。如果不再报错,则证明系统没有问题,您需要排查确认修改WITH参数是否正确。
类别 |
详情 |
---|---|
支持表类型 |
结果表 |
注意事项
- 创建Flink OpenSource SQL作业时,在作业编辑界面的“运行参数”处,“Flink版本”需要选择“1.15”,勾选“保存作业日志”并设置保存作业日志的OBS桶,方便后续查看作业日志。
- 认证用的username和password等硬编码到代码中或者明文存储都有很大的安全风险,建议使用DEW管理凭证。配置文件或者环境变量中密文存放,使用时解密,确保安全。Flink Opensource SQL使用DEW管理访问凭据
语法格式
create table blackhole_table ( attr_name attr_type (',' attr_name attr_type) * ) with ( 'connector' = 'blackhole' );
参数说明
选项 |
是否必要 |
默认值 |
类型 |
描述 |
---|---|---|---|---|
connector |
是 |
无 |
String |
指定需要使用的连接器,此处应为'blackhole'。 |
示例
通过DataGen源表产生数据,BlackHole结果表接收传来的数据。
create table datagenSource ( user_id string, user_name string, user_age int ) with ( 'connector' = 'datagen', 'rows-per-second'='1' ); create table blackholeSink ( user_id string, user_name string, user_age int ) with ( 'connector' = 'blackhole' ); insert into blackholeSink select * from datagenSource;
父主题: Connector列表