diff --git a/.github/workflows/interactive.yml b/.github/workflows/interactive.yml index bf13f00e66ac..716c79ac2627 100644 --- a/.github/workflows/interactive.yml +++ b/.github/workflows/interactive.yml @@ -218,10 +218,6 @@ jobs: bash hqps_sdk_test.sh ${TMP_INTERACTIVE_WORKSPACE} ./interactive_config_test.yaml python sed -i 's/temp_workspace/interactive_workspace/g' ./interactive_config_test.yaml sed -i 's/thread_num_per_worker: 4/thread_num_per_worker: 1/g' ./interactive_config_test.yaml - - - name: Setup tmate session - if: true - uses: mxschmitt/action-tmate@v3 - name: Robustness test env: diff --git a/flex/tests/hqps/interactive_config_test.yaml b/flex/tests/hqps/interactive_config_test.yaml index 0e1f9f15ed21..87371fa6d9d8 100644 --- a/flex/tests/hqps/interactive_config_test.yaml +++ b/flex/tests/hqps/interactive_config_test.yaml @@ -5,7 +5,7 @@ compute_engine: type: hiactor workers: - localhost:10000 - thread_num_per_worker: 1 + thread_num_per_worker: 4 store: type: cpp-mcsr metadata_store: diff --git a/interactive_engine/compiler/src/main/java/com/alibaba/graphscope/common/ir/meta/reader/HttpIrMetaReader.java b/interactive_engine/compiler/src/main/java/com/alibaba/graphscope/common/ir/meta/reader/HttpIrMetaReader.java index 2e12792d7bf1..e9212af1c880 100644 --- a/interactive_engine/compiler/src/main/java/com/alibaba/graphscope/common/ir/meta/reader/HttpIrMetaReader.java +++ b/interactive_engine/compiler/src/main/java/com/alibaba/graphscope/common/ir/meta/reader/HttpIrMetaReader.java @@ -45,6 +45,7 @@ public class HttpIrMetaReader implements IrMetaReader { private static final String CONTENT_TYPE = "Content-Type"; private static final String APPLICATION_JSON = "application/json; utf-8"; + private static final int TIME_OUT_SECONDS = 1; // Expect to get response in 1 second private final HttpClient httpClient; private final Configs configs; @@ -129,6 +130,7 @@ private HttpResponse sendRequest(String requestUri) .uri(URI.create(requestUri)) .headers(CONTENT_TYPE, APPLICATION_JSON) .GET() + .timeout(java.time.Duration.ofSeconds(TIME_OUT_SECONDS)) .build(); return httpClient.send(request, HttpResponse.BodyHandlers.ofString()); }