apache-flink - 当 writeToSocket 什么都没有发生
问题描述
并添加一些部分以将结果写入套接字
windowCounts
.writeToSocket("localhost", 7777, new SerializationSchema<WordWithCount>() {
@Override
public byte[] serialize(WordWithCount wordWithCount) {
return wordWithCount.toString().getBytes();
}
});
而且我的本地主机(端口 7777)上什么也没有。有什么我想念的吗?谢谢你
解决方案
推荐阅读
- sql-server - 将 While 与 SELECT 语句一起使用
- php - 仅显示不在连接表中的行
- javascript - 如何填充包含完整文档的 HTML 字符串的 iframe,而不是在 src 属性中为其提供指向另一个网页的链接?
- python - 填充缺失值
- java - 来自 Firebase 的重复值加载到 ListView
- ios - iOS 应用程序可以同时使用基于证书和基于令牌的 APNs 连接吗?
- python - 如何用python编写字典列表的csv
- regex - 将语法转换为正则表达式
- java - 使用JDK 10时找不到javax.annotation.Resource的lookup()方法
- excel - 将数据导出到文本文件