feat(1.4.0-beta1): 1. 优化代码
This commit is contained in:
parent
5c6703a0a1
commit
52b633967c
@ -105,7 +105,7 @@ services:
|
||||
- "5236:5236"
|
||||
volumes:
|
||||
- dm8:/opt/dmdbms/data
|
||||
# docker compose exec dm8 bash -c "/opt/dmdbms/bin/disql SYSDBA/SYSDBA001 \`/tmp/schema.sql"
|
||||
# docker compose exec dm8 bash -c "/opt/dmdbms/bin/disql SYSDBA/SYSDBA_dm001 \`/tmp/schema.sql"
|
||||
- ../sql/snail_job_dm8.sql:/tmp/schema.sql:ro
|
||||
|
||||
kingbase:
|
||||
|
@ -29,6 +29,7 @@ import java.util.concurrent.atomic.AtomicLong;
|
||||
*/
|
||||
@Component
|
||||
@Slf4j
|
||||
@Deprecated
|
||||
public class SegmentIdGenerator implements IdGenerator, Lifecycle {
|
||||
|
||||
/**
|
||||
|
@ -93,9 +93,7 @@ public class ScanRetryActor extends AbstractActor {
|
||||
return true;
|
||||
}
|
||||
|
||||
boolean b = rateLimiterHandler.tryAcquire(partitionTasks.size());
|
||||
log.warn("获取令牌, b:[{}] size:[{}]", b, partitionTasks.size());
|
||||
if (!b) {
|
||||
if (!rateLimiterHandler.tryAcquire(partitionTasks.size())) {
|
||||
log.warn("当前节点触发限流");
|
||||
return true;
|
||||
}
|
||||
|
Loading…
Reference in New Issue
Block a user