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