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]
