Slackbot
10/21/2022, 4:18 PMGian Merlino
10/21/2022, 4:26 PMGian Merlino
10/21/2022, 4:32 PMnano to micro or small or even larger, to see if these larger sizes would be able to handle your situation. (assuming your server supports these larger sizes.)
3) you could set maxTotalRows (https://druid.apache.org/docs/latest/development/extensions-core/kafka-supervisor-reference.html) lower, such that handoff happens more often, which limits the number of segments in flight. since you observe that things are OK until about 500K rows, you could set it to something conservative like 250K (half that). if you do this then make sure to run a compaction afterwards, since that will improve query performance quite a bit. (lots of small handoffs is not a recipe for good query perf!)Mark Veidemanis
10/21/2022, 10:05 PMMark Veidemanis
10/21/2022, 10:05 PMMark Veidemanis
10/21/2022, 10:07 PMMark Veidemanis
10/21/2022, 10:07 PMMark Veidemanis
10/21/2022, 10:08 PMMark Veidemanis
10/21/2022, 10:09 PMMark Veidemanis
10/21/2022, 10:16 PMGian Merlino
10/25/2022, 4:04 AMwould changing "segmentGranularity": "week" help at all?kind of: coarsening it up to "year" would mean fewer segments in flight. however, i didn't recommend this because coarsening up like that tends to cause other problems down the road with e.g. compaction. (you can't compact a time chunk that is receiving active ingestion; with "year" that's an entire year worth of data!)
Gian Merlino
10/25/2022, 4:04 AMhour or day or, sometimes, monthGian Merlino
10/25/2022, 4:05 AMIs there ever a benefit to having more segments?you got it: it's the parallelism, mainly.