Step 1 of 4: Choose Issues

Cancel

T Patch Info Key Summary Assignee Reporter P Status Resolution Created Updated Due Development
Sub-task RATIS-1602

RATIS-979 Add a ProxiesPool inner class in NettyServerStreamRpc.

Tsz-wo Sze Tsz-wo Sze Minor Open Unresolved  
Sub-task RATIS-1599

RATIS-979 Fix test failure from RATIS-1569

Tsz-wo Sze Tsz-wo Sze Major Open Unresolved  
Sub-task RATIS-1578

RATIS-979 The following assertion error occurs when transferring large files

Tsz-wo Sze GuoHao Major Resolved Not A Problem  
Sub-task RATIS-1569

RATIS-979 Move the asyncRpcApi.sendForward(..) call to the client side.

Tsz-wo Sze Tsz-wo Sze Major Resolved Fixed  
Sub-task RATIS-1567

RATIS-979 NettyServerStreamRpc may throw NPE

Tsz-wo Sze Tsz-wo Sze Major Resolved Fixed  
Sub-task RATIS-1556

RATIS-979 Support reference-counted buffer in StateMachine.DataChannel

Tsz-wo Sze Tsz-wo Sze Major Resolved Fixed  
Sub-task RATIS-1555

RATIS-979 Make a new ratis snapshot version

Tsz-wo Sze GuoHao Major Resolved Delivered  
Sub-task RATIS-1550

RATIS-979 Change the client timeout of stream to the server timeout

GuoHao GuoHao Major Open Unresolved  
Sub-task RATIS-1549

RATIS-979 If the stream client is abnormally disconnected, reconnect the stream client

GuoHao GuoHao Major Resolved Fixed  
Sub-task RATIS-1538

RATIS-979 DataStreamManagement#startTransaction prevent accidental assertion errors

Unassigned GuoHao Major Open Unresolved  
Sub-task RATIS-1531

RATIS-979 NettyServerStreamRpc.Proxies#getProxy NPE

Unassigned GuoHao Blocker Open Unresolved  
Sub-task RATIS-1530

RATIS-979 Cleanup NettyClientStreamRpc#replies empty queue optimize

GuoHao GuoHao Major Patch Available Unresolved  
Sub-task RATIS-1529

RATIS-979 Handle when there is an exception in NettyServerStreamRpc# getDataStreamOutput

GuoHao GuoHao Major Resolved Fixed  
Sub-task RATIS-1528

RATIS-979 Hung after a long time running when streaming writes

GuoHao GuoHao Major Open Unresolved  
Sub-task RATIS-1524

RATIS-979 Optional DataStreamManagement#startTransaction configuration

GuoHao GuoHao Major Patch Available Unresolved  
Sub-task RATIS-1522

RATIS-979 OrderedStreamAsync uses a separate of send thread pool

GuoHao GuoHao Major Resolved Not A Problem  
Sub-task RATIS-1521

RATIS-979 NettyServerStreamRpc use EpollEventLoopGroup

GuoHao GuoHao Major Resolved Fixed  
Sub-task RATIS-1519

RATIS-979 When DataStreamManagement#read an exception occurs, remove DataStream

GuoHao GuoHao Major Patch Available Unresolved  
Sub-task RATIS-1513

RATIS-979 Streaming tests may fail with TimeoutIOException: Timeout 3000ms

GuoHao Tsz-wo Sze Major Resolved Fixed  
Sub-task RATIS-1506

RATIS-979 Discussion on improving the stability of streaming

mingchao zhao mingchao zhao Major Resolved Workaround  
Sub-task RATIS-1504

RATIS-979 DataStreamManagement#checkSuccessRemoteWrite add timeout handling

GuoHao GuoHao Major Open Unresolved  
Sub-task RATIS-1495

RATIS-979 When DataStreamManagement#read an exception occurs, release ByteBuf

GuoHao GuoHao Major Resolved Fixed  
Sub-task RATIS-1480

RATIS-979 Change outstanding-requests.max default value.

mingchao zhao mingchao zhao Major Resolved Not A Problem  
Sub-task RATIS-1478

RATIS-979 NettyClientStreamRpc error reply handling

GuoHao GuoHao Major Resolved Fixed  
Sub-task RATIS-1475

