geomagilles
commented
7 months ago Hi @wssmd, which Infinitic version are you using?
Btw, I can see 2 issues:
-
from 2024-04-27 14:12:37:359 to 2024-04-27 14:12:37:590, it seems to be a Pulsar issue, a few warning are emitted because the topic
persistent://infinitic/dev/response:standalone-0-51is temporarily unavailable (a topic used to send back a result to the client when a request is done synchronously). I can not speculate the origin of this Pulsar error, but if it is really temporary, it should work after the automatic retries. Is this the case? -
2024-04-27 14:12:37:590, there is another error, but the stacktrace above is truncated and I can not see which error.
It seems you are running https://github.com/infiniticio/infinitic-example-java-hello-world?
wssmd
I get this error when dispatching a service synchronously. This error occurs in the worker after the response has been delivered to the client. Rerunning the client after getting the error makes the client actually deliver the "request" and the worker executes the service but does not deliver the response back to the client.
I should point out that I am using java17. With java11 the error still occurs but the client receives responses from the worker.
` 2024-04-27 14:12:37:359 +0200 WARN ClientCnx - [id: 0xf31cb2bd, L:/127.0.0.1:59049 - R:localhost/127.0.0.1:6650] Received error from server: org.apache.pulsar.broker.service.BrokerServiceException$TopicFencedException: Topic is temporarily unavailable 2024-04-27 14:12:37:372 +0200 ERROR ProducerImpl - [persistent://infinitic/dev/response:standalone-0-51] [standalone-0-54] Failed to create producer: {"errorMsg":"org.apache.pulsar.broker.service.BrokerServiceException$TopicFencedException: Topic is temporarily unavailable","reqId":4541017055689146743, "remote":"localhost/127.0.0.1:6650", "local":"/127.0.0.1:59049"} 2024-04-27 14:12:37:373 +0200 WARN ConnectionHandler - [persistent://infinitic/dev/response:standalone-0-51] [standalone-0-54] Error connecting to broker: org.apache.pulsar.client.api.PulsarClientException$LookupException: {"errorMsg":"org.apache.pulsar.broker.service.BrokerServiceException$TopicFencedException: Topic is temporarily unavailable","reqId":4541017055689146743, "remote":"localhost/127.0.0.1:6650", "local":"/127.0.0.1:59049"} 2024-04-27 14:12:37:374 +0200 WARN ConnectionHandler - [persistent://infinitic/dev/response:standalone-0-51] [standalone-0-54] Could not get connection to broker: org.apache.pulsar.client.api.PulsarClientException$LookupException: {"errorMsg":"org.apache.pulsar.broker.service.BrokerServiceException$TopicFencedException: Topic is temporarily unavailable","reqId":4541017055689146743, "remote":"localhost/127.0.0.1:6650", "local":"/127.0.0.1:59049"} -- Will try again in 0.191 s 2024-04-27 14:12:37:589 +0200 WARN ClientCnx - [id: 0xf31cb2bd, L:/127.0.0.1:59049 - R:localhost/127.0.0.1:6650] Received error from server: Topic Not Found. 2024-04-27 14:12:37:590 +0200 ERROR ProducerImpl - [persistent://infinitic/dev/response:standalone-0-51] [standalone-0-54] Failed to create producer: {"errorMsg":"Topic Not Found.","reqId":4541017055689146752, "remote":"localhost/127.0.0.1:6650", "local":"/127.0.0.1:59049"} 2024-04-27 14:14:02:613 +0200 WARN Consumer - Topic: persistent://infinitic/dev/workflow-task-executor:HelloWorkflow (88:12:1) - Exception when processing ExecuteTask(messageId=018f1f7a-088e-74a5-a3c4-d9efeac1bf37, serviceName=infinitic.workflow.Executor, taskId=018f1f7a-0889-7664-9dce-d9913219f198, emitterName=standalone-0-54, taskRetrySequence=0, taskRetryIndex=0, requester=WorkflowRequester(workflowName=HelloWorkflow, workflowVersion=0, workflowId=018f1f79-eddc-7220-8045-9b4785dea4c2, workflowMethodName=greet, workflowMethodId=018f1f79-eddc-7220-8045-9b4785dea4c2), workflowName=null, workflowId=null, workflowMethodId=null, taskTags=[], taskMeta=TaskMeta(map={}), clientWaiting=false, methodName=handle, methodParameterTypes=MethodParameterTypes(types=[io.infinitic.common.workflows.data.workflowTasks.WorkflowTaskParameters]), methodParameters=MethodParameters(parameters=[{bytes="wwEUb1tA+jS51QwwLjEzLjBIMDE4ZjFmN2EtMDg4OS03NjY0LTlkY2UtZDk5MTMyMTlmMTk4SDAxOGYxZjc5LWVkZGMtNzIyMC04MDQ1LTliNDc4NWRlYTRjMhpIZWxsb1dvcmtmbG93AgAAAAAEApKd0PfjYwIec3RhbmRhbG9uZS0wLTU2AEgwMThmMWY3OS1lZGRjLTcyMjAtODA0NS05YjQ3ODVkZWE0YzICHnN0YW5kYWxvbmUtMC01NgAAAAAACmdyZWV0AgIgamF2YS5sYW5nLlN0cmluZwACDCJ3YXNzIgQCEmphdmFDbGFzcyBqYXZhLmxhbmcuU3RyaW5nAAAAAAACAkgwMThmMWY3YS0wNWFkLTdmOTctYjFhZS1mMjU2ZGE3MTZkYjAALEhlbGxvU2VydmljZTo6c2F5SGVsbG8CABgiSGVsbG8gd2FzcyIEAhJqYXZhQ2xhc3MgamF2YS5sYW5nLlN0cmluZwACABhIZWxsb1NlcnZpY2UQc2F5SGVsbG8CIGphdmEubGFuZy5TdHJpbmcAAgwid2FzcyIEAhJqYXZhQ2xhc3MgamF2YS5sYW5nLlN0cmluZwAAAAAAAAACAgJIMDE4ZjFmN2EtMDVhZC03Zjk3LWIxYWUtZjI1NmRhNzE2ZGIwAAIAGCJIZWxsbyB3YXNzIgQCEmphdmFDbGFzcyBqYXZhLmxhbmcuU3RyaW5nAAIAQDFmMThkMTFjYzc5MTkwNTQxODMzOGJlMGFhZTQ3NjdhAgIYIkhlbGxvIHdhc3MiBAISamF2YUNsYXNzIGphdmEubGFuZy5TdHJpbmcAAgIAAgQAAB5zdGFuZGFsb25lLTAtNTQ=", type=AVRO_WITH_SCHEMA, meta={javaClass=WorkflowTaskParameters}}]), lastError=null, workflowVersion=null)
`