当前位置:网站首页>请问,在使用flink sql sink数据到kafka的时候出现执行成功,但是kafka里面没有数
请问,在使用flink sql sink数据到kafka的时候出现执行成功,但是kafka里面没有数
2022-07-07 12:01:00 【阿里云问答】
请问,在使用flink sql sink数据到kafka的时候出现执行成功,但是kafka里面没有数据,这个怎么解决?
采纳答案1:
在执行后面加了个print()。
此答案来自钉钉群“【2】Apache Flink China 社区”
边栏推荐
- 2022-7-6 Leetcode27.移除元素——太久没有做题了,为双指针如此狼狈的一天
- 云计算安全扩展要求关注的安全目标和实现方式区分原则有哪些?
- 华为镜像地址
- 648. 单词替换 : 字典树的经典运用
- Attribute keywords aliases, calculated, cardinality, ClientName
- The meaning of variables starting with underscores in PHP
- Cinnamon taskbar speed
- [fortress machine] what is the difference between cloud fortress machine and ordinary fortress machine?
- Flask session forged hctf admin
- SSRF vulnerability file pseudo protocol [netding Cup 2018] fakebook1
猜你喜欢

数据库系统概论-第一章绪论【概念模型、层次模型和三级模式(外模式、模式、内模式)】
![SSRF漏洞file伪协议之[网鼎杯 2018]Fakebook1](/img/10/6de1ee8467b18ae03894a8d5ba95ff.png)
SSRF漏洞file伪协议之[网鼎杯 2018]Fakebook1

Leecode3. Longest substring without repeated characters

DID登陆-MetaMask

Indoor ROS robot navigation commissioning record (experience in selecting expansion radius)

Flink | 多流转换

Leetcode simple question sharing (20)

为租客提供帮助

Flask session forged hctf admin

Redis can only cache? Too out!
随机推荐
PHP中用下划线开头的变量含义
LeetCode简单题分享(20)
Help tenants
Evolution of customer service hotline of dewu
Parameter keywords final, flags, internal, mapping keywords internal
MySQL "invalid use of null value" solution
2022-7-7 Leetcode 34.在排序数组中查找元素的第一个和最后一个位置
Solve the cache breakdown problem
Learning breakout 2 - about effective learning methods
请问指南针股票软件可靠吗?交易股票安全吗?
室内ROS机器人导航调试记录(膨胀半径的选取经验)
3D Detection: 3D Box和点云 快速可视化
How to make join run faster?
使用day.js让时间 (显示为几分钟前 几小时前 几天前 几个月前 )
Server to server (S2S) event (adjust)
call undefined function openssl_cipher_iv_length
Talk about pseudo sharing
Advanced Mathematics - Chapter 8 differential calculus of multivariate functions 1
得物客服热线的演进之路
PC端页面如何调用QQ进行在线聊天?