We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Is your feature request related to a problem? Please describe: TwoPhaseCommitter constructor can not support Customized thread pool size
Describe the feature you'd like: public TwoPhaseCommitter(TiSession session, long startTime, long lockTTL,ExecutorService executorService) { this( session, startTime, lockTTL, TXN_COMMIT_BATCH_SIZE, TXN_COMMIT_BATCH_SIZE, WRITE_BUFFER_SIZE, 1, true, 3, executorService }
Describe alternatives you've considered: default pool size too large and every TwoPhaseCommitter obejct have new ExecutorService
Teachability, Documentation, Adoption, Migration Strategy: TwoPhaseCommitter twoPhaseCommitter = new TwoPhaseCommitter(session, startTime, lockTTL, executorService);
The text was updated successfully, but these errors were encountered:
help me see see
Sorry, something went wrong.
add TwoPhaseCommitter new Constructor contains executorService(tikv#774)
5d22be4
178c948
Signed-off-by: b.tian <b.tian@trip.com>
[close tikv#774]remove redundant code
604eafb
700fad0
No branches or pull requests
Feature Request
Is your feature request related to a problem? Please describe:
TwoPhaseCommitter constructor can not support Customized thread pool size
Describe the feature you'd like:
public TwoPhaseCommitter(TiSession session, long startTime, long lockTTL,ExecutorService executorService) {
this(
session,
startTime,
lockTTL,
TXN_COMMIT_BATCH_SIZE,
TXN_COMMIT_BATCH_SIZE,
WRITE_BUFFER_SIZE,
1,
true,
3,
executorService
}
Describe alternatives you've considered:
default pool size too large and every TwoPhaseCommitter obejct have new ExecutorService
Teachability, Documentation, Adoption, Migration Strategy:
TwoPhaseCommitter twoPhaseCommitter = new TwoPhaseCommitter(session, startTime, lockTTL, executorService);
The text was updated successfully, but these errors were encountered: