You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@shardingsphere.apache.org by GitBox <gi...@apache.org> on 2021/04/15 10:19:18 UTC
[GitHub] [shardingsphere-elasticjob] sucg opened a new pull request #1873: Make sure supporting the case that job instances are crashed while ex…
sucg opened a new pull request #1873:
URL: https://github.com/apache/shardingsphere-elasticjob/pull/1873
Make sure supporting the case that job instances are crashed while executing failover.
Fixes #1868.
Changes proposed in this pull request:
Bugfix for Failover
Bugfix for Failover #714 is missing, submit a new 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.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [shardingsphere-elasticjob] codecov-commenter commented on pull request #1873: Make sure supporting the case that job instances are crashed while ex…
Posted by GitBox <gi...@apache.org>.
codecov-commenter commented on pull request #1873:
URL: https://github.com/apache/shardingsphere-elasticjob/pull/1873#issuecomment-823720788
# [Codecov](https://codecov.io/gh/apache/shardingsphere-elasticjob/pull/1873?src=pr&el=h1&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation) Report
> Merging [#1873](https://codecov.io/gh/apache/shardingsphere-elasticjob/pull/1873?src=pr&el=desc&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation) (7122c8c) into [master](https://codecov.io/gh/apache/shardingsphere-elasticjob/commit/05a0a2cbe67fdf72a56acd985145783cfda1a84a?el=desc&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation) (05a0a2c) will **decrease** coverage by `0.05%`.
> The diff coverage is `92.59%`.
> :exclamation: Current head 7122c8c differs from pull request most recent head 5c7ed82. Consider uploading reports for the commit 5c7ed82 to get more accurate results
[](https://codecov.io/gh/apache/shardingsphere-elasticjob/pull/1873?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation)
```diff
@@ Coverage Diff @@
## master #1873 +/- ##
============================================
- Coverage 85.68% 85.62% -0.06%
- Complexity 113 114 +1
============================================
Files 276 276
Lines 5999 6023 +24
Branches 916 921 +5
============================================
+ Hits 5140 5157 +17
- Misses 523 525 +2
- Partials 336 341 +5
```
| [Impacted Files](https://codecov.io/gh/apache/shardingsphere-elasticjob/pull/1873?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation) | Coverage Δ | Complexity Δ | |
|---|---|---|---|
| [...elasticjob/infra/handler/sharding/JobInstance.java](https://codecov.io/gh/apache/shardingsphere-elasticjob/pull/1873/diff?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation#diff-ZWxhc3RpY2pvYi1pbmZyYS9lbGFzdGljam9iLWluZnJhLWNvbW1vbi9zcmMvbWFpbi9qYXZhL29yZy9hcGFjaGUvc2hhcmRpbmdzcGhlcmUvZWxhc3RpY2pvYi9pbmZyYS9oYW5kbGVyL3NoYXJkaW5nL0pvYkluc3RhbmNlLmphdmE=) | `100.00% <ø> (ø)` | `1.00 <0.00> (ø)` | |
| [...ticjob/lite/internal/failover/FailoverService.java](https://codecov.io/gh/apache/shardingsphere-elasticjob/pull/1873/diff?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation#diff-ZWxhc3RpY2pvYi1saXRlL2VsYXN0aWNqb2ItbGl0ZS1jb3JlL3NyYy9tYWluL2phdmEvb3JnL2FwYWNoZS9zaGFyZGluZ3NwaGVyZS9lbGFzdGljam9iL2xpdGUvaW50ZXJuYWwvZmFpbG92ZXIvRmFpbG92ZXJTZXJ2aWNlLmphdmE=) | `94.20% <85.71%> (-2.17%)` | `0.00 <0.00> (ø)` | |
| [...ite/internal/failover/FailoverListenerManager.java](https://codecov.io/gh/apache/shardingsphere-elasticjob/pull/1873/diff?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation#diff-ZWxhc3RpY2pvYi1saXRlL2VsYXN0aWNqb2ItbGl0ZS1jb3JlL3NyYy9tYWluL2phdmEvb3JnL2FwYWNoZS9zaGFyZGluZ3NwaGVyZS9lbGFzdGljam9iL2xpdGUvaW50ZXJuYWwvZmFpbG92ZXIvRmFpbG92ZXJMaXN0ZW5lck1hbmFnZXIuamF2YQ==) | `100.00% <100.00%> (ø)` | `0.00 <0.00> (ø)` | |
| [...lasticjob/lite/internal/failover/FailoverNode.java](https://codecov.io/gh/apache/shardingsphere-elasticjob/pull/1873/diff?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation#diff-ZWxhc3RpY2pvYi1saXRlL2VsYXN0aWNqb2ItbGl0ZS1jb3JlL3NyYy9tYWluL2phdmEvb3JnL2FwYWNoZS9zaGFyZGluZ3NwaGVyZS9lbGFzdGljam9iL2xpdGUvaW50ZXJuYWwvZmFpbG92ZXIvRmFpbG92ZXJOb2RlLmphdmE=) | `90.00% <100.00%> (+1.11%)` | `0.00 <0.00> (ø)` | |
| [...ticjob/lite/internal/sharding/ShardingService.java](https://codecov.io/gh/apache/shardingsphere-elasticjob/pull/1873/diff?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation#diff-ZWxhc3RpY2pvYi1saXRlL2VsYXN0aWNqb2ItbGl0ZS1jb3JlL3NyYy9tYWluL2phdmEvb3JnL2FwYWNoZS9zaGFyZGluZ3NwaGVyZS9lbGFzdGljam9iL2xpdGUvaW50ZXJuYWwvc2hhcmRpbmcvU2hhcmRpbmdTZXJ2aWNlLmphdmE=) | `98.83% <100.00%> (+0.13%)` | `0.00 <0.00> (ø)` | |
| [...re/elasticjob/lite/internal/server/ServerNode.java](https://codecov.io/gh/apache/shardingsphere-elasticjob/pull/1873/diff?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation#diff-ZWxhc3RpY2pvYi1saXRlL2VsYXN0aWNqb2ItbGl0ZS1jb3JlL3NyYy9tYWluL2phdmEvb3JnL2FwYWNoZS9zaGFyZGluZ3NwaGVyZS9lbGFzdGljam9iL2xpdGUvaW50ZXJuYWwvc2VydmVyL1NlcnZlck5vZGUuamF2YQ==) | `80.00% <0.00%> (-20.00%)` | `0.00% <0.00%> (ø%)` | |
| [...ite/internal/election/ElectionListenerManager.java](https://codecov.io/gh/apache/shardingsphere-elasticjob/pull/1873/diff?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation#diff-ZWxhc3RpY2pvYi1saXRlL2VsYXN0aWNqb2ItbGl0ZS1jb3JlL3NyYy9tYWluL2phdmEvb3JnL2FwYWNoZS9zaGFyZGluZ3NwaGVyZS9lbGFzdGljam9iL2xpdGUvaW50ZXJuYWwvZWxlY3Rpb24vRWxlY3Rpb25MaXN0ZW5lck1hbmFnZXIuamF2YQ==) | `92.00% <0.00%> (-8.00%)` | `0.00% <0.00%> (ø%)` | |
| [...re/elasticjob/lite/internal/setup/SetUpFacade.java](https://codecov.io/gh/apache/shardingsphere-elasticjob/pull/1873/diff?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation#diff-ZWxhc3RpY2pvYi1saXRlL2VsYXN0aWNqb2ItbGl0ZS1jb3JlL3NyYy9tYWluL2phdmEvb3JnL2FwYWNoZS9zaGFyZGluZ3NwaGVyZS9lbGFzdGljam9iL2xpdGUvaW50ZXJuYWwvc2V0dXAvU2V0VXBGYWNhZGUuamF2YQ==) | `89.47% <0.00%> (-5.27%)` | `0.00% <0.00%> (ø%)` | |
| [...e/shardingsphere/elasticjob/infra/env/IpUtils.java](https://codecov.io/gh/apache/shardingsphere-elasticjob/pull/1873/diff?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation#diff-ZWxhc3RpY2pvYi1pbmZyYS9lbGFzdGljam9iLWluZnJhLWNvbW1vbi9zcmMvbWFpbi9qYXZhL29yZy9hcGFjaGUvc2hhcmRpbmdzcGhlcmUvZWxhc3RpY2pvYi9pbmZyYS9lbnYvSXBVdGlscy5qYXZh) | `63.07% <0.00%> (-1.54%)` | `0.00% <0.00%> (ø%)` | |
| [...sticjob/reg/zookeeper/ZookeeperRegistryCenter.java](https://codecov.io/gh/apache/shardingsphere-elasticjob/pull/1873/diff?src=pr&el=tree&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation#diff-ZWxhc3RpY2pvYi1pbmZyYS9lbGFzdGljam9iLXJlZ2lzdHJ5LWNlbnRlci9zcmMvbWFpbi9qYXZhL29yZy9hcGFjaGUvc2hhcmRpbmdzcGhlcmUvZWxhc3RpY2pvYi9yZWcvem9va2VlcGVyL1pvb2tlZXBlclJlZ2lzdHJ5Q2VudGVyLmphdmE=) | `73.22% <0.00%> (+0.78%)` | `33.00% <0.00%> (+1.00%)` | |
------
[Continue to review full report at Codecov](https://codecov.io/gh/apache/shardingsphere-elasticjob/pull/1873?src=pr&el=continue&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation).
> **Legend** - [Click here to learn more](https://docs.codecov.io/docs/codecov-delta?utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation)
> `Δ = absolute <relative> (impact)`, `ø = not affected`, `? = missing data`
> Powered by [Codecov](https://codecov.io/gh/apache/shardingsphere-elasticjob/pull/1873?src=pr&el=footer&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation). Last update [05a0a2c...5c7ed82](https://codecov.io/gh/apache/shardingsphere-elasticjob/pull/1873?src=pr&el=lastupdated&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation). Read the [comment docs](https://docs.codecov.io/docs/pull-request-comments?utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Software+Foundation).
--
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
[GitHub] [shardingsphere-elasticjob] TeslaCN merged pull request #1873: Make sure supporting the case that job instances are crashed while ex…
Posted by GitBox <gi...@apache.org>.
TeslaCN merged pull request #1873:
URL: https://github.com/apache/shardingsphere-elasticjob/pull/1873
--
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
[GitHub] [shardingsphere-elasticjob] TeslaCN commented on pull request #1873: Make sure supporting the case that job instances are crashed while ex…
Posted by GitBox <gi...@apache.org>.
TeslaCN commented on pull request #1873:
URL: https://github.com/apache/shardingsphere-elasticjob/pull/1873#issuecomment-823736259
Hi @sucg
Have you tried the new feature "Run Targets" in IntelliJ IDEA 2021.1? I use this feature to simulate distributed deployment.
--
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
[GitHub] [shardingsphere-elasticjob] sucg commented on pull request #1873: Make sure supporting the case that job instances are crashed while ex…
Posted by GitBox <gi...@apache.org>.
sucg commented on pull request #1873:
URL: https://github.com/apache/shardingsphere-elasticjob/pull/1873#issuecomment-823732752
Hi @TeslaCN , I fixed it.
But I find that unit test coverage is reduced, I will analyze the code of the unit test later
And I have a question.
Could you tell me how to deploy it in docker? thank you.
If you have any questions, I am very happy to explain.
--
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
[GitHub] [shardingsphere-elasticjob] TeslaCN commented on pull request #1873: Make sure supporting the case that job instances are crashed while ex…
Posted by GitBox <gi...@apache.org>.
TeslaCN commented on pull request #1873:
URL: https://github.com/apache/shardingsphere-elasticjob/pull/1873#issuecomment-822927794
I deployed 3 nodes in Docker. Killed one when the job was running. But NPE occurred and the failover didn't worked.
My Job:
```java
@Slf4j
public final class FailoverMain {
private static final CoordinatorRegistryCenter REGISTRY_CENTER = Configurations.getCoordinatorRegistryCenter();
private static final int SLEEP_SECONDS = 20;
public static void main(final String[] args) {
SimpleJob job = shardingContext -> {
log.info("Start {}", shardingContext);
for (int i = 0; i < SLEEP_SECONDS; i++) {
try {
Thread.sleep(1000);
log.info("Handling {}", shardingContext.getShardingItem());
} catch (final InterruptedException ex) {
Thread.currentThread().interrupt();
ex.printStackTrace();
}
}
log.info("Done {}", shardingContext);
};
new ScheduleJobBootstrap(REGISTRY_CENTER, job, jobConfiguration()).schedule();
}
private static JobConfiguration jobConfiguration() {
return JobConfiguration.newBuilder("failover-job", 3)
.cron("0 * * * * ?")
.jobErrorHandlerType("LOG")
.monitorExecution(false)
.overwrite(true)
.failover(true)
.maxTimeDiffSeconds(1)
.addExtraConfigurations(Configurations.getTracingConfiguration())
.build();
}
}
```
```
02:27:08.871 [Curator-SafeNotifyService-0] ERROR org.apache.curator.framework.listen.MappingListenerManager - Listener (org.apache.shardingsphere.elasticjob.lite.internal.failover.FailoverListenerManager$JobCrashedJobListener@698122b2) threw an exception
java.lang.NullPointerException: null
at java.io.StringReader.<init>(StringReader.java:50) ~[?:1.8.0_275]
at org.yaml.snakeyaml.reader.StreamReader.<init>(StreamReader.java:63) ~[snakeyaml-1.26.jar:?]
at org.yaml.snakeyaml.Yaml.loadAs(Yaml.java:452) ~[snakeyaml-1.26.jar:?]
at org.apache.shardingsphere.elasticjob.infra.yaml.YamlEngine.unmarshal(YamlEngine.java:50) ~[elasticjob-infra-common-3.0.0-SNAPSHOT.jar:3.0.0-SNAPSHOT]
at org.apache.shardingsphere.elasticjob.lite.internal.sharding.ShardingService.getCrashedShardingItems(ShardingService.java:185) ~[elasticjob-lite-core-3.0.0-SNAPSHOT.jar:3.0.0-SNAPSHOT]
at org.apache.shardingsphere.elasticjob.lite.internal.failover.FailoverListenerManager$JobCrashedJobListener.dataChanged(FailoverListenerManager.java:86) ~[elasticjob-lite-core-3.0.0-SNAPSHOT.jar:3.0.0-SNAPSHOT]
at org.apache.shardingsphere.elasticjob.lite.internal.listener.AbstractJobListener.event(AbstractJobListener.java:40) ~[elasticjob-lite-core-3.0.0-SNAPSHOT.jar:3.0.0-SNAPSHOT]
at org.apache.curator.framework.recipes.cache.CuratorCacheImpl.lambda$null$8(CuratorCacheImpl.java:286) ~[curator-recipes-5.1.0.jar:5.1.0]
at org.apache.curator.framework.listen.MappingListenerManager.lambda$forEach$0(MappingListenerManager.java:92) ~[curator-framework-5.1.0.jar:5.1.0]
at org.apache.curator.framework.listen.MappingListenerManager.forEach(MappingListenerManager.java:89) ~[curator-framework-5.1.0.jar:5.1.0]
at org.apache.curator.framework.listen.StandardListenerManager.forEach(StandardListenerManager.java:89) ~[curator-framework-5.1.0.jar:5.1.0]
at org.apache.curator.framework.recipes.cache.CuratorCacheImpl.lambda$callListeners$10(CuratorCacheImpl.java:293) ~[curator-recipes-5.1.0.jar:5.1.0]
at java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1640) [?:1.8.0_275]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_275]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_275]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_275]
```
--
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
[GitHub] [shardingsphere-elasticjob] TeslaCN commented on pull request #1873: Make sure supporting the case that job instances are crashed while ex…
Posted by GitBox <gi...@apache.org>.
TeslaCN commented on pull request #1873:
URL: https://github.com/apache/shardingsphere-elasticjob/pull/1873#issuecomment-823684416
Hi @sucg
I've noticed that the testcases failed. Could you fix it?
--
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
[GitHub] [shardingsphere-elasticjob] TeslaCN merged pull request #1873: Make sure supporting the case that job instances are crashed while ex…
Posted by GitBox <gi...@apache.org>.
TeslaCN merged pull request #1873:
URL: https://github.com/apache/shardingsphere-elasticjob/pull/1873
--
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
[GitHub] [shardingsphere-elasticjob] TeslaCN commented on pull request #1873: Make sure supporting the case that job instances are crashed while ex…
Posted by GitBox <gi...@apache.org>.
TeslaCN commented on pull request #1873:
URL: https://github.com/apache/shardingsphere-elasticjob/pull/1873#issuecomment-822922371
Hi @sucg
Thanks for your contribution! Before merging this PR, I'll make some tests about failover.
--
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
[GitHub] [shardingsphere-elasticjob] TeslaCN edited a comment on pull request #1873: Make sure supporting the case that job instances are crashed while ex…
Posted by GitBox <gi...@apache.org>.
TeslaCN edited a comment on pull request #1873:
URL: https://github.com/apache/shardingsphere-elasticjob/pull/1873#issuecomment-822927794
I deployed 3 nodes in Docker. Killed one when the job was running. But NPE occurred and the failover didn't worked. Did I missed something?
My Job:
```java
@Slf4j
public final class FailoverMain {
private static final CoordinatorRegistryCenter REGISTRY_CENTER = Configurations.getCoordinatorRegistryCenter();
private static final int SLEEP_SECONDS = 20;
public static void main(final String[] args) {
SimpleJob job = shardingContext -> {
log.info("Start {}", shardingContext);
for (int i = 0; i < SLEEP_SECONDS; i++) {
try {
Thread.sleep(1000);
log.info("Handling {}", shardingContext.getShardingItem());
} catch (final InterruptedException ex) {
Thread.currentThread().interrupt();
ex.printStackTrace();
}
}
log.info("Done {}", shardingContext);
};
new ScheduleJobBootstrap(REGISTRY_CENTER, job, jobConfiguration()).schedule();
}
private static JobConfiguration jobConfiguration() {
return JobConfiguration.newBuilder("failover-job", 3)
.cron("0 * * * * ?")
.jobErrorHandlerType("LOG")
.monitorExecution(false)
.overwrite(true)
.failover(true)
.maxTimeDiffSeconds(1)
.addExtraConfigurations(Configurations.getTracingConfiguration())
.build();
}
}
```
```
02:27:08.871 [Curator-SafeNotifyService-0] ERROR org.apache.curator.framework.listen.MappingListenerManager - Listener (org.apache.shardingsphere.elasticjob.lite.internal.failover.FailoverListenerManager$JobCrashedJobListener@698122b2) threw an exception
java.lang.NullPointerException: null
at java.io.StringReader.<init>(StringReader.java:50) ~[?:1.8.0_275]
at org.yaml.snakeyaml.reader.StreamReader.<init>(StreamReader.java:63) ~[snakeyaml-1.26.jar:?]
at org.yaml.snakeyaml.Yaml.loadAs(Yaml.java:452) ~[snakeyaml-1.26.jar:?]
at org.apache.shardingsphere.elasticjob.infra.yaml.YamlEngine.unmarshal(YamlEngine.java:50) ~[elasticjob-infra-common-3.0.0-SNAPSHOT.jar:3.0.0-SNAPSHOT]
at org.apache.shardingsphere.elasticjob.lite.internal.sharding.ShardingService.getCrashedShardingItems(ShardingService.java:185) ~[elasticjob-lite-core-3.0.0-SNAPSHOT.jar:3.0.0-SNAPSHOT]
at org.apache.shardingsphere.elasticjob.lite.internal.failover.FailoverListenerManager$JobCrashedJobListener.dataChanged(FailoverListenerManager.java:86) ~[elasticjob-lite-core-3.0.0-SNAPSHOT.jar:3.0.0-SNAPSHOT]
at org.apache.shardingsphere.elasticjob.lite.internal.listener.AbstractJobListener.event(AbstractJobListener.java:40) ~[elasticjob-lite-core-3.0.0-SNAPSHOT.jar:3.0.0-SNAPSHOT]
at org.apache.curator.framework.recipes.cache.CuratorCacheImpl.lambda$null$8(CuratorCacheImpl.java:286) ~[curator-recipes-5.1.0.jar:5.1.0]
at org.apache.curator.framework.listen.MappingListenerManager.lambda$forEach$0(MappingListenerManager.java:92) ~[curator-framework-5.1.0.jar:5.1.0]
at org.apache.curator.framework.listen.MappingListenerManager.forEach(MappingListenerManager.java:89) ~[curator-framework-5.1.0.jar:5.1.0]
at org.apache.curator.framework.listen.StandardListenerManager.forEach(StandardListenerManager.java:89) ~[curator-framework-5.1.0.jar:5.1.0]
at org.apache.curator.framework.recipes.cache.CuratorCacheImpl.lambda$callListeners$10(CuratorCacheImpl.java:293) ~[curator-recipes-5.1.0.jar:5.1.0]
at java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1640) [?:1.8.0_275]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_275]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_275]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_275]
```
--
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