HuangZhenQiu commented on code in PR #26640:
URL: https://github.com/apache/flink/pull/26640#discussion_r2155113879


##########
docs/layouts/shortcodes/generated/expert_rocksdb_section.html:
##########
@@ -14,6 +14,12 @@
             <td>Integer</td>
             <td>The number of threads (per stateful operator) used to transfer 
(download and upload) files in RocksDBStateBackend.If negative, the common (TM) 
IO thread pool is used (see cluster.io-pool.size)</td>
         </tr>
+        <tr>
+            <td><h5>state.backend.rocksdb.checkpoint.upload-jitter</h5></td>
+            <td style="word-wrap: break-word;">0 ms</td>
+            <td>Duration</td>
+            <td>The time interval used to create jitter for each checkpoint 
file upload.</td>

Review Comment:
   Thanks. It is a good question. The state uploader is in async path. The 
jitter help to span the upload request with in a time interval to reduce the 
spike traffic to cloud/remote storage.
   
   1. Whether there is a way to check for the rate limitting return code and 
only delay those.
   From our observation, the IO exception will throw within file system layer. 
In this case, Flink with fail current checkpoint. There is no easy way to use 
return code to adjust the jitter. We probably may add exponential delayed retry 
after catch IOException. It is out of our original scope of the problem we want 
to resolve. But it could be a further improve in another PR.
   
   2. if we add a random delay using the Jitter , is there a case that the 
checkpoints might end up out of order?
   How many checkpoints can happen is controlled by the allowed concurrent 
checkpoints configured by users. The jitter will add additional time for each 
task manager to finish the checkpoint and send back the ack to checkpoint 
coordinator. Given checkpoint interval is usually configured in minutes level, 
and the jitter is configured in seconds level. I don't the risk of checkpoint 
out of order.
   
   @mxm What's your opinion?
    
   
   
   
   



-- 
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]

Reply via email to