我一直在运行一个基于apache波束的数据摄取作业,它解析输入CSV文件并在接收器上写入数据。当一次提交一个作业(在正常负载情况下)时,此作业工作正常。但是最近,当我开始负载测试时,我开始在一个循环中顺序地调度多个作业,在这个循环中,我观察到一些异常和作业失败。目前,我正在使用脚本通过RUNNING的Flink API来调度9个作业。:139)
at org.apache.beam.
我正在尝试运行一个网络应用程序。一开始它运行良好,但我不得不从项目文件夹中删除一些jars。我没有用eclipse删除罐子。所以,我开始发现这些错误:Could not delete C:/Users/maniceto/Documents/workspace/.metadata/.plugins/org.eclipse.wst.server.core/tmp0/wtpwebapps/fj21-tarefas/WEB-INF/lib. May be locked by another process.
Could n
这个UUID的原因是,如果没有它,当A1和A2同时运行时,它们都包含一个名为“任务-调度程序-1”的线程。这最初导致了锁定问题,因为A1可能拥有锁,同时在处理文件时,A2请求锁,并且由于它们共享相同的名称,Curator在lock.acquire()上返回true,因此有两个拥有相同锁的实例。我看到在ZooKeeper中正在创建ZNodes,我看到了管理器为临时锁生成的UUID。当运行两个或多个实例时,进程有时会进入A1拥有锁的争用状态,然后运行一个冗长的进程。)
at org.apach