kudu-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "邓光超" <532869...@qq.com>
Subject Question about blocked reactor thread
Date Tue, 04 Jul 2017 06:29:17 GMT
Hi,

 

        I execute 20 (or more )thread for the same table Concurrently , the thread operation
is as follows,

        shared_ptr<KuduSession> session = table->client()->NewSession();

    session->SetFlushMode(KuduSession::MANUAL_FLUSH);

session->SetTimeoutMillis(500);

For(int i = 0; i ++; i <=1000)

{

KuduInsert* insert = table->NewInsert();

        KuduPartialRow* row = insert->mutable_row();

       

//set the different value

…………..

 

       KUDU_CHECK_OK(session->Apply(insert));

        Status s;

        s = session->Flush();

}

    

the error I get is as follows, and  I lost the data,

 

RPC callback for RPC call kudu.tserver.TabletServerService.Write -> {remote=127.0.0.1:7050,
user_credentials={real_user=root}} blocked reactor thread for 74807.3us

 

RPC callback for RPC call kudu.tserver.TabletServerService.Write -> {remote=10.110.18.176:7050,
user_credentials={real_user=root}} blocked reactor thread for 87339.7us

 

 

Guangchao Deng
Mime
View raw message