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);