I use the zkCli.sh client to see that there is no new id under this path "/ledgers/00/0000".
Flavio Junqueira <[email protected]> 于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 <[email protected]> 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)" #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 <[email protected]> 于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" <[email protected]> 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> @ /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: [] >> >> -- >> >> 一个人只拥有今生今世是不够的， >> 他还应该拥有诗意的世界。 >> >> [email protected] >> >> ------------------------------ >> >> 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. >> > > > -- > 一个人只拥有今生今世是不够的， > 他还应该拥有诗意的世界。 > > [email protected] > > > -- 一个人只拥有今生今世是不够的， 他还应该拥有诗意的世界。 [email protected]