RATIS-979 Use the stream level SlidingWindow.client in OrderedStreamAsync

GuoHao GuoHao Major Resolved Fixed  
Sub-task RATIS-1472

RATIS-979 make use CachedThreadPool configurable.

mingchao zhao mingchao zhao Major Resolved Fixed  
Sub-task RATIS-1464

RATIS-979 OrderedStreamAsync error handler

GuoHao GuoHao Major Resolved Fixed  
Sub-task RATIS-1457

RATIS-979 DataStreamManagement startTransaction error handler

GuoHao GuoHao Major Resolved Fixed  
Sub-task RATIS-1456

RATIS-979 Clean StreamMap when an exception occurs in DataStreamManagement#read

GuoHao GuoHao Major Resolved Fixed  
Sub-task RATIS-1455

RATIS-979 fix NettyClientStreamRpc.ChannelInboundHandler#clientInvocationId concurrency security problem

GuoHao GuoHao Major Resolved Not A Bug  
Sub-task RATIS-1454

RATIS-979 NettyServerStreamRpc get request resolving concurrency security

GuoHao GuoHao Major Resolved Not A Bug  
Sub-task RATIS-1453

RATIS-979 The file store client will hung when streaming writes.

mingchao zhao mingchao zhao Minor Resolved Fixed  
Sub-task RATIS-1452

RATIS-979 Fix log output in sendRequest

mingchao zhao mingchao zhao Major Resolved Fixed  
Sub-task RATIS-1449

RATIS-979 Move netty related code out from ratis-common

Tsz-wo Sze Tsz-wo Sze Major Resolved Fixed  
Sub-task RATIS-1448

RATIS-979 Include commit infos in DataStreamReply

Tsz-wo Sze Tsz-wo Sze Major Resolved Fixed  
Sub-task RATIS-1447

RATIS-979 Cleanup NettyClientStreamRpc#replies empty queue

GuoHao GuoHao Major Resolved Fixed  
Sub-task RATIS-1445

RATIS-979 NettyClientStreamRpc exception handling

GuoHao GuoHao Major Resolved Fixed  
Sub-task RATIS-1444

RATIS-979 Add metric to streaming

GuoHao GuoHao Major Resolved Fixed  
Sub-task RATIS-1440

RATIS-979 NettyClientStreamRpc#ChannelInboundHandler add exceptionCaught method

GuoHao GuoHao Major Resolved Fixed  
Sub-task RATIS-1438

RATIS-979 Add request timeout to ratis Streaming

GuoHao GuoHao Major Resolved Fixed  
Sub-task RATIS-1424

RATIS-979 NettyClientStreamRpc#workerGroup Can cause too much nioEventLoopGroup object

GuoHao GuoHao Major Resolved Fixed  
Sub-task RATIS-1421

RATIS-979 make client NioEventLoopGroup size configurable.

mingchao zhao mingchao zhao Major Resolved Fixed  
Sub-task RATIS-1406

RATIS-979 Add an optional API to StateMachine.DataStream for providing an Executor

Tsz-wo Sze Tsz-wo Sze Major Resolved Fixed  
Sub-task RATIS-1376

RATIS-979 Improve the used memory

runzhiwang runzhiwang Major Resolved Fixed  
Sub-task RATIS-1373

RATIS-979 Use async model for StreamInfo#applyToRemotes

runzhiwang runzhiwang Major Resolved Fixed  
Sub-task RATIS-1372

RATIS-979 Support multi-client in FileStore

runzhiwang runzhiwang Major Resolved Fixed  
Sub-task RATIS-1371

RATIS-979 Support multi-client when transfer data between servers

runzhiwang runzhiwang Major Resolved Fixed  
Sub-task RATIS-1328

RATIS-979 Avoid parse proto for each packet

runzhiwang runzhiwang Major Resolved Fixed  
Sub-task RATIS-1312

RATIS-979 Compare the performance between HDFS and DataStreamApi

runzhiwang runzhiwang Major Resolved Fixed  
Sub-task RATIS-1280

RATIS-979 Validate RoutingTable before building it

Tsz-wo Sze Tsz-wo Sze Major Resolved Fixed  
Sub-task RATIS-1279

RATIS-979 Protocol message contained an invalid tag

Unassigned runzhiwang Major Resolved Cannot Reproduce  
Sub-task RATIS-1278

RATIS-979 Resource leak when decoding DataStreamReplyByteBuffer

Tsz-wo Sze runzhiwang Major Resolved Fixed  
Sub-task RATIS-1277

RATIS-979 Fix FileStore write failed because reply out of order

runzhiwang runzhiwang Major Resolved Fixed  
Sub-task RATIS-1276

RATIS-979 Use ClientInvocationId as key instead of StreamMap.Key

runzhiwang runzhiwang Major Resolved Fixed  
Sub-task RATIS-1274

RATIS-979 Close DataStreamClient when close RaftClient

runzhiwang runzhiwang Major Resolved Fixed  
Sub-task RATIS-1270

RATIS-979 Set default primary DataStreamServer in RaftClient.Builder

Tsz-wo Sze Tsz-wo Sze Major Resolved Fixed  
Sub-task RATIS-1264

RATIS-979 Move routingTable to RaftRpcRequestProto

runzhiwang runzhiwang Major Resolved Fixed  
Sub-task RATIS-1258

RATIS-979 FileStore can support different mode of network topology through CLI

Rui Wang Rui Wang Major Open Unresolved  
Sub-task RATIS-1253

RATIS-979 FileStore support routing table

runzhiwang runzhiwang Major Resolved Fixed  
Sub-task RATIS-1249

RATIS-979 Add route table in RaftConfiguration

runzhiwang runzhiwang Major Resolved Won't Do  
Sub-task RATIS-1248

RATIS-979 Support network topology

runzhiwang runzhiwang Major Resolved Fixed  
Sub-task RATIS-1234

RATIS-979 Compare the performance between Ozone and DataStreamApi

runzhiwang runzhiwang Major Resolved Fixed  
Sub-task RATIS-1229

RATIS-979 FileStore client generate files in parallel

runzhiwang runzhiwang Major Resolved Fixed  
Sub-task RATIS-1228

RATIS-979 FileStore support multi disk

runzhiwang runzhiwang Major Resolved Fixed  
Sub-task RATIS-1226

RATIS-979 The primary server should get the other peers from the current RaftConfiguration

Tsz-wo Sze Tsz-wo Sze Major Resolved Fixed  
Sub-task RATIS-1223

RATIS-979 FileStore write file in parallel

runzhiwang runzhiwang Major Resolved Fixed  
Sub-task RATIS-1222

RATIS-979 Save STREAM_HEADER RPC call

runzhiwang runzhiwang Major Open Unresolved  
Sub-task RATIS-1221

RATIS-979 Stream small packet for NettyFileRegion and MappedByteBuffer

Unassigned runzhiwang Major Resolved Duplicate  
Sub-task RATIS-1220

RATIS-979 FileStore stream to send small packets for MappedByteBuffer and NettyFileRegion

Tsz-wo Sze Tsz-wo Sze Major Resolved Fixed  
Sub-task RATIS-1218

RATIS-979 Add sync when test filestore performance

runzhiwang runzhiwang Major Resolved Fixed  
Sub-task RATIS-1213

RATIS-979 Provide a default implementation for DataStreamApi.stream()

Rui Wang Rui Wang Major Resolved Fixed  
Sub-task RATIS-1212

RATIS-979 Remove streams from StreamMap when close stream

runzhiwang runzhiwang Major Resolved Fixed  
Sub-task RATIS-1209

RATIS-979 Compare the performance between DataStreamApi and AsyncApi

Tsz-wo Sze runzhiwang Major Resolved Fixed  
Sub-task RATIS-1207

RATIS-979 Fix duplicated StreamMap.Key

runzhiwang runzhiwang Major Resolved Fixed  
Sub-task RATIS-1202

RATIS-979 Executor thread crashes on NPE

Rui Wang Rui Wang Major Resolved Not A Problem  
Sub-task RATIS-1201

RATIS-979 Enhance FileStore steaming tests

Rui Wang Rui Wang Major Resolved Fixed  
Sub-task RATIS-1196

RATIS-979 Save STREAM_CLOSE RPC call

runzhiwang runzhiwang Major Resolved Fixed  
Sub-task RATIS-1186

RATIS-979 Change the FileStore CLI to use Streaming.

