Thank you, i found that autoflus is what i need.
发件人: Ilya Kasnacheev
发送时间: 2018年8月16日 21:22:10
收件人: user@ignite.apache.org
主题: Re: data loss using IgniteDataStreamer API
Hello!
For starters, I don't see that you do stmr.close() anywhere.
Data Streamer is only
Thank you, i found that autoflus is what i need.
发件人: Ilya Kasnacheev
发送时间: 2018年8月16日 21:22:10
收件人: user@ignite.apache.org
主题: Re: data loss using IgniteDataStreamer API
Hello!
For starters, I don't see that you do stmr.close() anywhere.
Data Streamer is only
Hello!
For starters, I don't see that you do stmr.close() anywhere.
Data Streamer is only guaranteed to write all data to cache after it is
closed properly.
Regards,
--
Ilya Kasnacheev
2018-08-16 16:19 GMT+03:00 Huang Meilong :
> Hi all,
>
>
> I'm use IgniteDataStreamer API to ingest
Hi all,
I'm use IgniteDataStreamer API to ingest 1,000,000 record to a sql table cache,
but only 996,626 records,
0: jdbc:ignite:thin://127.0.0.1/> select count(*) from APMMETRIC;
++
|COUNT(*)|
++
| 996626
