rkhachatryan opened a new pull request #13180:
URL: https://github.com/apache/flink/pull/13180


   
   ## What is the purpose of the change
   
   *Improve logging when a checkpoint is declined (e.g. target directory is not 
writable).*
   
   ## Verifying this change
   
   Tested manually on a local cluster.
   
   ### Job Manager ###
   
   ```
   2020-08-17 18:06:47,238 INFO  
org.apache.flink.runtime.checkpoint.CheckpointCoordinator    [] - Decline 
checkpoint 4 by task 5271c210329e73bd743f3227edfb3b71_0_0 of job 
815316dcc17ceea916d2a4da019aca13 at 127.0.1.1:44861-e3cf2c @ 
roman-ThinkPad-L380 (dataPort=33273).
   org.apache.flink.util.SerializedThrowable: Could not materialize checkpoint 
4 for operator ArtificalKeyedStateMapper_Kryo_and_Custom_Stateful (1/2).
   Caused by: org.apache.flink.util.SerializedThrowable: 
com.esotericsoftware.kryo.KryoException: java.io.IOException: Could not open 
output stream for state backend
        ... 
   Caused by: org.apache.flink.util.SerializedThrowable: java.io.IOException: 
Could not open output stream for state backend
        ...
   Caused by: org.apache.flink.util.SerializedThrowable: Could not open output 
stream for state backend
        ... 
   Caused by: org.apache.flink.util.SerializedThrowable: Mkdirs failed to 
create 
file:/tmp/forbidden/savepoint-e2e-test-chckpt-dir/815316dcc17ceea916d2a4da019aca13/chk-4
        ...
   ```
   
   ### Task Manager ###
   
   ```
   2020-08-17 18:06:45,239 INFO  
org.apache.flink.streaming.runtime.tasks.AsyncCheckpointRunnable [] - 
ArtificalKeyedStateMapper_Kryo_and_Custom_Stateful (2/2) - asynchronous part of 
checkpoint 2 could not be completed.
   java.util.concurrent.ExecutionException: 
com.esotericsoftware.kryo.KryoException: java.io.IOException: Could not open 
output stream for state backend
   Caused by: com.esotericsoftware.kryo.KryoException: java.io.IOException: 
Could not open output stream for state backend
        ... 
   Caused by: java.io.IOException: Could not open output stream for state 
backend
        ...
   Caused by: java.io.IOException: Mkdirs failed to create 
file:/tmp/forbidden/savepoint-e2e-test-chckpt-dir/815316dcc17ceea916d2a4da019aca13/chk-2
        ... 
   ```
   
   cc: @NicoK 


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

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


Reply via email to