From c5e800c9f1be3de8897c7fa9cd4b260e20f22d98 Mon Sep 17 00:00:00 2001 From: zhangjunfan Date: Tue, 14 Dec 2021 15:21:13 +0800 Subject: [PATCH] =?UTF-8?q?[OOZIE-3647]=20Oozie=20should=20use=20the=C2=A0?= =?UTF-8?q?ConfigurationService.getInt=20instead=20of=20Services.get().get?= =?UTF-8?q?Conf().getInt?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../src/main/java/org/apache/oozie/service/RecoveryService.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/core/src/main/java/org/apache/oozie/service/RecoveryService.java b/core/src/main/java/org/apache/oozie/service/RecoveryService.java index 64a67d6978..6e887f46f7 100644 --- a/core/src/main/java/org/apache/oozie/service/RecoveryService.java +++ b/core/src/main/java/org/apache/oozie/service/RecoveryService.java @@ -450,7 +450,7 @@ private void queueCallable(XCallable callable) { callables = new ArrayList>(); } callables.add(callable); - if (callables.size() == Services.get().getConf().getInt(CONF_CALLABLE_BATCH_SIZE, 10)) { + if (callables.size() == ConfigurationService.getInt(CONF_CALLABLE_BATCH_SIZE)) { boolean ret = Services.get().get(CallableQueueService.class).queueSerial(callables); if (ret == false) { XLog.getLog(getClass()).warn(