From the logs we see that the client is able to perform discovery of bookies and in order to perform this operation it must read from ZooKeeper.
Do you see errors on ZooKeeper server side ? Can you enable DEBUG log level on your client application ? Enrico Il giorno 04/12/19, 10:50 "Wei Liu" <liuwe...@gmail.com<mailto:liuwe...@gmail.com>> ha scritto: I use the zkCli.sh client to see that there is no new id under this path "/ledgers/00/0000". Flavio Junqueira <f...@apache.org<mailto:f...@apache.org>> 于2019年12月4日周三 下午5:48写道: Do you know if the ledger znode has been created in zk? Maybe use the zkCli to check it. -Flavio On 4 Dec 2019, at 10:35, Wei Liu <liuwe...@gmail.com<mailto:liuwe...@gmail.com>> wrote: Dear Enrico: 1) I don't see the new ledger id on zk 2) It looks like the server is not return? at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) at java.util.concurrent.CompletableFuture$Signaller.block(CompletableFuture.java:1695) at java.util.concurrent.ForkJoinPool.managedBlock(ForkJoinPool.java:3323) at java.util.concurrent.CompletableFuture.timedGet(CompletableFuture.java:1775) at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1915) at org.apache.bookkeeper.client.SyncCallbackUtils.waitForResult(SyncCallbackUtils.java:55) at org.apache.bookkeeper.client.BookKeeper.createLedger(BookKeeper.java:918) at org.apache.bookkeeper.client.BookKeeper.createLedger(BookKeeper.java:870) at org.apache.bookkeeper.client.BookKeeper.createLedger(BookKeeper.java:851) at com.mytest.App.CreateLedger(App.java:38) at com.mytest.App.main(App.java:259) 3) Below is jvm stack: Full thread dump Java HotSpot(TM) 64-Bit Server VM (25.191-b12 mixed mode): "Attach Listener" #23 daemon prio=9 os_prio=0 tid=0x00007fbc18001000 nid=0x5636 waiting on condition [0x0000000000000000] java.lang.Thread.State: RUNNABLE "main-EventThread" #21 daemon prio=5 os_prio=0 tid=0x00007fbc60645800 nid=0x55ff waiting on condition [0x00007fbc38c6d000] java.lang.Thread.State: WAITING (parking) at sun.misc.Unsafe.park(Native Method) - parking to wait for <0x000000076ddd7868> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) at java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) at org.apache.zookeeper.ClientCnxn$EventThread.run(ClientCnxn.java:504) "main-SendThread(10.209.242.147:2181<http://10.209.242.147:2181/>)" #20 daemon prio=5 os_prio=0 tid=0x00007fbc60649000 nid=0x55fe runnable [0x00007fbc38d6e000] java.lang.Thread.State: RUNNABLE at sun.nio.ch.EPollArrayWrapper.epollWait(Native Method) at sun.nio.ch.EPollArrayWrapper.poll(EPollArrayWrapper.java:269) at sun.nio.ch.EPollSelectorImpl.doSelect(EPollSelectorImpl.java:93) at sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:86) - locked <0x000000076dd86f50> (a sun.nio.ch.Util$3) - locked <0x000000076dd86ec8> (a java.util.Collections$UnmodifiableSet) - locked <0x000000076dd85b30> (a sun.nio.ch.EPollSelectorImpl) at sun.nio.ch.SelectorImpl.select(SelectorImpl.java:97) at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:349) at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1145) "BookKeeperClientWorker-OrderedExecutor-7-0" #19 prio=5 os_prio=0 tid=0x00007fbc605ce800 nid=0x55fd waiting on condition [0x00007fbc39298000] java.lang.Thread.State: WAITING (parking) at sun.misc.Unsafe.park(Native Method) - parking to wait for <0x000000076dac6570> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) at java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) at java.lang.Thread.run(Thread.java:748) "BookKeeperClientWorker-OrderedExecutor-6-0" #18 prio=5 os_prio=0 tid=0x00007fbc605cd000 nid=0x55fc waiting on condition [0x00007fbc39399000] java.lang.Thread.State: WAITING (parking) at sun.misc.Unsafe.park(Native Method) - parking to wait for <0x000000076dac3da8> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) at java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) at java.lang.Thread.run(Thread.java:748) "BookKeeperClientWorker-OrderedExecutor-5-0" #17 prio=5 os_prio=0 tid=0x00007fbc605cb800 nid=0x55fb waiting on condition [0x00007fbc3949a000] java.lang.Thread.State: WAITING (parking) at sun.misc.Unsafe.park(Native Method) - parking to wait for <0x000000076dac1630> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) at java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) at java.lang.Thread.run(Thread.java:748) "BookKeeperClientWorker-OrderedExecutor-4-0" #16 prio=5 os_prio=0 tid=0x00007fbc605c9800 nid=0x55fa waiting on condition [0x00007fbc3959b000] java.lang.Thread.State: WAITING (parking) at sun.misc.Unsafe.park(Native Method) - parking to wait for <0x000000076dabeeb8> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) at java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) at java.lang.Thread.run(Thread.java:748) "BookKeeperClientWorker-OrderedExecutor-3-0" #15 prio=5 os_prio=0 tid=0x00007fbc605c8000 nid=0x55f9 waiting on condition [0x00007fbc3969c000] java.lang.Thread.State: WAITING (parking) at sun.misc.Unsafe.park(Native Method) - parking to wait for <0x000000076dabc740> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) at java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) at java.lang.Thread.run(Thread.java:748) "BookKeeperClientWorker-OrderedExecutor-2-0" #14 prio=5 os_prio=0 tid=0x00007fbc605c6000 nid=0x55f8 waiting on condition [0x00007fbc3979d000] java.lang.Thread.State: WAITING (parking) at sun.misc.Unsafe.park(Native Method) - parking to wait for <0x000000076dab9f98> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) at java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) at java.lang.Thread.run(Thread.java:748) "BookKeeperClientWorker-OrderedExecutor-1-0" #13 prio=5 os_prio=0 tid=0x00007fbc605c4800 nid=0x55f7 waiting on condition [0x00007fbc3989e000] java.lang.Thread.State: WAITING (parking) at sun.misc.Unsafe.park(Native Method) - parking to wait for <0x000000076dab7820> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) at java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) at java.lang.Thread.run(Thread.java:748) "BookKeeperClientWorker-OrderedExecutor-0-0" #12 prio=5 os_prio=0 tid=0x00007fbc605c3000 nid=0x55f6 waiting on condition [0x00007fbc3999f000] java.lang.Thread.State: WAITING (parking) at sun.misc.Unsafe.park(Native Method) - parking to wait for <0x000000076da97970> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039) at java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442) at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) at java.lang.Thread.run(Thread.java:748) "BookKeeperClientScheduler-OrderedScheduler-0-0" #11 prio=5 os_prio=0 tid=0x00007fbc605b4800 nid=0x55f5 waiting on condition [0x00007fbc39aa0000] java.lang.Thread.State: TIMED_WAITING (parking) at sun.misc.Unsafe.park(Native Method) - parking to wait for <0x000000076d5fa668> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:1093) at java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take(ScheduledThreadPoolExecutor.java:809) at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) at java.lang.Thread.run(Thread.java:748) "Service Thread" #9 daemon prio=9 os_prio=0 tid=0x00007fbc6021a800 nid=0x55f3 runnable [0x0000000000000000] java.lang.Thread.State: RUNNABLE "C1 CompilerThread3" #8 daemon prio=9 os_prio=0 tid=0x00007fbc6020f800 nid=0x55f2 waiting on condition [0x0000000000000000] java.lang.Thread.State: RUNNABLE "C2 CompilerThread2" #7 daemon prio=9 os_prio=0 tid=0x00007fbc6020d800 nid=0x55f1 waiting on condition [0x0000000000000000] java.lang.Thread.State: RUNNABLE "C2 CompilerThread1" #6 daemon prio=9 os_prio=0 tid=0x00007fbc6020b800 nid=0x55f0 waiting on condition [0x0000000000000000] java.lang.Thread.State: RUNNABLE "C2 CompilerThread0" #5 daemon prio=9 os_prio=0 tid=0x00007fbc60208800 nid=0x55ef waiting on condition [0x0000000000000000] java.lang.Thread.State: RUNNABLE "Signal Dispatcher" #4 daemon prio=9 os_prio=0 tid=0x00007fbc60207000 nid=0x55ee runnable [0x0000000000000000] java.lang.Thread.State: RUNNABLE "Finalizer" #3 daemon prio=8 os_prio=0 tid=0x00007fbc601d5000 nid=0x55ed in Object.wait() [0x00007fbc3aceb000] java.lang.Thread.State: WAITING (on object monitor) at java.lang.Object.wait(Native Method) - waiting on <0x000000076cb08ed0> (a java.lang.ref.ReferenceQueue$Lock) at java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:144) - locked <0x000000076cb08ed0> (a java.lang.ref.ReferenceQueue$Lock) at java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:165) at java.lang.ref.Finalizer$FinalizerThread.run(Finalizer.java:216) "Reference Handler" #2 daemon prio=10 os_prio=0 tid=0x00007fbc601d2800 nid=0x55ec in Object.wait() [0x00007fbc3adec000] java.lang.Thread.State: WAITING (on object monitor) at java.lang.Object.wait(Native Method) - waiting on <0x000000076cb06bf8> (a java.lang.ref.Reference$Lock) at java.lang.Object.wait(Object.java:502) at java.lang.ref.Reference.tryHandlePending(Reference.java:191) - locked <0x000000076cb06bf8> (a java.lang.ref.Reference$Lock) at java.lang.ref.Reference$ReferenceHandler.run(Reference.java:153) "main" #1 prio=5 os_prio=0 tid=0x00007fbc6000b800 nid=0x55e2 waiting on condition [0x00007fbc6975c000] java.lang.Thread.State: TIMED_WAITING (parking) at sun.misc.Unsafe.park(Native Method) - parking to wait for <0x000000076f04d0b8> (a java.util.concurrent.CompletableFuture$Signaller) at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) at java.util.concurrent.CompletableFuture$Signaller.block(CompletableFuture.java:1695) at java.util.concurrent.ForkJoinPool.managedBlock(ForkJoinPool.java:3323) at java.util.concurrent.CompletableFuture.timedGet(CompletableFuture.java:1775) at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1915) at org.apache.bookkeeper.client.SyncCallbackUtils.waitForResult(SyncCallbackUtils.java:55) at org.apache.bookkeeper.client.BookKeeper.createLedger(BookKeeper.java:918) at org.apache.bookkeeper.client.BookKeeper.createLedger(BookKeeper.java:870) at org.apache.bookkeeper.client.BookKeeper.createLedger(BookKeeper.java:851) at com.mytest.App.CreateLedger(App.java:38) at com.mytest.App.main(App.java:259) "VM Thread" os_prio=0 tid=0x00007fbc601c8800 nid=0x55eb runnable "GC task thread#0 (ParallelGC)" os_prio=0 tid=0x00007fbc60021000 nid=0x55e3 runnable "GC task thread#1 (ParallelGC)" os_prio=0 tid=0x00007fbc60023000 nid=0x55e4 runnable "GC task thread#2 (ParallelGC)" os_prio=0 tid=0x00007fbc60024800 nid=0x55e5 runnable "GC task thread#3 (ParallelGC)" os_prio=0 tid=0x00007fbc60026800 nid=0x55e6 runnable "GC task thread#4 (ParallelGC)" os_prio=0 tid=0x00007fbc60028000 nid=0x55e7 runnable "GC task thread#5 (ParallelGC)" os_prio=0 tid=0x00007fbc6002a000 nid=0x55e8 runnable "GC task thread#6 (ParallelGC)" os_prio=0 tid=0x00007fbc6002b800 nid=0x55e9 runnable "GC task thread#7 (ParallelGC)" os_prio=0 tid=0x00007fbc6002d800 nid=0x55ea runnable "VM Periodic Task Thread" os_prio=0 tid=0x00007fbc6021e000 nid=0x55f4 waiting on condition JNI global references: 392 Enrico Olivelli - Diennea <enrico.olive...@diennea.com<mailto:enrico.olive...@diennea.com>> 于2019年12月4日周三 下午3:48写道: Liu, From your logs I see that the client is able to reach ZooKeeper, so I think that createLedger should complete. Are you sure that your program is not stuck at “addEntry” ? Is your client machine able to connect to the bookies ? You can dump the stacktrace of the JVM with jstack I suggest you to use the org.apache.bookkeeper.client.api package, the code is like this (I don’t have an IDE now, I am not sure it compiles, but it gives an idea): org.apache.bookkeeper.client.api.Bookkeeper bookkeeper = org.apache.bookkeeper.client.api.Bookkeeper.forConfig(config).build(); org.apache.bookkeeper.client.api.WriteHandle handle = bookkeeper.newCreateLedgerOp() .withEnsembleSize(1) .withWriteQuorumSize(1) .withAckQuorumSize(1) .withDigestType(DigestType.CRC32C) .execute() .get(); long entryId = handle.append("Some entry data".getBytes()); long entryId1 = handle. append ("111Some entry data".getBytes()); long entryId2 = handle. append ("222Some entry data".getBytes()); // always close a WriteHandle !!! handle.close(); Enrico Il giorno 04/12/19, 03:43 "Wei Liu" <liuwe...@gmail.com<mailto:liuwe...@gmail.com>> ha scritto: Dear All: I can't create ledger using bookkeeper 4.10.0 version. Below is my test code: static String connectionString = "xxx.xxx.xxx.xxx:2181"; bkClient = new BookKeeper(connectionString); byte[] password = "some-password".getBytes(); handle = bkClient.createLedger(BookKeeper.DigestType.MAC, password); long entryId = handle.addEntry("Some entry data".getBytes()); long entryId1 = handle.addEntry("111Some entry data".getBytes()); long entryId2 = handle.addEntry("222Some entry data".getBytes()); Stuck in 'createLedger' when the program is running. Below is log: 2019-12-04 10:13:39,236 - INFO - [main:MetadataDrivers@107] - BookKeeper metadata driver manager initialized 2019-12-04 10:13:39,239 - INFO - [main:MetadataDrivers@107] - BookKeeper metadata driver manager initialized 2019-12-04 10:13:39,240 - INFO - [main:MetadataDrivers@107] - BookKeeper metadata driver manager initialized 2019-12-04 10:13:39,247 - INFO - [main:ZKMetadataDriverBase@192] - Initialize zookeeper metadata driver at metadata service uri zk+null://xxx.xxxx.xxx.xxx:2181/ledgers : zkServers = xxx.xxxx.xxx.xxx, ledgersRootPath = /ledgers. 2019-12-04 10:13:39,288 - INFO - [main-EventThread:ZooKeeperWatcherBase@130] - ZooKeeper client is connected now. 2019-12-04 10:13:39,411 - ERROR - [main:RackawareEnsemblePlacementPolicyImpl@267] - Failed to initialize DNS Resolver org.apache.bookkeeper.net.ScriptBasedMapping, used default subnet resolver : java.lang.RuntimeException: No network topology script is found when using script based DNS resolver. 2019-12-04 10:13:39,430 - INFO - [main:RackawareEnsemblePlacementPolicyImpl@214] - Initialize rackaware ensemble placement policy @ <Bookie:127.0.1.1:0<http://127.0.1.1:0/>> @ /default-rack : org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy$DefaultResolver. 2019-12-04 10:13:39,430 - INFO - [main:RackawareEnsemblePlacementPolicyImpl@224] - Not weighted 2019-12-04 10:13:39,433 - INFO - [main:BookKeeper@509] - Weighted ledger placement is not enabled 2019-12-04 10:13:39,458 - INFO - [BookKeeperClientScheduler-OrderedScheduler-0-0:NetworkTopologyImpl@429] - Adding a new node: /default-rack/xxx.xxxx.xxx.xxx:3181 2019-12-04 10:13:39,789 - INFO - [BookKeeperClientScheduler-OrderedScheduler-0-0:NetworkTopologyImpl@429] - Adding a new node: /default-rack/xxx.xxxx.xxx.xxx:3181 2019-12-04 10:13:39,791 - INFO - [BookKeeperClientScheduler-OrderedScheduler-0-0:NetworkTopologyImpl@429] - Adding a new node: /default-rack/xxx.xxxx.xxx.xxx:4181 2019-12-04 10:13:40,123 - INFO - [BookKeeperClientScheduler-OrderedScheduler-0-0:NetworkTopologyImpl@429] - Adding a new node: /default-rack/xxx.xxxx.xxx.xxx:3181 11111 2019-12-04 10:13:40,153 - WARN - [main:BookieWatcherImpl@240] - New ensemble: [xxx.xxxx.xxx.xxx:4181, xxx.xxxx.xxx.xxx:3181, xxx.xxxx.xxx.xxx:3181] is not adhering to Placement Policy. quarantinedBookies: [] -- 一个人只拥有今生今世是不够的, 他还应该拥有诗意的世界。 liuwe...@gmail.com<mailto:liuwe...@gmail.com> ________________________________ CONFIDENTIALITY & PRIVACY NOTICE This e-mail (including any attachments) is strictly confidential and may also contain privileged information. If you are not the intended recipient you are not authorised to read, print, save, process or disclose this message. If you have received this message by mistake, please inform the sender immediately and destroy this e-mail, its attachments and any copies. Any use, distribution, reproduction or disclosure by any person other than the intended recipient is strictly prohibited and the person responsible may incur in penalties. The use of this e-mail is only for professional purposes; there is no guarantee that the correspondence towards this e-mail will be read only by the recipient, because, under certain circumstances, there may be a need to access this email by third subjects belonging to the Company. -- 一个人只拥有今生今世是不够的, 他还应该拥有诗意的世界。 liuwe...@gmail.com<mailto:liuwe...@gmail.com> -- 一个人只拥有今生今世是不够的, 他还应该拥有诗意的世界。 liuwe...@gmail.com<mailto:liuwe...@gmail.com> ________________________________ CONFIDENTIALITY & PRIVACY NOTICE This e-mail (including any attachments) is strictly confidential and may also contain privileged information. If you are not the intended recipient you are not authorised to read, print, save, process or disclose this message. If you have received this message by mistake, please inform the sender immediately and destroy this e-mail, its attachments and any copies. Any use, distribution, reproduction or disclosure by any person other than the intended recipient is strictly prohibited and the person responsible may incur in penalties. The use of this e-mail is only for professional purposes; there is no guarantee that the correspondence towards this e-mail will be read only by the recipient, because, under certain circumstances, there may be a need to access this email by third subjects belonging to the Company.