开发者社区 > 大数据与机器学习 > 实时计算 Flink > 正文

Flink从这个配置来看,是不是可以理解为,jdbc_fixed模式 就是rpc 模式升级版?

Flink从这个配置来看,是不是可以理解为,jdbc_fixed模式 就是rpc 模式升级版?8a0efc0d09ef27e4c8fc31e6b805a468.png

展开
收起
三分钟热度的鱼 2023-11-22 19:53:33 51 0
4 条回答
写回答
取消 提交回答
  • Apache Flink的JdbcOutputFormat有两种模式:RPC模式和BATCH模式。RPC模式也被称为"fire-and-forget"模式,它会立即发送更新到数据库,而不等待整个窗口的数据。这种模式适用于低延迟的场景,但是它可能会导致大量的数据库连接。

    BATCH模式则会等待整个窗口的数据,然后再一次性地将所有数据发送到数据库。这种模式适用于高吞吐量的场景,但是它可能会增加延迟。

    Jdbc_fixed模式是Flink的一种新的输出格式,它结合了RPC模式和BATCH模式的优点。在这种模式下,Flink会等待整个窗口的数据,然后再一次性地将所有数据发送到数据库。但是,它会使用多个数据库连接来并行地发送数据,从而提高吞吐量。

    所以,虽然Jdbc_fixed模式和RPC模式都会立即发送更新到数据库,但是Jdbc_fixed模式使用了多个数据库连接来并行地发送数据,而RPC模式则只使用一个数据库连接。因此,Jdbc_fixed模式可以看作是RPC模式的升级版本。

    2023-11-28 10:58:19
    赞同 展开评论 打赏
  • 从配置的角度来看,可以将JDBC模式视为RPC模式的升级版。JDBC模式提供了更高级别的抽象和易用性,同时支持更多的功能和优化。

    在Flink的早期版本中,RPC模式是主要的连接器模式,用于与外部系统进行通信。但是,随着Flink的演进和外部系统的不断发展,RPC模式逐渐暴露出一些局限性,例如性能瓶颈、可扩展性等问题。

    为了解决这些问题,Flink社区引入了JDBC模式作为新的连接器模式。JDBC模式利用了JDBC(Java Database Connectivity)接口的优点,提供了一种标准化的、高性能的、可扩展的数据库连接方式。通过使用JDBC模式,Flink可以更好地利用数据库的优化机制,提高查询性能和可扩展性。

    因此,可以说JDBC模式是RPC模式的升级版,提供了更好的性能和可扩展性,以及更多的功能和优化。但是,具体的行为和性能差异可能会因外部系统和Flink版本的不同而有所差异。建议查阅Flink官方文档或社区讨论以获取更详细的信息。

    2023-11-25 21:07:10
    赞同 展开评论 打赏
  • 面对过去,不要迷离;面对未来,不必彷徨;活在今天,你只要把自己完全展示给别人看。

    Flink SQL 提供了两种与数据库交互的方式:JDBC 模式和 RPC 模式。JDBC 模式允许 Flink 直接访问数据库,并从数据源中读取数据,从而减少了数据传输过程中的瓶颈,加快了速度。而 RPC 模式通过连接 Flink 的 Source 端口和 Sink 端口来发送数据。
    从本质上讲,这两种模式都是异步操作,并不是相互替代的关系。也就是说,它们之间不存在“升级”的概念。但是,在大多数情况下,JDBC 模式的性能优于 RPC 模式,因为它允许 Flink 直接访问数据库,而不需要通过多个网络层传输数据。

    2023-11-22 21:39:02
    赞同 展开评论 打赏
  • 是的。此回答整理自钉群“实时计算Flink产品交流群”

    2023-11-22 20:05:35
    赞同 展开评论 打赏

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

相关产品

  • 实时计算 Flink版
  • 相关电子书

    更多
    Flink CDC Meetup PPT - 龚中强 立即下载
    Flink CDC Meetup PPT - 王赫 立即下载
    Flink CDC Meetup PPT - 覃立辉 立即下载