现象:实时日志报错2021-11-11 21:29:56.399 [main] ERROR Engine - nullorg.apache.flink.util.SerializedThrowable: java.lang.RuntimeException: [400] com.aliyun.odps.OdpsException: ODPS-0420061: Invalid parameter in HTTP request - 'partition' is invalid: Can't find latest cluster meta file on streaming partition elecxxxxxxss_pro.prod_user_coin_detail/day=20210723
原因:odps schema发生变更的时候同一时间有新建partition的请求进来的时候会报错。
解决:一般重试可以解决,启动的时候配置加些failover次数。