• 大数据

  【flink】SinkUpsertMaterializer

  在flink cdc同步数据时，基于sql的实现方式中发现了作业DAG有个SinkMaterializer算子，而且检查checkpoint历史时发现该算子state越来越大， 有…

  1天前