Attach filesAttach ScreenshotAdd voteVotersWatch issueWatchersLinkCloneUpdate Comment AuthorReplace String in CommentUpdate Comment VisibilityDelete Comments
    XMLWordPrintableJSON

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

          This comment will be Viewable by All Users Viewable by All Users
          Cancel

          People

            Unassigned Unassigned
            nobleyd nobleyd

            Dates

              Created:
              Updated:

              Slack

                Issue deployment