111111 #8318
Closed
111111 #8318
Conversation
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
… find ACL configuration related (#6885) Co-authored-by: fengbaichao <fbc@163.com>
* Add attributesBuilderSupplier for BrokerMetricsManager * fix * add initial value
…address of broker (#6909) Fix the problem that the proxy in the cluster mode obtains the wrong address of the broker.
…sManager caused the controller mode to fail to start.
…GroupTable method
Co-authored-by: y00421926 <yuzhou4@huawei.com>
Co-authored-by: RongtongJin <jinrongtong16@mails.ucas.ac.cn>
…e and optimize fetch code (#6952) If cq dispatch smaller than local store min offset, do self-healing logic for storage and rebuild automatically
* Use CompositeByteBuf to prevent mem_copy. * Fix code * Add tests * Remove useless UTs * Remove unused imports. --------- Co-authored-by: RongtongJin <jinrongtong16@mails.ucas.ac.cn>
…f tail (#7599) * fix dledger recover abnormally may lost consume queue of tail * fix correct storeTimestampPosition when bornhost is v6 * fix correct SYSFLAG offset --------- Co-authored-by: 赵宇晗 <zhaoyuhan@xiaomi.com>
* add request codes' distribution and timing messages' distribution * remove the requestCode distribution. * add delay message latency distribution. * add transaction metrics * transaction metric of topics finished, v1. * add the transaction metrics, to be tested. * fix the judgement of putMessageResult * optimize. * add config. * fix test case. * add unit tests for transactionMetrics. * remove chinese character * add rocksdb metrics. * add more rocksdb metrics. * fix NPE * avoid the total time is 0. * add license * remove useless import.
…ot return ACK (#7773) * add stop pop situation. * refactor the imports * modify the threadhold into threshold. * checkstyle
…ByCluster to avoid unnecessary deserialization (#7778)
* jRaft-Controller Implemention * fix bazel build * reformat code * remove fury dependence * fix bazel build * resolve conflict * clear code * Optimize code style * Optimize code style * Optimize code style * revert style only change fix code style rollback an unexpected modification. * Update Producer.java * chore: move raft startup to start method * chore: use jraftconfig to collect all configs about jraft * fix: fix wrong store path because init use string constant * fix: fix CONTROLLER_NOT_LEADER error in follower * chore: seperate jraft and controller log * chore: fix conflict with develop * chore: add comment to clear the filter logic * feat: triggerElectMaster will retry when failed * feat: when controller all restart, we use a timestamp to trace the first heartbeat, avoid to elect again * fix: implements Serializable to enable snapshot serialize * fix: use for loop to simple the elect retry * chore: update jraft version * chore: opt import --------- Co-authored-by: leizhiyuan <leizhiyuan@gmail.com>
* bugfix broker boot succes but get fail ip addr bug: broker ip addr(IPV4) get fail after broker start up; fix: add compare ,continue when ip is start with '0.' ; like : The broker[broker-a, 0.0.1.1:10911] boot success. serializeType=JSON and name server is 127.0.0.1:9876; * add config maxFilterMessageSize , not hard code * Pass the code check style --------- Co-authored-by: mingzhi.zhang <mingzhi.zhang@jiduauto.com> Co-authored-by: RongtongJin <jinrongtong16@mails.ucas.ac.cn>
Co-authored-by: landonchan90 <landaonChan@163.com>
* Update bazel toolchain Signed-off-by: Bazelisky <bazelisk@hotmail.com> * fix a bad test case as it violates requirement of ConcurrentHashMap#computeIfAbsent Signed-off-by: Bazelisky <bazelisk@hotmail.com> * Exclude flaky tests from test suite Signed-off-by: bazelisky <155456828+bazelisky@users.noreply.github.com> * fix: format issue Signed-off-by: Zhanhui Li <lizhanhui@gmail.com> * fix: Remove unused import * fix deps issue Signed-off-by: Zhanhui Li <lizhanhui@gmail.com> * Expose data property of java_test, allowing to specify run_file Signed-off-by: Zhanhui Li <lizhanhui@gmail.com> --------- Signed-off-by: Bazelisky <bazelisk@hotmail.com> Signed-off-by: bazelisky <155456828+bazelisky@users.noreply.github.com> Signed-off-by: Zhanhui Li <lizhanhui@gmail.com> Co-authored-by: Zhanhui Li <lizhanhui@gmail.com>
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
Which Issue(s) This PR Fixes
Fixes #issue_id
Brief Description
How Did You Test This Change?