GitHub user bohuslav-broza added a comment to the discussion: pulsar IO sink
missing after functions worker cluster leader restart
hi Lari,
thanks for helping me on this issue! I have reproduced the issue in my
environment following way =>
The sink testsink is running. I have restarted 3x broker-0 and 1x broker-1
```
date; k delete pod -n pulsar pulsar-broker-0
Wed Apr 23 03:13:02 PM CEST 2025
pod "pulsar-broker-0" deleted
date; k delete pod -n pulsar pulsar-broker-0
Wed Apr 23 03:14:56 PM CEST 2025
pod "pulsar-broker-0" deleted
date; k delete pod -n pulsar pulsar-broker-0
Wed Apr 23 03:16:19 PM CEST 2025
pod "pulsar-broker-0" deleted
date; k delete pod -n pulsar pulsar-broker-1
Wed Apr 23 03:18:25 PM CEST 2025
pod "pulsar-broker-1" deleted
```
After restart of the broker-1 I have ended in a situation where the pipeline is
not running but operator sees it in the ready state
```
root@tiger-tools-756d99c95c-dq6bk:/tools# date; pulsarctl functions-worker
get-cluster
Wed Apr 23 01:19:44 PM UTC 2025
[
{
"workerId":
"c-pulsar-fw-pulsar-broker-0.pulsar-broker.pulsar.svc.cluster.local-8080",
"workerHostname": "pulsar-broker-0.pulsar-broker.pulsar.svc.cluster.local",
"port": 8080
},
{
"workerId":
"c-pulsar-fw-pulsar-broker-1.pulsar-broker.pulsar.svc.cluster.local-8080",
"workerHostname": "pulsar-broker-1.pulsar-broker.pulsar.svc.cluster.local",
"port": 8080
}
]root@tiger-tools-756d99c95c-dq6bk:/tools# date; pulsarctl functions-worker
get-cluster-leader
Wed Apr 23 01:19:49 PM UTC 2025
{
"workerId":
"c-pulsar-fw-pulsar-broker-1.pulsar-broker.pulsar.svc.cluster.local-8080",
"workerHostname": "pulsar-broker-1.pulsar-broker.pulsar.svc.cluster.local",
"port": 8080
}root@tiger-tools-756d99c95c-dq6bk:/tools# date; pulsarctl functions-worker
get-function-assignments
Wed Apr 23 01:19:54 PM UTC 2025
[bohuslav.broza@mgmt-dev01:~] date; k get pulsarsink -n auditlog
Wed Apr 23 03:20:06 PM CEST 2025
NAME RESOURCE_NAME GENERATION OBSERVED_GENERATION READY
mia-auditlog001 mia-auditlog001 1 1 True
testsink testsink 22 22 True
```
[Logs from
brokers](https://github.com/user-attachments/files/19869490/Archive.zip)
GitHub link:
https://github.com/apache/pulsar/discussions/24202#discussioncomment-12923502
----
This is an automatically sent email for commits@pulsar.apache.org.
To unsubscribe, please send an email to: commits-unsubscr...@pulsar.apache.org
