MAPREDUCE服务 MRS-Structured Streaming的cluster模式,在数据处理过程中终止ApplicationManager,应用失败:回答

时间:2024-06-13 09:38:30

回答

原因分析:显示该异常是因为“recoverFromCheckpointLocation”的值判定为false,但却配置了checkpoint目录。

参数“recoverFromCheckpointLocation”的值为代码中“outputMode == OutputMode.Complete()”语句的判断结果(outputMode的默认输出方式为“append”)。

处理方法:编写应用时,用户可以根据具体情况修改数据的输出方式。

将输出方式修改为“complete”“recoverFromCheckpointLocation”的值会判定为true。此时配置了checkpoint目录时就不会显示异常。

support.huaweicloud.com/devg-lts-mrs/mrs_07_200156.html