Details

    Description

      1. Cassandra Sink use direct memorys.
      2. Start a standalone cluster(1 machines) for test.
      3. After the cluster started, check the flink web-ui, and record the task manager's memory info. I mean the direct memory part info.
      4. 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.
      5. Stop the job, and the direct memory count is not decreased(using 'jmap -histo:live pid' to make the task manager gc).
      6. Repeat serveral times, the direct memory count will be more and more.

      Attachments

        Issue Links

          Activity

            People

              Unassigned Unassigned
              nobleyd nobleyd
              Votes:
              0 Vote for this issue
              Watchers:
              14 Start watching this issue

              Dates

                Created:
                Updated: