elasticsearch - 如果计划任务在下一个计划时间开始之前没有完成，会发生什么？

Question

用于从toLogstash导入数据，该 sql 跟踪一个表，并且每1 分钟调度一次。MysqlElasticsearchupdate_timestamp

有一些特殊情况下 sql 不能在 1 分钟内完成（例如初始导入到新的 ES 实例中）。

顺便说一句，如果 sql 匹配超过 100k 行，logstash 似乎会以 100k 行的小批量导入。

问题是：

• 如果 sql 不能在 1 分钟内完成（又名。在下一个预定时间开始之前），logstash 会做什么？

  会不会：

  • 跳过下一个计划任务？
    根据我的观察，情况似乎是这样，但不确定。
  • 延迟下一个计划任务，但从不跳过一个？
  • 或者是其他东西。

标签： elasticsearchcronlogstashscheduled-tasks

Answer 1

jdbc 输入将Rufus 调度程序的 max_work_threads 设置为1。如果没有可用的工作线程，则trigger_queue什么都不做，因此该作业的实例将永远不会运行。它将等到下一次应该触发队列​​。