开发者社区 > 大数据与机器学习 > 开源大数据平台 E-MapReduce > 正文

请问flink sql 写oss有个报错该怎么办?

请问flink sql 写oss 有个Caused by: TimerException{java.lang.UnsupportedOperationException: Cannot sync state to system like S3. Use persist() to create a persistent recoverable intermediate point.}这样的 报错该怎么办呢?

展开
收起
圆葱猪肉包 2023-03-07 10:32:34 1493 0
2 条回答
写回答
取消 提交回答
  • 月移花影,暗香浮动

    这个错误提示的意思是不能直接将状态同步到像S3这样的系统中,需要使用persist()方法创建一个持久化的可恢复的中间状态点。这个方法的作用是将当前的状态保存在指定的路径中,以便以后可以从该位置恢复状态。这个方法通常在长时间运行的任务或分布式计算中使用,以避免因故障或其他原因中断导致状态丢失。

    2023-03-07 14:29:37
    赞同 1 展开评论 打赏
  • 我也遇到这个问题了。同问呀,好几天了也没有解决方案

    2023-03-07 11:37:35
    赞同 展开评论 打赏

阿里云EMR是云原生开源大数据平台,为客户提供简单易集成的Hadoop、Hive、Spark、Flink、Presto、ClickHouse、StarRocks、Delta、Hudi等开源大数据计算和存储引擎,计算资源可以根据业务的需要调整。EMR可以部署在阿里云公有云的ECS和ACK平台。

相关电子书

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