runzhiwang Tsz-wo Sze Major Resolved Fixed  
Sub-task RATIS-1179

RATIS-979 Add a new API to DataStreamOutput for sending a File

Tsz-wo Sze Tsz-wo Sze Major Resolved Fixed  
Sub-task RATIS-1178

RATIS-979 Use RaftClient to submit request

runzhiwang runzhiwang Major Resolved Fixed  
Sub-task RATIS-1176

RATIS-979 Benchmark various ways to stream data

Unassigned Tsz-wo Sze Major Open Unresolved  
Sub-task RATIS-1175

RATIS-979 DataStreamOutput should support FileChannel#transferTo

Tsz-wo Sze Tsz-wo Sze Major Resolved Fixed  
Sub-task RATIS-1174

RATIS-979 Test leader change when close stream

runzhiwang runzhiwang Major Resolved Fixed  
Sub-task RATIS-1173

RATIS-979 Rename StateMachineDataChannel to DataChannel

Tsz-wo Sze Tsz-wo Sze Minor Resolved Fixed  
Sub-task RATIS-1172

RATIS-979 DataStreamApi/DataStreamOutput should expose stream close()

Rui Wang Rui Wang Major Resolved Won't Fix  
Sub-task RATIS-1171

RATIS-979 Allow null for the stream parameter in StateMachine.DataApi.link

Tsz-wo Sze Tsz-wo Sze Major Resolved Fixed  
Sub-task RATIS-1170

RATIS-979 Support WriteSmallFile by ratis streaming

runzhiwang runzhiwang Major Resolved Invalid  
Sub-task RATIS-1169

RATIS-979 Move the DataStream tests from TestDataStreamNetty to DataStreamClusterTests

Tsz-wo Sze Tsz-wo Sze Minor Resolved Fixed  
Sub-task RATIS-1168

RATIS-979 Move the utils from DataStreamBaseTest to a new file

Tsz-wo Sze Tsz-wo Sze Minor Resolved Fixed  
Sub-task RATIS-1166

RATIS-979 Link DataStream with LogEntryProto

Tsz-wo Sze Tsz-wo Sze Major Resolved Fixed  
Sub-task RATIS-1162

RATIS-979 Enable testing clusters with Netty data stream and gRPC

Tsz-wo Sze Tsz-wo Sze Major Resolved Fixed  
Sub-task RATIS-1160

RATIS-979 DataStreamClientImpl.closeAsync() should be idempotent

Tsz-wo Sze Tsz-wo Sze Major Resolved Fixed  
Sub-task RATIS-1157

RATIS-979 Buffer packets when the size of packets are too small

Unassigned Rui Wang Major In Progress Unresolved  
Sub-task RATIS-1155

RATIS-979 Add a builder for DataStreamReplyByteBuffer

Tsz-wo Sze Tsz-wo Sze Major Resolved Fixed  
Sub-task RATIS-1154

RATIS-979 Add sync flag when write stream data

runzhiwang Shashikant Banerjee Major Resolved Fixed  
Sub-task RATIS-1153

RATIS-979 Implement ChannelInboundHandler.exceptionCaught in NettyServerStreamRpc

Tsz-wo Sze Tsz-wo Sze Major Resolved Fixed  
Sub-task RATIS-1151

RATIS-979 Move the DateStream requests handling code from NettyServerStreamRpc to a new class

Tsz-wo Sze Tsz-wo Sze Major Resolved Fixed  
Sub-task RATIS-1150

RATIS-979 Return DataStreamException to client.

runzhiwang runzhiwang Major Resolved Fixed  
Sub-task RATIS-1148

RATIS-979 In NettyServerStreamRpc, each remote stream should not wait for its own previous write.

Tsz-wo Sze Tsz-wo Sze Major Resolved Fixed  
Sub-task RATIS-1145

RATIS-979 In NettyServerStreamRpc, the local/remote writes should only wait for the previous write

Tsz-wo Sze Tsz-wo Sze Major Resolved Fixed  
Sub-task RATIS-1144

RATIS-979 Default disable datastream when start a MiniRaftCluster

runzhiwang runzhiwang Major Resolved Fixed  
Sub-task RATIS-1143

RATIS-979 Return exception of submitClientRequestAsync to client.

runzhiwang runzhiwang Major Resolved Fixed  
Sub-task RATIS-1142

