Logstash consuming CPU usage over 100%

Elastic Stack Logstash
1

Hi!

I would like ask question about logstash plugin.

I am now using logstash but looks like it is consuming high CPU usage.

Below is part of lines from my config.

input {
  file {
    path => ["/var/log/logstash/data/test/test1/*/always/*"]
    start_position => "beginning"
    codec => multiline {
      pattern => "----------------------\+|Present Rot \[360deg\]|Total   Rot \[360deg\] "
      negate  => false
      what    => previous
    }
    ignore_older => 31104000

    tags => ["arm"]
  }
}

output {
  if "RIGHT HAND" in [tags] or "LEFT HAND" in [tags] {
    elasticsearch {
      hosts  => ["127.0.0.1"]
      index => "test-%{+YYYY.MM.dd}"
      document_type => "arm"
    }
    stdout { codec => rubydebug }
    
  }
}

filter {
# Set the date 
  if [message] =~ "\*\*\* \d{4}-\d{2}-\d{2} \d{2}:\d{2}:\d{2} \*\*\*" {
    grok {
      match => { 
        "message" => "\*\*\* (?<date>\d{4}-\d{2}-\d{2}) \d{2}:\d{2}:\d{2} \*\*\*" 
      }
    }

    ruby {
      init => "
        @@date = ''
      "
      code => "
        @@date = event.get('date')
      "
    }
  }

#########################################################
# Filter stanza for arm parsing
#########################################################
  if "arm" in [tags] and "multiline" in [tags] {
    # Set tags for right or left arm
    if [message] =~ ".*RIGHT HAND.*" {
      mutate {
        add_tag => [ "RIGHT HAND" ]
      }
    } else if [message] =~ ".*LEFT HAND.*" {
      mutate {
        add_tag => [ "LEFT HAND" ]
      }
    }

    if "RIGHT HAND" in [tags] or "LEFT HAND" in [tags] {
      # Parsing comes first
      grok {
        # Parse the parts values
        match => {
          "message" => ".*\[(?<logged_time>\d{2}:\d{2}:\d{2})\.\d{6}\]\s+Total\s+Rot\s+\[360deg\]\s+\|\s+(?<f11_val>\d+)\|\s+(?<f12_val>\d+)\|\s+(?<f13_val>\d+)\|\s+(?<f21_val>\d+)\|\s+(?<f22_val>\d+)\|\s+(?<f23_val>\d+)\|\s+(?<f31_val>\d+)\|\s+(?<f32_val>\d+)\|\s+(?<f33_val>\d+)\|\s+(?<f41_val>\d+)\|\s+(?<f42_val>\d+)\|\s+(?<f51_val>\d+)\|\s+(?<f52_val>\d+).*"
        }

        # Create a new field to split
        add_field => {
          "arm_parts_and_val" => "f11_%{f11_val},f12_%{f12_val},f13_%{f13_val},f21_%{f21_val},f22_%{f22_val},f23_%{f23_val},f31_%{f31_val},f32_%{f32_val},f33_%{f33_val},f41_%{f41_val},f42_%{f42_val},f51_%{f51_val},f52_%{f52_val}"
        }

        # Remove unnecessary fields
        remove_field => [
          "message" ,
          "f11_val" ,
          "f12_val" , 
          "f13_val" , 
          "f21_val" , 
          "f22_val" , 
          "f23_val" , 
          "f31_val" , 
          "f32_val" , 
          "f33_val" , 
          "f41_val" , 
          "f42_val" , 
          "f51_val" , 
          "f52_val" 
        ]
      }

      # Next split the event
      split { 
        # Tell the split plugin for which field to split
        field      => "arm_parts_and_val"

        # Define the terminator . Comma in this case
        terminator => ","

        # Define a new field to set the new values
        target     => "new_arm_parts_and_val"
      }

      # Grok again to split the "new_arm_parts_and_val"
      grok {
        # Split "new_arm_parts_and_val" into parts name and value
        match => {
          "new_arm_parts_and_val" => "(?<parts_name>\w\d+)_(?<total_rot>\d+)"
        }

        # Remove rest of fields
        remove_field => [
          "arm_parts_and_val",
          "new_arm_parts_and_val"
        ]
      }

I am considering to tune the config file but not sure where to start from.
Is there a know issue that any of the plugin consumes high cpu usage?

Thanks,
Yu Watanabe

2

HI,
First I would recommend doing a bit of profiling, to do it you could take a few thread dumps and see where the cost is, one very good article on this tools is http://www.ibm.com/developerworks/library/j-5things8/ for example.

However with your config, If I had to have one suspicion, here for high cpu performance would it be the multiline codec, so that would be my first hypothesis.

When you get this data if you share we can sort of the offender and sort out the problem more in deep.

PD: Knowing how your multiline files looks like would it also be necessary and helpful.

  • purbon
3

Hi @purbon

I will take a look at jstack and see if I find anything.

I have a below format in my log.

[10:47:33.068415]        RIGHT     |A|B|C|D|E|F|G|H|I|J|K|L|L|
[10:47:33.068415]  ----------------------+-------+-------+-------+-------+-------+-------+-------+-------+-------+-------+-------+-------+-------+
[10:47:33.068415]   test1 |      0|      0|      0|      0|      0|      0|      0|      0|      0|      0|      0|      0|      0|
[10:47:33.068415]   test2 |  1|  2|   3|   4|  5|  6|   7|  8|  9|  10|  11|  12|  13|
[10:47:33.068415]  ----------------------+-------+-------+-------+-------+-------+-------+-------+-------+-------+-------+-------+-------+-------+
[10:47:33.068415]   test3 |      0|      0|      0|      0|      0|      0|      0|      0|      0|      0|      0|      0|      0|
[10:47:33.068540]   test4 |  1|  2|   3|   4|  5|  6|   7|  8|  9|  10|  11|  12|  13|
[10:47:33.068540]  ----------------------+-------+-------+-------+-------+-------+-------+-------+-------+-------+-------+-------+-------+-------+
[10:47:33.068540]   test5 |      0|      0|      0|      0|      0|      0|      0|      0|      0|      0|      0|      0|      0|
[10:47:33.068540]   test6 |      0|    0|      0|      0|      0|      1|      0|      0|      0|      0|      0|      0|      0|
[10:47:33.068540]  ======================+=======+=======+=======+=======+=======+=======+=======+=======+=======+=======+=======+=======+=======+
[10:47:33.068540]         LEFT      |A|B|C|D|E|F|G|H|I|J|K|L|L|
[10:47:33.068540]  ----------------------+-------+-------+-------+-------+-------+-------+-------+-------+-------+-------+-------+-------+-------+
[10:47:33.068540]   test1 |      0|      0|      0|      0|      0|      0|      0|      0|      0|      0|      0|      0|      0|
[10:47:33.068540]   test2  |  1|  2|   3|   4|  5|  6|   7|  8|  9|  10|  11|  12|  13|
[10:47:33.068540]  ----------------------+-------+-------+-------+-------+-------+-------+-------+-------+-------+-------+-------+-------+-------+
[10:47:33.068540]   test3 |      0|      0|      0|      0|      0|      0|      0|      0|      0|      0|      0|      0|      0|
[10:47:33.068540]   test4  |  1|  2|   3|   4|  5|  6|   7|  8|  9|  10|  11|  12|  13|
[10:47:33.068540]  ----------------------+-------+-------+-------+-------+-------+-------+-------+-------+-------+-------+-------+-------+-------+
[10:47:33.068540]   test5 |      0|      0|      0|      0|      0|      0|      0|      0|      0|      0|      0|      0|      0|
[10:47:33.068665]   test6 |      0|      0|      0|      0|      0|      0|      0|      0|      0|      0|      0|      0|      0|
[10:47:33.068665]  ----------------------+-------+-------+-------+-------+-------+-------+-------+-------+-------+-------+-------+-------+-------+

I am using the multiline codec to parse line test1 of RIGHT HAND and line test1 of LEFT HAND.

4

Is your log with or without the timestamp part? I don't see this in the pattern, so might be one reason to it might get nuts, will debug a bit more and report here if I find the reason.

5

@purbon

Thanks for the reply.
Each line includes a time . Date is logged in another line. But I this date and time in a different field logged_time.

@timestamp is filled with the datetime which is automatically generated by logstash.

6

@purbon
I just found that filebeat also support multiline.

I will check the performance with filebeat.

7

yeah, my overall recommendation would be to do multiline at filebeat level, is usually easier.

8

I merged the multiline process to filebeat .
It looks like CPU usage of is flowing at around 100% and filebeat is at around 60%.

logstash_cpu_usage2.PNG1151×367 18 KB

9

Hi,
my suspicion here is the pattern to do the multiline is not working, are you able to see any output at all using a simple config like:

input {
  beats { .... }
}

output {
  stdout { codec => rubydebug }
}
10

Hello @purbon

Yes.

Multiline in beats is working perfectly and I was able to see events in output plugin (stdout and elasticsearch).

However, I still do not know which module in filter plugin is causing the high cpu usage though.

11

After we discarded all other situations, so is definitely an issue with the filters. Can you share here a few thread dumps and/or the jstack output. We're looking to get an impression which threads are running, so we can spot the filter causing this high cpu usage. I see you use a lot of grok who can be one of the reasons of this behaviour, but we'll need this information to move forward.

  • purbon