sockets - socket坏了时flink如何通过socketTextStream方法重新连接socket
问题描述
代码如下： DataStream transactions = env.socketTextStream("192.168.120.234", 18899, "|", 10); 我发现 maxRety 次 10 不起作用，当套接字服务器关闭时，套接字将始终连接套接字服务器而不是计数 10。我使用的 flink 版本是 1.10.1
解决方案
推荐阅读
- android - 上传图像以训练 ML Kit 是不可能的
- javascript - 记住移动设备中的登录用户
- python - Google 表格 API 工作表 ID 问题/python
- unit-testing - 是否可以像 Jasmine 那样使用 Cypress 独立版本运行 UNIT TEST？（在浏览器中）
- android - Flutter 的 TextPainter 抛出一个 '!_needsLayout': is not true。例外
- nginx - nginx 配置 server_name 错误但网站还在运行？
- python - Cython：将带有 `except` 的 Cython 函数转换为 C 类函数
- node.js - 一对多关系 ObjectId 在快速打字稿中的 mongoose mongodb 中不起作用
- c++ - Qt：如何在 QVBoxLayout 中交替对齐 QTextEdit？
- r - 有没有更快的方法在 R 中制作这个混淆矩阵表？