starrocks-connector-for-apache-flink icon indicating copy to clipboard operation
starrocks-connector-for-apache-flink copied to clipboard

Published 20 hours ago • verified publisher icon StarRocks

too much threads of 'starrocks-interval-sink-thread-1'

Open tonyDong-code opened this issue 2 years ago • 1 comments

The flink task consumes kafka and writes starrocks, implemented via Flinks-connector-Starrocks. flink task started for 3 months. On a node of yarn cluster, it was found that this task created 60,000 + threads named "starrocks-interval-sink-thread-1", and the threads were WAITTING state.

pom <dependency> <groupId>com.starrocks</groupId> <artifactId>flink-connector-starrocks</artifactId> <version>1.1.14_flink-1.13_2.11</version> </dependency>

图片

ps -eLf | wc -l 图片

jstack -l 26756 图片

arthas threads 图片

tonyDong-code avatar Dec 07 '22 02:12 tonyDong-code

flink code 图片

tonyDong-code avatar Dec 07 '22 02:12 tonyDong-code