-
Notifications
You must be signed in to change notification settings - Fork 963
fix close ledgerAuditorManager repeatedly #3503
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Conversation
|
ping @hangc0276 PTAL. Thanks. |
|
rerun failure checks |
StevenLuMT
left a comment
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
good catch
|
also ping @dlg99 @eolivelli @shoothzj |
|
@eolivelli @dlg99 |
|
@StevenLuMT @zymap Can this PR be merged? Any more questions, please let me know. Thanks. |
|
@zymap Can this pr be merged now. Thanks. |
### Motivation this introduced in #2842, the `ledgerAuditorManager` will be close repeatedly. ```java private void submitShutdownTask() { executor.submit(new Runnable() { @OverRide public void run() { if (!running.compareAndSet(true, false)) { return; } try { ledgerAuditorManager.close(); <- here has already closed LAM. } catch (InterruptedException ie) { Thread.currentThread().interrupt(); LOG.warn("InterruptedException while closing ledger auditor manager", ie); } catch (Exception ke) { LOG.error("Exception while closing ledger auditor manager", ke); } } }); } ``` (cherry picked from commit dbec4e9)
### Motivation this introduced in apache#2842, the `ledgerAuditorManager` will be close repeatedly. ```java private void submitShutdownTask() { executor.submit(new Runnable() { @OverRide public void run() { if (!running.compareAndSet(true, false)) { return; } try { ledgerAuditorManager.close(); <- here has already closed LAM. } catch (InterruptedException ie) { Thread.currentThread().interrupt(); LOG.warn("InterruptedException while closing ledger auditor manager", ie); } catch (Exception ke) { LOG.error("Exception while closing ledger auditor manager", ke); } } }); } ``` (cherry picked from commit dbec4e9)
### Motivation this introduced in apache#2842, the `ledgerAuditorManager` will be close repeatedly. ```java private void submitShutdownTask() { executor.submit(new Runnable() { @OverRide public void run() { if (!running.compareAndSet(true, false)) { return; } try { ledgerAuditorManager.close(); <- here has already closed LAM. } catch (InterruptedException ie) { Thread.currentThread().interrupt(); LOG.warn("InterruptedException while closing ledger auditor manager", ie); } catch (Exception ke) { LOG.error("Exception while closing ledger auditor manager", ke); } } }); } ``` (cherry picked from commit dbec4e9)
### Motivation this introduced in apache#2842, the `ledgerAuditorManager` will be close repeatedly. ```java private void submitShutdownTask() { executor.submit(new Runnable() { @OverRide public void run() { if (!running.compareAndSet(true, false)) { return; } try { ledgerAuditorManager.close(); <- here has already closed LAM. } catch (InterruptedException ie) { Thread.currentThread().interrupt(); LOG.warn("InterruptedException while closing ledger auditor manager", ie); } catch (Exception ke) { LOG.error("Exception while closing ledger auditor manager", ke); } } }); } ``` (cherry picked from commit dbec4e9) (cherry picked from commit 224254b)
### Motivation this introduced in apache#2842, the `ledgerAuditorManager` will be close repeatedly. ```java private void submitShutdownTask() { executor.submit(new Runnable() { @OverRide public void run() { if (!running.compareAndSet(true, false)) { return; } try { ledgerAuditorManager.close(); <- here has already closed LAM. } catch (InterruptedException ie) { Thread.currentThread().interrupt(); LOG.warn("InterruptedException while closing ledger auditor manager", ie); } catch (Exception ke) { LOG.error("Exception while closing ledger auditor manager", ke); } } }); } ```
Motivation
this introduced in #2842, the
ledgerAuditorManagerwill be close repeatedly.