fix: update test helper.getTaskProfile() variables

emptyOVO · Sep 22, 2024 · 8e2cda6 · 8e2cda6
1 parent 9ceb364
commit 8e2cda6
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...t/agent-plugins/src/test/java/org/apache/inlong/agent/plugin/sources/TestRedisSource.java b/...t/agent-plugins/src/test/java/org/apache/inlong/agent/plugin/sources/TestRedisSource.java
@@ -121,8 +121,8 @@ private void initProfile() {
         final String command = "zscore";
         final String subOperation = "set,del";
 
-        TaskProfile taskProfile = helper.getTaskProfile(1, "", false, 0L, 0L, TaskStateEnum.RUNNING, "D",
-                "GMT+8:00");
+        TaskProfile taskProfile = helper.getTaskProfile(1, "", "csv", false, 0L, 0L, TaskStateEnum.RUNNING, "D",
+                "GMT+8:00", null);
         profile = taskProfile.createInstanceProfile("",
                 "", taskProfile.getCycleUnit(), "20240725", AgentUtils.getCurrentTime());
         profile.set(CommonConstants.PROXY_INLONG_GROUP_ID, groupId);