nobleyd created FLINK-17492: ------------------------------- Summary: Possible direct memory leak in cassandra sink Key: FLINK-17492 URL: https://issues.apache.org/jira/browse/FLINK-17492 Project: Flink Issue Type: Bug Components: Connectors / Cassandra Affects Versions: 1.10.0, 1.9.3 Reporter: nobleyd
# Cassandra Sink use direct memorys. # Start a standalone cluster(1 machines) for test. # After the cluster started, check the flink web-ui, and record the task manager's memory info. I mean the direct memory part info. # Start a job which read from kafka and write to cassandra using the cassandra sink, and you can see that the direct memory count in 'Outside JVM' part go up. # Stop the job, and the direct memory count is not decreased(using 'jmap -histo:live pid' to make the task manager gc). # Repeat serveral times, the direct memory count will be more and more. -- This message was sent by Atlassian Jira (v8.3.4#803005)