RATIS-979 Remove STREAM_CLOSE_FORWARD

runzhiwang runzhiwang Major Resolved Fixed  
Sub-task RATIS-1140

RATIS-979 Do not create DataStreamOutput for non-primary server

Rui Wang Rui Wang Major Resolved Fixed  
Sub-task RATIS-1138

RATIS-979 Add dataStreamAddress to RaftPeer

Tsz-wo Sze Tsz-wo Sze Major Resolved Fixed  
Sub-task RATIS-1137

RATIS-979 Rename StreamRequestTypeProto to MessageStreamRequestTypeProto

Tsz-wo Sze Tsz-wo Sze Major Resolved Fixed  
Sub-task RATIS-1136

RATIS-979 Add DataStreamRequestTypeProto

Tsz-wo Sze Tsz-wo Sze Major Resolved Fixed  
Sub-task RATIS-1135

RATIS-979 Initialize DataStreamServer after RaftServerProxy id is set

Rui Wang Rui Wang Major Resolved Fixed  
Sub-task RATIS-1134

RATIS-979 Remove DataStreamApi.stream(RaftGroupId).

Tsz-wo Sze Tsz-wo Sze Major Resolved Fixed  
Sub-task RATIS-1133

RATIS-979 Primary and peer should use the same RaftClientRequest

runzhiwang runzhiwang Major Resolved Fixed  
Sub-task RATIS-1132

RATIS-979 Primary and peer should use the same streamId

runzhiwang runzhiwang Major Resolved Fixed  
Sub-task RATIS-1130

RATIS-979 Have a E2E test for Ratis streaming based on MiniRaftCluster

Rui Wang Rui Wang Major Resolved Fixed  
Sub-task RATIS-1129

RATIS-979 Move out the RPC related APIs from DataStreamOutput

Tsz-wo Sze Tsz-wo Sze Major Resolved Fixed  
Sub-task RATIS-1127

RATIS-979 Add a stream(RaftGroupId) method to DataStreamApi.

Tsz-wo Sze Tsz-wo Sze Major Resolved Fixed  
Sub-task RATIS-1126

RATIS-979 Fix can not support more than 10 stream

runzhiwang runzhiwang Major Resolved Fixed  
Sub-task RATIS-1125

RATIS-979 Fix TestDataStream

Rui Wang Rui Wang Major Resolved Fixed  
Sub-task RATIS-1124

RATIS-979 NettyServerStreamRpc should get stateMachine from RaftServer

Tsz-wo Sze Tsz-wo Sze Major Resolved Fixed  
Sub-task RATIS-1123

RATIS-979 Support multiple DataStream clients

Tsz-wo Sze Tsz-wo Sze Major Resolved Fixed  
Sub-task RATIS-1122

RATIS-979 Use thenApplyAsync instead of thenApply

runzhiwang runzhiwang Major Resolved Fixed  
Sub-task RATIS-1121

RATIS-979 Support multiple streams

Tsz-wo Sze Tsz-wo Sze Major Resolved Fixed  
Sub-task RATIS-1118

RATIS-979 Remove DataStreamServerRpc.start()

Rui Wang Rui Wang Major Resolved Won't Fix  
Sub-task RATIS-1117

RATIS-979 Remove DataStreamClient.start() and DataStreamClientRpc.startClient()

Tsz-wo Sze Tsz-wo Sze Major Resolved Fixed  
Sub-task RATIS-1116

RATIS-979 Add DataStreamType

Tsz-wo Sze Tsz-wo Sze Major Resolved Fixed  
Sub-task RATIS-1115

RATIS-979 NettyServerStreamRpc should handle duplicate headers

Rui Wang Rui Wang Major Resolved Implemented  
Sub-task RATIS-1114

RATIS-979 Change NettyServerStreamRpc to use only one ConcurrentMap

Tsz-wo Sze Tsz-wo Sze Major Resolved Fixed  
Sub-task RATIS-1111

RATIS-979 Change the FileStore example to use Streaming

Rui Wang Tsz-wo Sze Major Resolved Fixed  
Sub-task RATIS-1110

RATIS-979 Fix DataStreamReply out of order

Tsz-wo Sze runzhiwang Major Resolved Fixed  
Sub-task RATIS-1108

