Kinesis PutRecordsRequest failed! #395
Comments
|
can you run valgrind? I suspect there is some memory craziness going on with those strings that are being mutated in a loop.
…Sent from my iPhone
On Dec 31, 2016, at 12:33 AM, acsdkquery ***@***.***> wrote:
Hi, Kinesis PutRecordsRequest failing with the following error,
i have checked with AWS-CLI and its working as excepted. But in my own code am getting this error.
am running in Ubuntu machine.
error:
terminate called after throwing an instance of 'std::system_error'
what(): Resource temporarily unavailable
Aborted (core dumped)
code:
function :
void StreamData(const Aws::Vector& data)
{
PutRecordsRequest putRecordsRequest;
putRecordsRequest.SetStreamName(m_streamName);
for(auto& datum : data)
{
PutRecordsRequestEntry putRecordsRequestEntry;
putRecordsRequestEntry.WithData(datum)
.WithPartitionKey(m_partition);
putRecordsRequest.AddRecords(putRecordsRequestEntry);
}
m_client->PutRecordsAsync(putRecordsRequest,
std::bind(&KinesisProducer::OnPutRecordsAsyncOutcomeReceived, this, std::placeholders::_1, std::placeholders::_2, std::placeholders::_3, std::placeholders::_4));
}
caller
Aws::String LogDataHead("AP Logs");;
Aws::String LogData;
while (true){
producer.StreamData( {
ByteBuffer((unsigned char*)LogDataHead.c_str(), LogDataHead.length()),
ByteBuffer((unsigned char*)LogData.c_str(), LogData.length())
});
}
—
You are receiving this because you are subscribed to this thread.
Reply to this email directly, view it on GitHub, or mute the thread.
|
|
Thanks Jona, This is the valgrind output, .so) Thread 492: status = VgTs_WaitSys (lwpid 2316) Thread 493: status = VgTs_WaitSys (lwpid 2318) Thread 494: status = VgTs_WaitSys (lwpid 2319) Thread 495: status = VgTs_WaitSys (lwpid 2320) Thread 496: status = VgTs_WaitSys (lwpid 2321) Thread 497: status = VgTs_WaitSys (lwpid 2322) Thread 498: status = VgTs_WaitSys (lwpid 2323) Thread 499: status = VgTs_Init (lwpid 0) Note: see also the FAQ in the source distribution. If that doesn't help, please report this bug to: www.valgrind.org |
|
plz let me know if we need more logs.... |
|
This trace looks to me like you haven't called InitAPI(). Can you verify that InitAPI is getting called before this code is invoked? |
|
Yes , Am calling InitAPI and shut API also, |
|
It's been two years without further information and investigation. So close this for now. Reopen if you still have problem. |
justnance
added
help wanted
Hi, Kinesis PutRecordsRequest failing with the following error,
i have checked with AWS-CLI and its working as excepted. But in my own code am getting this error.
am running in Ubuntu machine.
error:
terminate called after throwing an instance of 'std::system_error'
what(): Resource temporarily unavailable
Aborted (core dumped)
code:
function :
void StreamData(const Aws::Vector& data)
{
PutRecordsRequest putRecordsRequest;
putRecordsRequest.SetStreamName(m_streamName);
caller
Aws::String LogDataHead("AP Logs");;
Aws::String LogData;
The text was updated successfully, but these errors were encountered: