Uploaded image for project: 'Flume'
  1. Flume
  2. FLUME-1003

The memory channel does not seem to respect the capacity

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Resolved
    • Major
    • Resolution: Not A Problem
    • 1.1.0
    • None
    • Channel
    • None
    • RHEL 6.2 64-bit

    Description

      Use the following config (no sink configured)

      a1.sources = r1
      a1.channels = c1

      a1.sources.r1.type = SEQ
      a1.sources.r1.channels = c1
      a1.channels.c1.type = MEMORY

      If I run with this config, then the source and channel instance is created. If you add a print statement to ChannelProcessor.processEvent(), you'll see that the source is sending events to the channel. The source generates about 104 events, and then generates an additional one about every second... which is interesting, since the mem channel's default capacity is only 100 and there's no sink.

      Attachments

        Activity

          People

            juhanic Juhani Connolly
            will@cloudera.com Will McQueen
            Votes:
            0 Vote for this issue
            Watchers:
            0 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: