This is an automated email from the ASF dual-hosted git repository.
szetszwo pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/ratis-hadoop-projects.git.
at 29dbfb9 RATIS-1503. Avoid using ForkJoinPool.commonPool() in
RaftServerProxy/Impl. (#590)
This branch includes the following new commits:
new 64a4f0a RATIS-1415. Avoid follower gap limitation for watch requests
(#518)
new a6c0710 RATIS-1416. Update Ratis master version to 2.3.0-SNAPSHOT
(#519)
new 0e38073 RATIS-1420. Improve the appendEntity with inconsistency
entities case (#523)
new d62117a RATIS-1418. Leader step down for not sending out heartbeat
promptly (#521)
new 1970565 RATIS-1417. catch user statemachine
notifyInstallSnapshotFromLeader exception (#520)
new bba47a5 RATIS-1421. [Streaming]make client NioEventLoopGroup size
configurable. (#524)
new 637f4b2 RATIS-1422. Add ratis-shell maven module. (#525)
new 1dec9dc RATIS-1424. NettyClientStreamRpc#workerGroup Can cause too
much nioEventLoopGroup object (#527)
new 8fb9f7a RATIS-1425. Add ratis-shell sub commands framework (#528)
new 5507ca9 RATIS-1427. Add ratis-shell info command (#529)
new a136a62 RATIS-1423. Remove commons.lang3 dependency from
ratis-examples and ratis-test. (#526)
new ad22fbf RATIS-1432. fix SegmentedRaftLogCache#getTotalCacheSize Null
pointer exception (#530)
new ba7b24b RATIS-1428. Add ratis-shell elect command (#531)
new 0c2533c RATIS-1429. Add ratis-shell setPriority command (#532)
new b0a9586 RATIS-1419. Use cached thread pools in DataStreamManagement.
(#522)
new 2739eb6 RATIS-1434. Add iterator() and remove(..) methods to
DataQueue and DataBlockingQueue (#533)
new d98c7be Ratis-1435. Update metric of leaderElectionTimeout (#536)
new 8fe94ff Revert "Ratis-1435. Update metric of leaderElectionTimeout
(#536)" for updating commit message.
new 77e5e74 RATIS-1435. Update metric for transferLeadership. (#536)
new 2e55654 RATIS-1440. NettyClientStreamRpc#ChannelInboundHandler add
exceptionCaught method (#537)
new 2c86489 RATIS-1431. Add ratis-shell add&remove peer command (#534)
new 4fbda52 RATIS-1442. Typo: orderedWithTimeout should be
unorderedWithTimeout in GrpcClientProtocolClient. (#539)
new 2ad0389 RATIS-1445. NettyClientStreamRpc exception handling (#541)
new b8fca7e RATIS-1450. Remove ProtoUtils.addCommitInfos(..). (#544)
new 10a8311 RATIS-1449. Move netty related code out from ratis-common.
(#543)
new 2027c15 RATIS-1451. GroupManagementImpl should use
sendRequestWithRetry. (#545)
new a00a66d RATIS-1452. Fix log output in sendRequest. (#547)
new 802f00e RATIS-1448. Include commit infos in DataStreamReply. (#546)
new eb1ea9f RATIS-1447. Cleanup NettyClientStreamRpc#replies empty queue
(#542)
new fb062dd RATIS-1456. Clean StreamMap when an exception occurs in
DataStreamManagement#read (#551)
new dd909fc RATIS-1100. Make raft log gap error easier to troubleshoot.
(#548)
new 1f4ec88 RATIS-1436.Add ratis-shell GroupInfo command (#540)
new 6fef0f7 RATIS-1458. Implement ExceptionDependentRetry#toString (#553)
new 3ec14c9 RATIS-1410. Wrong comment in ratis filestore example (#507)
new 1453c4d RATIS-1460. Rename assembly id from ratis-shell to shell
(#555)
new 8866b83 RATIS-531.
TestServerRestartWithGrpc.runTestRestartCommitIndex is flaky (#554)
new 0e62cbb RATIS-1453. The file store client will hung when streaming
writes. (#557)
new 9c369f3 RATIS-1463 Fix verbose logging at INFO level (#558)
new 87e2d96 RATIS-1462. RaftServer started failed when rpc timeout use
different unit (#556)
new 076b83c RATIS-1464. OrderedStreamAsync error handler (#559)
new 2faf872 RATIS-1457. DataStreamManagement startTransaction error
handler (#552)
new a7555cf RATIS-1408. Add metrics of statemachine read/write timeout
count. (#506)
new 96b5c92 RATIS-1467. Remove unused log4j dependency from pom.xml.
(#562)
new f349fdf RATIS-1438. Add request timeout to ratis Streaming (#563)
new 478749c RATIS-1446. Avoid leader election for invalid conf (#560)
new e7509ea RATIS-1470. Add peerId option to group list (#564)
new 0d8e70b RATIS-1472. make use CachedThreadPool configurable. (#566)
new cea19a6 RATIS-1473.Implement takeSnapshot in Server (#567)
new beb3e3d RATIS-1475. Use the stream level SlidingWindow.client in
OrderedStreamAsync (#568)
new 3ef7f1d RATIS-1477. Exclude log4j JMSAppender.class in jar. (#570)
new 94db58b RATIS-1479. Make the min gap to take snapshot configurable
(#572)
new 56a8e17 RATIS-1441. Add snapshot manually request and proto (#538)
new 05cac19 RATIS-1482. fix shouldNotifyToInstallSnapshot to return the
first avail term index (#574)
new 8f3b684 RATIS-1478 NettyClientStreamRpc error reply handling (#571)
new 3d06ad6 RATIS-1484. Add take snapshot grpc related request and proto
(#575)
new 74159d4 RATIS-1488. Improve README for FileStore example (#578)
new 805a495 RATIS-1489. Add take snapshot raftClient and grpc-test
related code (#579)
new b57be79 RATIS-1486. Add take snapshot hadoop and netty related
request and proto (#576)
new b53c51d RATIS-1490. Follower should not change to candidate if
already stopped (#581)
new f0190f5 RATIS-1487. Implement pause election in server (#577)
new e296b56 RATIS-1491. TestNettyDataStreamChainTopologyWithGrpcCluster
timed out after 100 seconds (#583)
new 6e7faae RATIS-1492. Use tomcat annotations-api. (#582)
new 2368243 RATIS-1494. Change spotbugs-annotations to provided scope.
(#584)
new 394b473 RATIS-1412. Add ratis-shell snapshot command (#580)
new 7a066f9 RATIS-1495. When DataStreamManagement#read an exception
occurs, release ByteBuf (#585)
new 8dc6493 RATIS-1498. Take snapshot on specific ratis server (#586)
new f479974 RATIS-1497. Avoid using ForkJoinPool.commonPool() in
GrpcClientProtocolService. (#587)
new 0026645 RATIS-1501. Exclude log4j JMSSink, JDBCAppender, and Chainsaw
from the generated jar. (#589)
new 96e7384 RATIS-1500. Fix LogAppender NN_NAKED_NOTIFY. (#588)
new 7776209 RATIS-1508. Clean up vulnerabilities from dependencies. (#591)
new b07ee72 RATIS-1509. Remove GrpcOutputStream and the related conf
GrpcConfigKeys.OutputStream.* (#592)
new 51bfa17 RATIS-1510. Add pause leader election request related code
(#593)
new 29dbfb9 RATIS-1503. Avoid using ForkJoinPool.commonPool() in
RaftServerProxy/Impl. (#590)
The 73 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
