[
https://issues.apache.org/jira/browse/IGNITE-17407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Pavel Pereslegin updated IGNITE-17407:
--------------------------------------
Description:
The snapshot rate limit does not work correctly when set to values greater
than 100 MB per second.
Currently, the snapshot transfer rate is limited by the BasicRateLimiter.
Testing shows that limiter is unable to give more than 119 304 647 permits per
second.
{code:java}
long dataSize = U.GB;
BasicRateLimiter limiter = new BasicRateLimiter(dataSize / 2);
int blockSize =
IgniteSnapshotManager.SNAPSHOT_LIMITED_TRANSFER_BLOCK_SIZE_BYTES;
long start = System.currentTimeMillis();
for (int i = 0; i < dataSize; i+=blockSize)
limiter.acquire(blockSize);
long totalSec =
TimeUnit.MILLISECONDS.toSeconds(System.currentTimeMillis() - start);
System.out.println("Speed= " + (dataSize / totalSec));
{code}
was:
The snapshot rate limit does not work correctly when set to values greater
than 100 MB per second.
Currently, the snapshot transfer rate is limited by the BasicRateLimiter.
Testing shows that limiter is unable to give more than 119 304 647 permits per
second.
> The snapshot rate limit does not work correctly when set to values greater
> than 100 MB per second.
> ----------------------------------------------------------------------------------------------------
>
> Key: IGNITE-17407
> URL: https://issues.apache.org/jira/browse/IGNITE-17407
> Project: Ignite
> Issue Type: Bug
> Reporter: Pavel Pereslegin
> Assignee: Pavel Pereslegin
> Priority: Major
>
> The snapshot rate limit does not work correctly when set to values greater
> than 100 MB per second.
> Currently, the snapshot transfer rate is limited by the BasicRateLimiter.
> Testing shows that limiter is unable to give more than 119 304 647 permits
> per second.
> {code:java}
> long dataSize = U.GB;
> BasicRateLimiter limiter = new BasicRateLimiter(dataSize / 2);
> int blockSize =
> IgniteSnapshotManager.SNAPSHOT_LIMITED_TRANSFER_BLOCK_SIZE_BYTES;
> long start = System.currentTimeMillis();
> for (int i = 0; i < dataSize; i+=blockSize)
> limiter.acquire(blockSize);
> long totalSec =
> TimeUnit.MILLISECONDS.toSeconds(System.currentTimeMillis() - start);
> System.out.println("Speed= " + (dataSize / totalSec));
> {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
