Dd969696 opened a new issue, #4725:
URL: https://github.com/apache/paimon/issues/4725

   ### Search before asking
   
   - [X] I searched in the [issues](https://github.com/apache/paimon/issues) 
and found nothing similar.
   
   
   ### Paimon version
   
   0.9.0
   
   ### Compute Engine
   
   Flink
   
   ### Minimal reproduce step
   
   First async lookup join some paimon table in full cache mode with dynamic 
partition = max_pt(),
   then create new partition in paimon table, finally the async task for 
refreshing local dim table will be reject because executor thread pool has been 
terminated.
   It will reopen lookupTable when partition has been changed 
(org.apache.paimon.flink.lookup.FileStoreLookupFunction#tryRefresh)
   
![image](https://github.com/user-attachments/assets/2366219c-0600-4c3d-96c6-f80a25d3d2cf)
   the executor thread pool for async refreshing local dim table task has been 
closed (org.apache.paimon.flink.lookup.FullCacheLookupTable#close)
   
![image](https://github.com/user-attachments/assets/e1366383-e3bd-40de-a501-100630b21b24)
   but we won't build new thread pool, hence we will occur exception as follow:
   
![image](https://github.com/user-attachments/assets/9284fae5-a32d-408b-8f60-7915e29cde7d)
   
   
   
   
   
   
   
   ### What doesn't meet your expectations?
   
   The executor thread pool for async refreshing local dim table task should be 
rebuilt and the refreshing task shouldn't be rejected.
   
   ### Anything else?
   
   _No response_
   
   ### Are you willing to submit a PR?
   
   - [X] I'm willing to submit a PR!


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