File tree Expand file tree Collapse file tree 2 files changed +5
-2
lines changed
core/src/main/java/tech/ydb/core/impl Expand file tree Collapse file tree 2 files changed +5
-2
lines changed Original file line number Diff line number Diff line change 99import org .slf4j .Logger ;
1010import org .slf4j .LoggerFactory ;
1111
12+
1213/**
1314 *
1415 * @author Aleksandr Gorshenin
1516 */
1617public class YdbSchedulerFactory {
17- private static final long WAIT_FOR_SHUTDOWN_MS = 1000 ;
18+ /** Scheduler waits for closing of channels so this timeout must be greater that GrpcChannel.WAIT_FOR_CLOSING_MS */
19+ private static final long WAIT_FOR_SHUTDOWN_MS = 2 * 5000 ;
1820
1921 private static final Logger logger = LoggerFactory .getLogger (YdbSchedulerFactory .class );
2022
Original file line number Diff line number Diff line change 1515 * @author Nikolay Perfilov
1616 */
1717public class GrpcChannel {
18- private static final long WAIT_FOR_CLOSING_MS = 1000 ;
18+ /* Channel shutdown waits for finish of active grpc calls, so there must be enough time to complete them all */
19+ private static final long WAIT_FOR_CLOSING_MS = 5000 ;
1920 private static final Logger logger = LoggerFactory .getLogger (GrpcChannel .class );
2021
2122 private final EndpointRecord endpoint ;
You can’t perform that action at this time.
0 commit comments