flink 
sql运行在阿里云k8s用oss作为checkpoint存储介质,在作业启动过程中出错,请问这个NoSuchKey是指什么?flink在获取checkpoint作restore吗?


2021-05-21 10:56:10,278 INFO 
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Source: 
TableSourceScan(table=[[default_catalog, default_database, kafka_source]], 
fields=[id, acct_seq_id, acct_date, log_id, sttl_date, acct_no, trans_type, 
dc_flag, trans_amt, acct_bal, avl_bal, frz_bal, cust_id, cust_id2, product_id, 
dept_id, trans_name, trans_obj, mer_order_id, pnr_id, gate_id, frt_txn_id1, 
frt_txn_id2, frt_txn_id3, frt_req_date, frt_req_id, sys_id, frt_req_dtl_id, 
intr_rgn_flag, acct_rgn_id, biz_type, trace_id, rsv1, rsv2, rsv3, ext_info, 
create_time, last_update_time]) -> DropUpdateBefore -> Calc(select=[id, 
acct_seq_id, acct_date, log_id, sttl_date, acct_no, trans_type, dc_flag, 
trans_amt, acct_bal, avl_bal, frz_bal, cust_id, cust_id2, product_id, dept_id, 
trans_name, trans_obj, mer_order_id, pnr_id, gate_id, frt_txn_id1, frt_txn_id2, 
frt_txn_id3, frt_req_date, frt_req_id, sys_id, frt_req_dtl_id, intr_rgn_flag, 
acct_rgn_id, biz_type, trace_id, rsv1, rsv2, rsv3, ext_info, create_time, 
last_update_time, _UTF-16LE'binlog2mongo' AS EXPR$38, (CAST(()) DATE_FORMAT 
_UTF-16LE'yyyyMMddHHmmssSSS') AS EXPR$39, _UTF-16LE'binlog2mongo' AS EXPR$40, 
(CAST(()) DATE_FORMAT _UTF-16LE'yyyyMMddHHmmssSSS') AS EXPR$41, _UTF-16LE'0' AS 
EXPR$42]) -> Sink: Sink(table=[default_catalog.default_database.mongo_table], 
fields=[id, acct_seq_id, acct_date, log_id, sttl_date, acct_no, trans_type, 
dc_flag, trans_amt, acct_bal, avl_bal, frz_bal, cust_id, cust_id2, product_id, 
dept_id, trans_name, trans_obj, mer_order_id, pnr_id, gate_id, frt_txn_id1, 
frt_txn_id2, frt_txn_id3, frt_req_date, frt_req_id, sys_id, frt_req_dtl_id, 
intr_rgn_flag, acct_rgn_id, biz_type, trace_id, rsv1, rsv2, rsv3, ext_info, 
create_time, last_update_time, EXPR$38, EXPR$39, EXPR$40, EXPR$41, EXPR$42]) 
(1/1) (e8c335fd6c7edf5fe941cf52f5042697) switched from DEPLOYING to RUNNING.

2021-05-21 10:56:12,881 INFO 
org.apache.flink.fs.osshadoop.shaded.com.aliyun.oss [] - [Server]Unable to 
execute HTTP request: Not Found

[ErrorCode]: NoSuchKey

[RequestId]: 60A7214CDB6FC83031C28EF9

[HostId]: null

2021-05-21 10:56:12,885 INFO 
org.apache.flink.fs.osshadoop.shaded.com.aliyun.oss [] - [Server]Unable to 
execute HTTP request: Not Found

[ErrorCode]: NoSuchKey

[RequestId]: 60A7214CDB6FC83031D58EF9

[HostId]: null

2021-05-21 10:56:12,895 INFO 
org.apache.flink.fs.osshadoop.shaded.com.aliyun.oss [] - [Server]Unable to 
execute HTTP request: Not Found

[ErrorCode]: NoSuchKey

[RequestId]: 60A7214CDB6FC83031E68EF9

[HostId]: null

2021-05-21 10:56:12,900 INFO 
org.apache.flink.fs.osshadoop.shaded.com.aliyun.oss [] - [Server]Unable to 
execute HTTP request: Not Found

[ErrorCode]: NoSuchKey

[RequestId]: 60A7214CDB6FC83031F08EF9

[HostId]: null

2021-05-21 10:56:12,925 INFO 
org.apache.flink.runtime.checkpoint.CheckpointCoordinator [] - Triggering 
checkpoint 1 (type=CHECKPOINT) @ 1621565772870 for job 
9e968b0059199b6d2063c02d95b6f619.

回复