diff --git a/src/main/java/com/baidu/fsg/uid/worker/DisposableWorkerIdAssigner.java b/src/main/java/com/baidu/fsg/uid/worker/DisposableWorkerIdAssigner.java index 26570c9..e17dae8 100644 --- a/src/main/java/com/baidu/fsg/uid/worker/DisposableWorkerIdAssigner.java +++ b/src/main/java/com/baidu/fsg/uid/worker/DisposableWorkerIdAssigner.java @@ -53,8 +53,7 @@ public long assignWorkerId() { // add worker node for new (ignore the same IP + PORT) workerNodeDAO.addWorkerNode(workerNodeEntity); LOGGER.info("Add worker node:" + workerNodeEntity); - - return workerNodeEntity.getId(); + return workerNodeEntity.getId() & ~(-1L << 13); } /**