apache-flink - Apache Flink 依次写入多个接收器
问题描述
我有一个 CsvTableSource 来读取 CSV 文件并将数据写入 S3,然后我想将文件从 S3 加载到 JDBC 接收器。如何使 JDBC 接收器仅在 S3 接收器成功完成后才执行。原因是,S3 将用于其他一些处理,没有 S3 跃点,数据无法直接移动到 JDBC
解决方案
听起来您可以有一个读取 CSV 文件并写入 S3 的作业,以及使用 S3 作为其源并写入 JDBC 的第二个作业。
推荐阅读
- elasticsearch - ELASTICSEARCH - 计算具有条件的唯一值
- android - 使用 Apollo 客户端将文件上传到 GraphQL
- mongodb - 使用外部字段值 Mongodb 更新内部数组元素属性
- java - (GXT) 在弹出面板的所有子项中更改注册
- php - 未捕获的 PHP 异常
- c++ - 为什么我会收到此错误:“bool”之前的预期主表达式?
- javascript - 关于 Hyperledger Fabric 的登录注册架构师
- sql - 如果在 Microsoft SQL Server 中未找到任何行,则返回 0
- python - “SQLAlchemy”的实例没有“列”成员
- c# - ItemsControl、ItemContainerStyle 和 ItemTemplate