timeout error with Java SDK

[hollywater]

i got a serious error while using java lib to query workflow-templates, please kind to help me, thanks a lot.

1. java client error:

Exception when calling WorkflowServiceApi#workflowServiceListWorkflows
Status code: 0
Reason: null
Response headers: null
io.argoproj.workflow.ApiException: java.net.**SocketTimeoutException: timeout**
	at io.argoproj.workflow.ApiClient.execute(ApiClient.java:928)
	at io.argoproj.workflow.apis.WorkflowTemplateServiceApi.workflowTemplateServiceListWorkflowTemplatesWithHttpInfo(WorkflowTemplateServiceApi.java:782)
	at io.argoproj.workflow.apis.WorkflowTemplateServiceApi.workflowTemplateServiceListWorkflowTemplates(WorkflowTemplateServiceApi.java:752)

2. kubectl get pods -n argo

NAME                                READY   STATUS    RESTARTS   AGE
argo-server-6dccfbd89f-l65rp        1/1     Running   0          17m
workflow-controller-c6c784b-7kcd7   1/1     Running   0          18m

3. kubectl logs argo-server-6dccfbd89f-l65rp -n argo

time="2024-07-24T00:35:42.064Z" level=info duration=10.009123934s method=GET path=/api/v1/workflow-templates/argo **size=39 status=408**
E0724 00:35:42.064916       1 request.go:977] **Unexpected error when reading response body**: context canceled
time="2024-07-24T00:35:42.065Z" level=error msg="finished unary call with code Internal" error="rpc error: code = Internal desc = unexpected error when reading response body. Please retry. Original error: context canceled" grpc.code=Internal grpc.method=ListWorkflowTemplates grpc.service=workflowtemplate.WorkflowTemplateService grpc.start_time="2024-07-24T00:35:32Z" grpc.time_ms=10008.839 span.kind=server system=grpc

4. i can visit url through chrome

http://XXXXX:30180/api/v1/workflow-templates/argo , got:

{"metadata":{"resourceVersion":"3027628"},"items":[{"metadata":{"name":"test-template-xxhfd","generateName":"test-template-","namespace":"argo","uid":"57ea9ea7-5f52-407c-9a34-1620cb410e6f","resourceVersion":"3027062","generation":1,"creationTimestamp":"2024-07-24T00:34:34Z","labels":{"workflows.argoproj.io/creator":"system-serviceaccount-argo-argo-server"},"managedFields":[{"manager":"argo","operation":"Update","apiVersion":"argoproj.io/v1alpha1","time":"2024-07-24T00:34:34Z","fieldsType":"FieldsV1","fieldsV1":{"f:metadata":{"f:generateName":{},"f:labels":{".":{},"f:workflows.argoproj.io/creator":{}}},"f:spec":{}}}]},"spec":{"templates":[{"name":"main","inputs":{},"outputs":{},"metadata":{},"container":{"name":"","image":"argoproj/argosay:v2","command":["cowsay"],"args":["hello world"],"resources":{}}}],"entrypoint":"main","arguments":{},"serviceAccountName":"argo"}}]}

some information about this error:

1. environment:

• argo-server: v3.5.8 \ argo-server: v3.5.7
• quay.io/argoproj/argocli:v3.5.8 \ quay.io/argoproj/argocli:v3.5.7 \ argoproj/workflow-controller:dev-fix-list-load
• argo-client-java-v3.5.8.jar/argo-client-java-v3.5.7.jar
• k8s: v1.20.10
• docker: 19.03.0

i try many versions, but the same error

2. i remove the auth because it's in LAN:

• kubectl -n argo port-forward --address 0.0.0.0 svc/argo-server 2746:2746 > /dev/null &
• kubectl patch deployment argo-server --namespace argo --type='json' -p='[{"op": "replace", "path": "/spec/template/spec/containers/0/args", "value": ["server", "--auth-mode=server", "--secure=false"]},{"op": "replace", "path": "/spec/template/spec/containers/0/readinessProbe/httpGet/scheme", "value": "HTTP"}]'

3. ingress

---
apiVersion: networking.k8s.io/v1
kind: Ingress
metadata:
  name: argo-ingress
  namespace: argo
spec:
  ingressClassName: nginx
  rules:
    - host: argo.abc.com
      http:
        paths:
        - path: /
          pathType: Prefix
          backend:
            service:
              name: argo-server
              port:
                number: 2746

4. java code:

  public static WorkflowServiceApi getWorkflowApiInstance() {
       ApiClient defaultClient = Configuration.getDefaultApiClient();
       defaultClient.setBasePath("http://XXXXX");
       WorkflowServiceApi apiInstance = new WorkflowServiceApi(defaultClient);
       return apiInstance;
   }

   public static void listWorkflowTemplate() {
       WorkflowTemplateServiceApi apiInstance = getWorkflowTemplateApiInstance();
       String namespace = "argo"; // String |
       String namePattern = null;
       String listOptionsLabelSelector = null;
       String listOptionsFieldSelector = null;
       Boolean listOptionsWatch = true; 
       Boolean listOptionsAllowWatchBookmarks = true; 
       String listOptionsResourceVersion = null; 
       String listOptionsResourceVersionMatch = null; 
       String listOptionsTimeoutSeconds = null; 
       String listOptionsLimit = "100"; 
       String listOptionsContinue = null; 
       try {
           IoArgoprojWorkflowV1alpha1WorkflowTemplateList result = apiInstance.workflowTemplateServiceListWorkflowTemplates(namespace, namePattern, listOptionsLabelSelector, listOptionsFieldSelector, listOptionsWatch, listOptionsAllowWatchBookmarks, listOptionsResourceVersion, listOptionsResourceVersionMatch, listOptionsTimeoutSeconds, listOptionsLimit, listOptionsContinue);
           System.out.println(result);
       } catch (ApiException e) {
           System.err.println("Exception when calling WorkflowServiceApi#workflowServiceListWorkflows");
           System.err.println("Status code: " + e.getCode());
           System.err.println("Reason: " + e.getResponseBody());
           System.err.println("Response headers: " + e.getResponseHeaders());
           e.printStackTrace();
       }
   }


   public static void main(String[] args) throws Exception{
       listWorkflowTemplate();
   }

[hollywater]

hi, any idea about this timeout error?
i've tried this image - argoproj/workflow-controller:dev-fix-list-load

and i can create and delete workflow-templates through java sdk, but not list them.

[hollywater]

OK , i lost my patience. i turn to raw way.

use httpclient to request url as below

Then i use the method deserialize() of class io.argoproj.workflow.JSON to parse httpclient return body manually.

And then i find that class JSON also have some problems.

Finally i have to copy the same code from git source to create the same name JSON.java of package io.argoproj.workflow in my project to cover the class in argo-client-java-v3.5.8.jar. And in my JSON.java, i register some additional new type adapter.

And at last i can use JSON to parse the return-content of url request, and parse them into IoArgoprojWorkflowV1alpha1WorkflowTemplateList.

That is all. It is a temporary solution.

[hollywater]

It is a very interesting problem. I can visit template list through url, but i cant visit through java sdk. So I finally have to do things by myself as above. Hope it will help you. Close it myself.