You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@seatunnel.apache.org by GitBox <gi...@apache.org> on 2022/03/17 14:20:42 UTC

[GitHub] [incubator-seatunnel] ruanwenjun commented on pull request #1452: [Feature][connector] Support batch mode and stream data for Druid Sink

ruanwenjun commented on pull request #1452:
URL: https://github.com/apache/incubator-seatunnel/pull/1452#issuecomment-1070963123


   > > It might not a good choose to use batch mode in stream job.
   > > And if you hope to use batch flush, it is also better to set a time interval flush strategy. For example, if the current data size is less than your batch size in a long time, you can still flush data.
   > 
   > @ruanwenjun Sounds good to me, do you have any demo of the time interval flush strategy, it would be better you can provide it as well, thanks
   
   You can find a related example from [ElasticSearch BulkProcessor](https://github.com/elastic/elasticsearch/blob/master/server/src/main/java/org/elasticsearch/action/bulk/BulkProcessor.java), it uses a flushInterval to set the max flush time interval.


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: commits-unsubscribe@seatunnel.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org