Question about blocked reactor thread

[??????]

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