[GitHub] [spark] PingHao commented on issue #24922: [SPARK-28120][SS] Rocksdb state storage implementation

[GitBox <gi...@apache.org>]

PingHao commented on issue #24922: [SPARK-28120][SS]  Rocksdb state storage implementation
URL: https://github.com/apache/spark/pull/24922#issuecomment-540235341
 
 
   > 
   > 
   > @PingHao - Both the issue- stuck executor, core dump - might be due to the same reasons. Will debug and fix it.
   > 
   > Would you have some code snippets that can help me to reproduce the problem?
   My running code is difficult to isolation or share here, so here is a new test case  (based on existing test case "maintenance" ) in your RocksDbStateStoreSuite.scala, to try simulator parallel spark tasks operation on each partition statestore and at same time have maintenance thread try destoryDB.  see code here 
   
   https://gist.github.com/PingHao/c20846542adda742f27ff00459fafe29#file-rocksdbstatestoresuite-scala-L384
   
   I can produce core dump on my developer machine, but not sure if logic is legit anyway. 
   you can change N - number of partitions, and LOOPS. recommend N = number of cpu cores.
   

----------------------------------------------------------------
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:
users@infra.apache.org


With regards,
Apache Git Services

---------------------------------------------------------------------
To unsubscribe, e-mail: reviews-unsubscribe@spark.apache.org
For additional commands, e-mail: reviews-help@spark.apache.org