Skip to content

Commit

Permalink
more memory usage for kafka sink
Browse files Browse the repository at this point in the history
Signed-off-by: Ping Yu <yuping@pingcap.com>
  • Loading branch information
pingyu committed Jan 23, 2024
1 parent 9be8016 commit 1fe4cae
Showing 1 changed file with 5 additions and 0 deletions.
5 changes: 5 additions & 0 deletions cdc/tests/integration_tests/flow_control/run.sh
Original file line number Diff line number Diff line change
Expand Up @@ -57,6 +57,11 @@ EOF
# We set `per-changefeed-memory-quota=10M` and forbid sorter to use memory cache data,
# so maybe there is 10M of memory for data. But still needs some memory to hold related data structures.
expected=307200 #300M
if [ "$SINK_TYPE" == "kafka" ]; then
# Kafka sink use more memory
# TODO: investigate why. Maybe memory leak.
expected=$((expected + 524288)) # +500M
fi
used=$(expr $rss1 - $rss0)
echo "cdc server used memory: $used"
if [ $used -gt $expected ]; then
Expand Down

0 comments on commit 1fe4cae

Please sign in to comment.