jdbc输入将Rufus调度程序的max_work_threads设置为1。若并没有可用的工作线程,那个么trigger_queue什么也不做,所以作业的实例永远不会运行。它将等待,直到下一次应该触发队列。
使用Logstash
将数据从Mysql
导入到Elasticsearch
,sql跟踪表的update_timestamp
,并每1分钟调度一次。
在一些特殊情况下,sql无法在1分钟内完成(例如,初始导入到新的ES实例中(。
顺便说一句,如果sql匹配超过10万行,logstash似乎会以10万行的小批量导入。
问题是:
-
如果sql不能在1分钟内完成(也就是在下一个计划时间开始之前(,logstash会怎么做?
会吗:
- 是否跳过下一个计划任务
根据我的观察,情况似乎是这样,但不确定 - 推迟下一个计划任务,但从不跳过一个
- 或者,其他什么
- 是否跳过下一个计划任务