SaturnIC opened a new issue #6215: Pulsar localrun function cannot store state 
URL: https://github.com/apache/pulsar/issues/6215
 
 
   **Describe the bug**
   Hi,
   i am trying to deploy a localrun python pulsar function to a pulsar 
standalone docker container and connect to topics on another pulsar standalone 
container and i can never store any state
   successfully over the context object.
   
   If i run the same function alongside the brokers on the broker_container 
everything works fine,
   state can be stored and retrieved afterwards.
   
   **To Reproduce**
   If i deploy the function on the remote_container, i ll do it like this:
   ```
   /pulsar/bin/pulsar-admin functions localrun \
   --broker-service-url pulsar://broker_container:6650 \
   --tenant user1 \
   --namespace namespace1 \
   --py /pulsar_functions/function1.py \
   --name function_test \
   --user-config '{"output_topic": 
"persistent://user1/namespace1/output_topic"}' \
   --classname testfunction.Function1 \
   --custom-serde-inputs 
'{"persistent://user1/namespace1/input_topic1":"function1.MyJsonSerDe"}' \
   ```
   I can that the input msgs are indeed arriving but the state never gets 
stored.
   
   Did i forget to specify something? (like --broker-service-url?)
   
   **Expected behavior**
   Be able to store and retrieve state from the context object no matter if i 
run the 
   pulsar function on the broker cluster or a dedicated remote_container.
   
   Thank you

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
[email protected]


With regards,
Apache Git Services

Reply via email to