You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@inlong.apache.org by zi...@apache.org on 2022/03/22 14:46:25 UTC
[incubator-inlong] branch master updated: [INLONG-3308][Agent] Agent fix deliveryTime npe (#3309)
This is an automated email from the ASF dual-hosted git repository.
zirui pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-inlong.git
The following commit(s) were added to refs/heads/master by this push:
new b72dc91 [INLONG-3308][Agent] Agent fix deliveryTime npe (#3309)
b72dc91 is described below
commit b72dc91cd454bfe1e79cb14ed6dcf7944c896e0a
Author: Schnapps <zp...@connect.ust.hk>
AuthorDate: Tue Mar 22 22:46:21 2022 +0800
[INLONG-3308][Agent] Agent fix deliveryTime npe (#3309)
---
.../agent-common/src/main/java/org/apache/inlong/agent/db/CommandDb.java | 1 -
1 file changed, 1 deletion(-)
diff --git a/inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/db/CommandDb.java b/inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/db/CommandDb.java
index 2d759eb..e9d7f44 100644
--- a/inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/db/CommandDb.java
+++ b/inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/db/CommandDb.java
@@ -58,7 +58,6 @@ public class CommandDb {
CommandEntity entity = new CommandEntity();
entity.setId(CommandEntity.generateCommandId(profile.getTriggerId(), profile.getOpType()));
entity.setTaskId(Integer.parseInt(profile.getTriggerId()));
- entity.setDeliveryTime(profile.getDeliveryTime());
entity.setCommandResult(success ? Constants.RESULT_SUCCESS : Constants.RESULT_FAIL);
entity.setVersion(profile.getInt(JOB_VERSION, DEFAULT_JOB_VERSION));
entity.setAcked(false);