RATIS-979 Add SupportedDataStreamType.DISABLED

Rui Wang Rui Wang Major Resolved Fixed  
Sub-task RATIS-1107

RATIS-979 Start NettyServerStreamRpc when create RaftServerProxy

runzhiwang runzhiwang Major Resolved Fixed  
Sub-task RATIS-1106

RATIS-979 Add type for DataStream

runzhiwang runzhiwang Major Resolved Fixed  
Sub-task RATIS-1105

RATIS-979 Refactor Netty streaming encoder and decoder

Tsz-wo Sze Tsz-wo Sze Major Resolved Fixed  
Sub-task RATIS-1104

RATIS-979 Should check "bytewritten" from remote writes to peers to determine whether current stream write is successful

Rui Wang Rui Wang Major Resolved Fixed  
Sub-task RATIS-1099

RATIS-979 DataStreamServerRpc should connect other peers automatically

Tsz-wo Sze Rui Wang Major Resolved Fixed  
Sub-task RATIS-1098

RATIS-979 DataStreamReply should include byteWritten and isSuccess

Tsz-wo Sze Tsz-wo Sze Major Resolved Fixed  
Sub-task RATIS-1097

RATIS-979 DataStreamOutputImpl should use streamOffset instead of messageId

Tsz-wo Sze Tsz-wo Sze Major Resolved Fixed  
Sub-task RATIS-1090

RATIS-979 Implement RaftClient.getDataStreamApi()

runzhiwang Tsz-wo Sze Major Resolved Fixed  
Sub-task RATIS-1089

RATIS-979 Add getDataStreamApi() to RaftClient

Tsz-wo Sze Tsz-wo Sze Major Resolved Fixed  
Sub-task RATIS-1085

RATIS-979 Encode a RaftClientRequest as the head of a stream request

runzhiwang Tsz-wo Sze Major Resolved Fixed  
Sub-task RATIS-1084

RATIS-979 Support multiple groups in Streaming

Rui Wang Tsz-wo Sze Major Resolved Fixed  
Sub-task RATIS-1083

RATIS-979 Create a transaction once the stream data is replicated to all servers

runzhiwang Tsz-wo Sze Major Resolved Fixed  
Sub-task RATIS-1082

RATIS-979 Netty stream server should forward the data to the other servers in the group

Rui Wang Tsz-wo Sze Major Resolved Fixed  
Sub-task RATIS-1081

RATIS-979 Change NettyServerStreamRpc to write data to StateMachine

Tsz-wo Sze Tsz-wo Sze Major Resolved Fixed  
Sub-task RATIS-1079

RATIS-979 Improve encoder/decoder by javadoc and error catch

Unassigned Rui Wang Major Resolved Won't Fix  
Sub-task RATIS-1078

RATIS-979 Refactor DataStream classes

Tsz-wo Sze Tsz-wo Sze Major Resolved Fixed  
Sub-task RATIS-1039

RATIS-979 Update ratis-thirdparty version in order to use the latest netty

Ansh Khanna Tsz-wo Sze Major Resolved Fixed  
Sub-task RATIS-1038

RATIS-979 Update netty version - 4.1.50.Final

Ansh Khanna Ansh Khanna Major Resolved Fixed  
Sub-task RATIS-1031

RATIS-979 Implement ratis streaming using netty - Server code

Ansh Khanna Ansh Khanna Major Resolved Fixed  
Sub-task RATIS-1030

RATIS-979 Implement ratis streaming using netty - Client code

Ansh Khanna Ansh Khanna Major Resolved Fixed  
Sub-task RATIS-1012

RATIS-979 Implement ratis streaming using netty

Ansh Khanna Tsz-wo Sze Major Resolved Duplicate  
Sub-task RATIS-1011

RATIS-979 Define internal streaming APIs

Ansh Khanna Tsz-wo Sze Major Resolved Fixed  
Sub-task RATIS-1009

RATIS-979 A simple benchmark achieving zero-copy semantics using Netty.

Ansh Khanna Ansh Khanna Major Resolved Fixed  
Sub-task RATIS-997

RATIS-979 Benchmarking Flatbuffers and Protobuffers for GRPC streaming

Ansh Khanna Ansh Khanna Major Resolved Fixed  

Cancel