(inlong) branch master updated: [INLONG-9400][Manager] Fix the problem of rrror obtaining sort task type (#9401)

[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 fafc71f58a [INLONG-9400][Manager] Fix the problem of rrror obtaining 
sort task type (#9401)
fafc71f58a is described below

commit fafc71f58acb09d5a4336f110c7f7bc9b352c4f8
Author: fuweng11 <76141879+fuwen...@users.noreply.github.com>
AuthorDate: Mon Dec 4 15:20:15 2023 +0800

    [INLONG-9400][Manager] Fix the problem of rrror obtaining sort task type 
(#9401)
---
 .../java/org/apache/inlong/common/pojo/agent/TaskSnapshotRequest.java   | 2 +-
 .../src/main/java/org/apache/inlong/manager/common/consts/SinkType.java | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/inlong-common/src/main/java/org/apache/inlong/common/pojo/agent/TaskSnapshotRequest.java
 
b/inlong-common/src/main/java/org/apache/inlong/common/pojo/agent/TaskSnapshotRequest.java
index c5f7b64f52..232a3fd327 100644
--- 
a/inlong-common/src/main/java/org/apache/inlong/common/pojo/agent/TaskSnapshotRequest.java
+++ 
b/inlong-common/src/main/java/org/apache/inlong/common/pojo/agent/TaskSnapshotRequest.java
@@ -42,7 +42,7 @@ public class TaskSnapshotRequest {
     /**
      * Report Time
      */
-    @JsonFormat(pattern = "YYYY-MM-dd'T'HH:mm:ss.SSSZ", timezone = "GMT+8")
+    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
     private Date reportTime;
 
     /**
diff --git 
a/inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/consts/SinkType.java
 
b/inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/consts/SinkType.java
index 6169426932..b9b8a17350 100644
--- 
a/inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/consts/SinkType.java
+++ 
b/inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/consts/SinkType.java
@@ -95,7 +95,7 @@ public class SinkType extends StreamType {
     }
 
     public static boolean containSortFlinkSink(List<String> sinkTypes) {
-        return sinkTypes.stream().anyMatch(SORT_STANDALONE_SINK::contains);
+        return sinkTypes.stream().anyMatch(SORT_FLINK_SINK::contains);
     }
 
 }