[Fix-17704][HttpTask] The output parameters of an HTTP task cannot be referenced in downstream tasks.

dolphinscheduler-task-plugin/dolphinscheduler-task-http/src/main/java/org/apache/dolphinscheduler/plugin/task/http/HttpTask.java

@@ -73,6 +73,8 @@
 
         OkHttpResponse httpResponse = sendRequest();
 
+        taskExecutionContext.setVarPool(httpParameters.getVarPool());
+
         validateResponse(httpResponse.getBody(), httpResponse.getStatusCode());
     }
 
@@ -204,7 +206,7 @@
                 .filter(httpProperty -> httpProperty.getHttpParametersType() != null)
                 .filter(httpProperty -> httpProperty.getHttpParametersType().equals(HttpParametersType.HEADERS)
                         && !httpProperty.getProp().equalsIgnoreCase(HttpConstants.CONTENT_TYPE))
                 .peek((httpProperty) -> {
                     httpProperty.setProp(ParameterUtils.convertParameterPlaceholders(httpProperty.getProp(),
                             ParameterUtils.convert(taskExecutionContext.getPrepareParamsMap())));
                     httpProperty.setValue(ParameterUtils.convertParameterPlaceholders(httpProperty.getValue(),
@@ -237,7 +239,7 @@
 
         return httpParameters.getHttpRequestParams().stream()
                 .filter(httpProperty -> httpProperty.getHttpParametersType().equals(HttpParametersType.PARAMETER))
                 .peek((httpProperty) -> {
                     httpProperty.setProp(ParameterUtils.convertParameterPlaceholders(httpProperty.getProp(),
                             ParameterUtils.convert(taskExecutionContext.getPrepareParamsMap())));
                     httpProperty.setValue(ParameterUtils.convertParameterPlaceholders(httpProperty.getValue(),

dolphinscheduler-task-plugin/dolphinscheduler-task-http/src/test/java/org/apache/dolphinscheduler/plugin/task/http/HttpTaskTest.java

@@ -181,6 +181,39 @@
         Assertions.assertEquals(response, property.getValue());
     }
 
+    @Test
+    public void testHandleSetsVarPoolToTaskExecutionContext() throws Exception {
+        String responseBody = "{\"status\": \"success\", \"data\": \"test\"}";
+        String taskName = "testHttpTask";
+
+        TaskExecutionContext taskExecutionContext = Mockito.mock(TaskExecutionContext.class);
+        Mockito.when(taskExecutionContext.getTaskName()).thenReturn(taskName);
+
+        String url = withMockWebServer(DEFAULT_MOCK_PATH, HttpStatus.SC_OK, responseBody);
+        String paramData = generateHttpParameters(url, HttpRequestMethod.GET, "",
+                new ArrayList<>(), HttpCheckCondition.STATUS_CODE_DEFAULT, "");
+        Mockito.when(taskExecutionContext.getTaskParams()).thenReturn(paramData);
+
+        HttpTask httpTask = new HttpTask(taskExecutionContext);
+        httpTask.init();
+        httpTask.handle(null);
+
+        Mockito.verify(taskExecutionContext, Mockito.times(1)).setVarPool(Mockito.anyList());
+
+        Mockito.verify(taskExecutionContext).setVarPool(Mockito.argThat(varPool -> {
+            if (varPool == null || varPool.isEmpty()) {
+                return false;
+            }
+            Property property = varPool.get(0);
+            return property.getProp().equals(taskName + ".response")
+                    && property.getDirect() == Direct.OUT
+                    && property.getType() == DataType.VARCHAR
+                    && property.getValue().contains("status");
+        }));
+
+        Assertions.assertEquals(EXIT_CODE_SUCCESS, httpTask.getExitStatusCode());
+    }
+
     private String withMockWebServer(String path, int actualResponseCode,
                                      String actualResponseBody) throws IOException {
         MockWebServer server = new MockWebServer();