chenwyi2 commented on issue #6066:
URL: https://github.com/apache/iceberg/issues/6066#issuecomment-1294294691

   > `.avro` might be a manifest file. do you have the complete stack trace? 
Which Flink version?
   > 
   > I couldn't find this log line in 1.13 (or 1.14 and 1.15).
   > 
   > ```
   > 2022-10-21 16:57:19,750 INFO 
org.apache.iceberg.flink.sink.IcebergFilesCommitter [] - Committed in 562 ms
   > without flushing snapshot state to state backend
   > ```
   > 
   > 1.13 has log line without the part after `Committed in 562 ms`. 
https://github.com/apache/iceberg/blob/master/flink/v1.13/flink/src/main/java/org/apache/iceberg/flink/sink/IcebergFilesCommitter.java
   
   it is my mistake, the right log should be 
   "2022-10-21 16:57:19,188 INFO 
org.apache.iceberg.flink.sink.IcebergFilesCommitter [] - Committing append with 
2 data files and 0 delete files to table icebergCatalog.xxx
   2022-10-21 16:57:19,573 INFO org.apache.iceberg.BaseMetastoreTableOperations 
[] - Successfully committed to table icebergCatalog.xx
   2022-10-21 16:57:19,573 INFO org.apache.iceberg.SnapshotProducer [] - 
Committed snapshot 7536746147835307981 (MergeAppend)
   2022-10-21 16:57:19,594 INFO org.apache.iceberg.BaseMetastoreTableOperations 
[] - Refreshing table metadata from new version: 
qbfs://online01/warehouse/xx/metadata/99171-45858db6-5917-4397-afcc-76c10ea80305.metadata.json
   2022-10-21 16:57:19,750 INFO 
org.apache.iceberg.flink.sink.IcebergFilesCommitter [] - Committed in 562 ms
   2022-10-21 16:57:20,090 INFO 
org.apache.iceberg.flink.sink.IcebergFilesCommitter [] - Start to flush 
snapshot state to state backend, table: 
icebergCatalog.cupid_bi.ads_qixiao_tracking_hawkeye_no_filter_1min, 
checkpointId: 8227"
   but in my situation, the task existed without showing  flushing snapshot 
state to state backend, because of nodemanager restart, then i restart fllink 
job, the job failed with FileNotFoundException
   in the hdfs audit log, i never saw that avro file has been created.
   


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to