I was trying out "flow control" see the example here
https://github.com/davinash/grpc-bench/blob/master/bench/src/main/java/io/adongre/grpc/formatted/ScanFormattedServiceImpl.java
Thanks
Avinash
On Sunday, October 23, 2016 at 8:51:35 PM UTC+5:30, Matt Mitchell wrote:
>
> After digging a little,
oughput when dealing with large numbers of small messages in a
> stream.
>
> One thing I notice between your two APIs is that in the more structure one
> you send the column name for every column value which seems quite
> inefficient
>
> On Tue, Oct 4, 2016 at 1:31 AM, Avinash
ws(NUM_OF_ROWS)
> .setSizeOfEachColumn(SIZE_OF_EACH_COLUMN)
> .build());
>
> On Sun, Oct 2, 2016 at 3:16 AM, Avinash Dongre > wrote:
>
>> Thanks Louis, For helping me here
>>
>> Sorry for delayed response
>>
>> I am sure I am doing something wrong
> performance
>
> -louis (from phone)
>
> On Sep 26, 2016 3:57 AM, "Avinash Dongre" > wrote:
>
> Hi All,
> Please help.
>
> Thanks
> Avinash
>
>
> On Saturday, September 24, 2016 at 12:01:02 PM UTC+5:30, Avinash Dongre
> wrote:
>>
>&g
Hi All,
Please help.
Thanks
Avinash
On Saturday, September 24, 2016 at 12:01:02 PM UTC+5:30, Avinash Dongre
wrote:
>
> >>> Now I get around 130-135 MegaBytes/Seconds Speed.
>
> This result is on the Same Machine. i.e. gRPC Client and gRPC Servers are
> running on the
>>> Now I get around 130-135 MegaBytes/Seconds Speed.
This result is on the Same Machine. i.e. gRPC Client and gRPC Servers are
running on the same machine.
On Saturday, September 24, 2016 at 11:59:53 AM UTC+5:30, Avinash Dongre
wrote:
>
> Hi All,
>
> Thanks all for
Hi All,
Thanks all for replying/resolving my previous doubts. I am planning to use
gRPC for our project. I have following question related to performance.
If I have following proto definition.
option optimize_for = SPEED;
message ScanRow {
repeated bytes row = 1;
}
Thanks Paul,
My mistake on coding side.
Issue is fixed is now.
Thanks
Avinash
On Tuesday, September 20, 2016 at 10:07:54 PM UTC+5:30, Avinash Dongre
wrote:
>
> Thanks Paul,
> I changed the code but still I am getting the same Exception.
>
> Thanks
> Avinash
>
>
> On
s the server from the command line.
>*/
> public static void main(String[] args) throws IOException,
> InterruptedException {
> final HelloWorldServer server = new HelloWorldServer();
> server.start();
> server.blockUntilShutdown();
> }
>
>
>
I am getting following exception on Server
Server started, listening on 50051
Sep 20, 2016 7:24:07 PM io.grpc.netty.NettyServerHandler onStreamError
WARNING: Stream Error
io.netty.handler.codec.http2.Http2Exception$StreamException: Stream closed
before write could take place
at
io.netty.handler.
Thanks Andreas,
It was the reason for client shutdown.
Thanks
Avinash
On Friday, September 16, 2016 at 7:45:04 PM UTC+5:30, Andreas Pillath wrote:
>
> Maybe sending 20_000_000L messages takes longer than 1min. Then
>
> finishLatch.await(1, TimeUnit.MINUTES);
>
> would return and shutdown your
Any Help Guys ?
Thanks
Avinash
On Thursday, September 15, 2016 at 12:53:04 PM UTC+5:30, Avinash Dongre
wrote:
>
> I have client which make a request to server and Server in reply sends a
> Stream-reply, This works fine for small number of message but when the
> number of messag
I have client which make a request to server and Server in reply sends a
Stream-reply, This works fine for small number of message but when the
number of messages are large then My client is shutdown before I could
receive all the message.
Following is how I have implemented Server RPC Streamin
s, but right now the examples have somewhat
> diverged from current best practices. The blocking API is mostly for
> convenience, but you will get more fine grained performance from the Async
> APIs.
>
> On Monday, September 12, 2016 at 4:28:06 PM UTC-7, Avinash Dongre wrote:
>&g
nder load.
>
> Also, you are using the blocking client API, which won't be as fast as the
> Async API. You should only create one channel, and reuse it. Also, the
> Channel needs its own threadpool too.
>
> On Monday, September 12, 2016 at 6:59:58 AM UTC-7, Avinash Dongre wr
Hello All,
I am trying to see if I can use this framework in my project. I need to
know what should be my GRPC Server configuration to achieve low latency and
high throughput.
This is how I am starting a GRPC which is embedded in another Java Process.
I am not doing anything on the server side
16 matches
Mail list logo
