(inlong) branch master updated: [INLONG-10187][Agent] Handle situations where time offset is empty (#10188)

[dockerzhang]

This is an automated email from the ASF dual-hosted git repository.

dockerzhang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git


The following commit(s) were added to refs/heads/master by this push:
     new 632aa88e44 [INLONG-10187][Agent] Handle situations where time offset 
is empty (#10188)
632aa88e44 is described below

commit 632aa88e448de9acb4cd575e6bc57c10615aef4d
Author: justinwwhuang <hww_jus...@163.com>
AuthorDate: Mon May 13 10:18:40 2024 +0800

    [INLONG-10187][Agent] Handle situations where time offset is empty (#10188)
---
 .../src/main/java/org/apache/inlong/agent/pojo/TaskProfileDto.java   | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git 
a/inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/pojo/TaskProfileDto.java
 
b/inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/pojo/TaskProfileDto.java
index 374b7331d4..d0b378dd47 100644
--- 
a/inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/pojo/TaskProfileDto.java
+++ 
b/inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/pojo/TaskProfileDto.java
@@ -97,6 +97,8 @@ public class TaskProfileDto {
 
     private static final Gson GSON = new Gson();
 
+    public static final String deafult_time_offset = "0";
+
     private Task task;
     private Proxy proxy;
 
@@ -157,9 +159,10 @@ public class TaskProfileDto {
         fileTask.setCycleUnit(taskConfig.getCycleUnit());
         fileTask.setStartTime(taskConfig.getStartTime());
         fileTask.setEndTime(taskConfig.getEndTime());
-        fileTask.setProperties(GSON.toJson(taskConfig.getProperties()));
         if (taskConfig.getTimeOffset() != null) {
             fileTask.setTimeOffset(taskConfig.getTimeOffset());
+        } else {
+            fileTask.setTimeOffset(deafult_time_offset + 
fileTask.getCycleUnit());
         }
 
         if (taskConfig.getAdditionalAttr() != null) {