《2022毕业即失业取暖地》专题

我有几个运行在不同节点上并执行Spring批处理作业的“Orchestrator”微服务实例。一次只有一个实例必须是“活动的”并执行该作业。每天通过带有cron表达式的注释调度作业两次。因此，mocriservice尝试使用一个标识的作业来执行，该作业是一个被截断为秒，以补偿我的实例所运行的OpenShift节点之间的时间差。底层DB是Postgres12，事务隔离级别设置为可重复读取。 这个问题

我正在用异步JobLauncher在Spring Batch中配置一个（长时间运行的）作业，我有两个RESTendpoint： null 谢谢朱利奥

我希望能够用REST控制器开始我的作业，然后当作业开始时，它应该在计划的基础上运行，直到我用REST再次停止它。

我们的Spring批处理作业在处理输入文件时突然失败。当我试图重新运行批处理作业时，它会抛出以下消息。 02:27:09.088[main]调试O.S.B.C.R.dao.jdbcstepExecutionDAO-在更新StepExecution之前截断长消息，原始消息为：org.springframework.batch.core.jobExecutionException：无法从开始状态重新启

我的要求: 一旦文件上传到 Blob 容器，Azure 函数就会收到警报，并且使用该 Azure 函数，我想调用使用上传的文件并执行任何任务的 Web 作业。 我学到了什么： 我了解到，当文件被上传到blob容器时，Azure功能可以被触发。我尝试了这些教程，并能够配置Azure函数，它可以对blob容器中的任何更改起作用。我是通过Azure Portal完成的，没有使用Visual Studio

我有一个Hadoop作业，其中映射器必须使用外部jar。 我试图将这个jar传递给映射器的JVM 通过hadoop命令上的-libjars参数 via作业。addFileToClassPath HADOOP_CLASSPATH。 这些方法都不起作用。这是我得到的堆栈跟踪。它抱怨的缺失类是SparseDoubleMatrix1D在colt.jar. 如果我需要提供任何其他调试信息，请告诉我。谢谢

我使用Apache Flink 1.9和标准检查点/保存点机制来FS。 我的问题是：如果作业的代码发生了更改，从保存点恢复作业的正确方法是什么？例如，在重构之后，我重命名了几个类，之后我无法从旧的检查点恢复。 我丢失了我的数据，想问-在这种情况下我能做些什么？ 所有运算符都有uid和name

有人能帮我解决这个问题吗？

我正在尝试使用我自己的sickit learn ML模型和SageMaker，并使用github示例。 python代码如下所示： 但是我得到了这个错误： 信息：sagemaker：创建培训工作与名称：决策树样本-2018-04-24-13-13-38-281 ---------------------------------------------------------------------

我有一个Spark作业抛出“java.lang.OutOfMemoryError：GC开销限制超出”。 作业正在尝试处理4.5g的文件。 我尝试了以下spark配置：

我们的团队在我们的K8S集群中设置了Flink会话集群。我们选择Flink会话集群而不是作业集群，因为我们有许多不同的Flink作业，因此我们希望将Flink的开发和部署与我们的作业分离。我们的Flink设置包含： 单个JobManager作为K8S吊舱，无高可用性（HA）设置 我们在一个单独的存储库中开发工作，并在代码合并时部署到Flink集群。 现在，我们注意到在K8S中作为pod的JobMa

我已从AdoJobStore成功连接到Oracle DB。但是当我尝试添加一个作业时，我得到了以下异常。 异常源：Quartz异常方法：Void StoreJob（Quartz.Impl.AdoJobStore.ConnectionAndTransactionHolder，Quartz.IJobDetail，布尔值）异常堆栈跟踪：位于Quartz。Impl。阿多乔布商店。Jobstore支持。c:

java.io.ioException：映射项中的类型不匹配：应为org.apache.hadoop.io.text，已收到org.apache.hadoop.mapred.maptask$MapOutputBuffer.Collect(Maptask.java:870)在org.apache.hadoop.mapred.maptask$NewOutputCollector.Write(Mapta

未找到作业函数。试着公开你的作业类和方法。如果您使用的是绑定扩展（例如Azure存储、ServiceBus、定时器等），请确保在启动代码中调用了扩展的注册方法（例如builder.AddAzureStorage（）、builder）。AddServiceBus（），生成器。AddTimers（）等）。 当我们将.netframework从4.7升级到.netcore 3.0时，问题开始出现

我正在使用启动作业。问题：我如何线程化这些调用？以便最多有4个作业线程可以并发运行，而任何其他作业都只是排队？