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 <[email protected]>
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);