草庐IT

elastic-job

全部标签

java - 使用 Elastic Cloud/Found 随机断开与主节点 NoNodeAvailableException 的连接

我正在使用带防护罩和传输Java客户端的弹性云(以前发现的)。与ES通信的应用程序运行在heroku上。我正在使用一个节点在暂存环境中运行压力测试{"cluster_name":...,"status":"yellow","timed_out":false,"number_of_nodes":1,"number_of_data_nodes":1,"active_primary_shards":19,"active_shards":19,"relocating_shards":0,"initializing_shards":0,"unassigned_shards":7,"delayed

java - Java中的Cron Job第六个参数

我是Java的新手。作为我的第一个项目,我将使用cron作业调度程序。我想澄清一下日程安排。我有一个每小时运行一次的代码。CronTriggerct=newCronTrigger("cronTrigger","group2","01/0***?");我已经阅读了有关调度的文档,但我感到困惑在一份文件中,我阅读如下("00***?")第一个0表示秒第二个表示分钟第3小时每月的哪一天哪个月的5号。在一些文件中我读到1st表示分钟2nd-小时等谁能给我解释一下这个(01/0***?)以及它的含义(1/0)?我想每六个小时运行一次作业。如果我这样给出(0*/6***?)它是否会每六个小时运行一

java - Spring Data Elastic Search - 按距离对地理位置进行排序

给定一个地理定位点,我试图找到10公里以内的一些地点,并按离给定位置最近的地点对其进行排序。我设法返回了10公里以内的位置列表,但是当我尝试对其进行排序时,出现了异常:我正在使用以下版本:3.2.12.61.0.0.BUILD-SNAPSHOT3.2.5.RELEASEjava代码如下:publicListfindByGeoLocation(Doublelongitude,Doublelatitude,StringchannelKey,Stringdistance){if(StringUtils.isEmpty(distance)){distance=defaultRadius;}Ge

java - 为什么 Elastic Search java API 会忽略我们的查询限制?

我正在使用这段代码:client.prepareSearch("test").addSort("dateUpdated",SortOrder.DESC).setSearchType(SearchType.DFS_QUERY_AND_FETCH).setIndices("reach").setTypes(types).setQuery(QueryBuilders.queryString(queryString)).setFrom(0).setSize(2).setExplain(true).execute().actionGet()客户端是远程客户端。总共有5个结果,根据我上面的内容,我

java - 捕捉 Ctrl+C 信号抛出异常 "Job manager has been shut down"

我正在尝试添加对信号的支持(尤其是对于Ctrl+C)。我的工具是用Java编写的,我想在Ctrl+C被捕获时执行清理。我的主文件是应用程序,有以下和平代码:if(ArgDefinitions.getInstance().hasOption(ArgNames.EXECUTE)){performShutdownHooks();preformRun();}应用程序解析用户的选项并运行正确的方法。因此,当用户使用execute选项并单击Ctrl+C时,我希望程序停止并清理该区域。我添加了performShutdownHooks方法来处理信号,它看起来如下:privatevoidperformS

java - Spring Scheduled Jobs 在不同的池中执行 3 次

我有一个每小时运行一次的Spring@Scheduled作业,但我发现它实际上每小时运行3次。这是显示此问题的日志输出:2013-05-0612:00:27,656[pool-2-thread-1]INFOsrc.jobs.NotifyUsersWhenVideoAvailableJob-EmailssentfromNotifyUsersWhenVideoAvailableJob:12013-05-0612:00:27,750[pool-1-thread-1]INFOsrc.jobs.NotifyUsersWhenVideoAvailableJob-EmailssentfromNoti

java - Spring 批处理 : different job launcher for different jobs

我有2份不同的工作(实际上更多,但为简单起见假设有2份)。每个作业都可以与另一个作​​业并行运行,但同一个作业的每个实例都应该按顺序运行(否则实例会蚕食彼此的资源)。基本上,我希望这些作业中的每一个都有自己的作业实例队列。我想我可以使用两个不同的线程池作业启动器(每个都有1个线程)并将作业启动器与每个作业相关联。有没有一种方法可以在从SpringBatchAdminWebUI启Action业时执行此操作? 最佳答案 有一种方法可以为特定作业指定特定作业启动器,但我发现唯一的方法是使用JobStep。如果您有一个名为“specific

java - AWS Elastic Beanstalk 上的 Spring Boot/Tomcat 仅显示 404 页面

我有一个SpringBoot应用程序,它在Tomcat下的本地主机上运行良好。当我将其打包为WAR并将其部署到ElasticBeanstalk上时,我只得到404页面。我尝试了许多不同的调整来尝试让它工作,但我不知所措。我已将打包配置为WAR,IntelliJ生成工件:com.ideaEngineapp_deployment0.0.1-SNAPSHOTwarUTF-8UTF-8com.xxxxxxxx.WebappApplication1.8我还包括了Tomcatorg.springframework.bootspring-boot-starter-tomcatprovidedElas

java.lang.NoClassDefFoundError : Could not initialize class when launching spark job via spark-submit in scala code 错误

我有一个代码,如下所示objectErrorTest{caseclassAPIResults(status:String,col_1:Long,col_2:Double,...)deffuncA(rows:ArrayBuffer[Row])(implicitdefaultFormats:DefaultFormats):ArrayBuffer[APIResults]={//callsomeAPIanggetresultsandreturnAPIResults...}//MARK:loadpropertiesvalprops=loadProperties()privatedefloadPr

java - quartz 调度器 : Trigger some jobs on every cluster node and some only once per cluster

我在集群环境中使用QuartzScheduler作为Springbean。我有一些用@NotConcurrent注释的作业,它们在每个集群中运行一次(即仅在一个节点中,仅在一个线程中)。现在我需要在集群的每个节点上运行一个作业。我删除了@NotConcurrent注释,但它只在一台机器上的每个线程上运行。它不会在其他节点上触发。我应该用什么来注释作业?示例:Job1NotConcurrentannotatedisscheduledatmidnight=>它每个午夜只在一台机器上触发。Job2注释为午夜安排=>它在每个午夜在每台机器上触发。谢谢。 最佳答案