Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

[Bug] [pulsar-function-go] function process ackInputMessage error #19367

Closed
2 tasks done
quinniup opened this issue Jan 31, 2023 · 2 comments · Fixed by #20413 · May be fixed by #19372 or flowchartsman/pulsar#3
Closed
2 tasks done

[Bug] [pulsar-function-go] function process ackInputMessage error #19367

quinniup opened this issue Jan 31, 2023 · 2 comments · Fixed by #20413 · May be fixed by #19372 or flowchartsman/pulsar#3
Labels
type/bug The PR fixed a bug or issue reported a bug

Comments

@quinniup
Copy link

Search before asking

  • I searched in the issues and found nothing similar.

Version

Minimal reproduce step

  1. write function-go code;

  2. start function with golang:

 ./bin/pulsar-admin functions localrun \
--go ./func-test/publishFunc \
--inputs privatetenant/functions/input-test \
--tenant privatetenant \
--namespace functions \
--output privatetenant/functions/event \
--name test-hello \
--auto-ack true
  1. when functions receive msg, ack message had panic: runtime error: invalid memory address or nil pointer dereference

What did you expect to see?

Functions normal ack message.

What did you see instead?

[signal SIGSEGV: segmentation violation code=0x1 addr=0x18 pc=0xaf9cf3]

goroutine 1 [running]:
github.com/apache/pulsar/pulsar-function-go/pf.(*goInstance).ackInputMessage(0xc000198640, {0xdaefe0, 0xc000186b40})
        /Users/cheneyin/project/intelliJ/github/apache/pulsar/pulsar-function-go/pf/instance.go:395 +0xb3
github.com/apache/pulsar/pulsar-function-go/pf.(*goInstance).processResult(0xc000198640, {0xdaefe0?, 0xc000186b40?}, {0x0?, 0x0?, 0x1?})
        /Users/cheneyin/project/intelliJ/github/apache/pulsar/pulsar-function-go/pf/instance.go:387 +0x1bd
github.com/apache/pulsar/pulsar-function-go/pf.(*goInstance).startFunction(0xc000198640, {0xda5aa0?, 0xc0000afec0?})
        /Users/cheneyin/project/intelliJ/github/apache/pulsar/pulsar-function-go/pf/instance.go:179 +0x4f6
github.com/apache/pulsar/pulsar-function-go/pf.Start({0xb7d020?, 0xcd6c88?})
        /Users/cheneyin/project/intelliJ/github/apache/pulsar/pulsar-function-go/pf/function.go:171 +0x45
main.main()
        /Users/cheneyin/project/intelliJ/github/apache/pulsar/pulsar-function-go/examples/publishFunc/publishFunc.go:53 +0x27

Anything else?

No response

Are you willing to submit a PR?

  • I'm willing to submit a PR!
@quinniup quinniup added the type/bug The PR fixed a bug or issue reported a bug label Jan 31, 2023
@sijie sijie mentioned this issue Jan 31, 2023
Open
2 tasks
quinniup added a commit to quinniup/pulsar that referenced this issue Jan 31, 2023
@quinniup
[fix][broker] Fix function-go can't auto ack (apache#19367)
0e5441b
quinniup added a commit to quinniup/pulsar that referenced this issue Jan 31, 2023
@quinniup
[fix][broker] Fix function-go can't auto ack (apache#19367)
959a06f
This was referenced Jan 31, 2023
Closed
Open
quinniup added a commit to quinniup/pulsar that referenced this issue Feb 6, 2023
@quinniup
[fix][broker] Fix function-go style check (apache#19367)
00cad32
@github-actions
Copy link

github-actions bot commented Mar 3, 2023

The issue had no activity for 30 days, mark with Stale label.

@github-actions github-actions bot added the Stale label Mar 3, 2023
@pocockn
Copy link

pocockn commented May 19, 2023

I am also seeing this issue on github.com/apache/pulsar/pulsar-function-go v0.0.0-20230518181313-2ebb3797c3f3

@github-actions github-actions bot removed the Stale label May 20, 2023
flowchartsman added a commit to flowchartsman/pulsar that referenced this issue May 27, 2023
@flowchartsman
Use NameWithoutPartition() to lookup consumers.
ca20307 
- Fixes apache#19367
This was referenced May 27, 2023
Open
Merged
flowchartsman added a commit to flowchartsman/pfunc that referenced this issue May 27, 2023
@flowchartsman
port fix for apache/pulsar#19367
261660f
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Assignees
No one assigned
Labels
type/bug The PR fixed a bug or issue reported a bug
Projects
None yet
Milestone
No milestone
2 participants
@pocockn @quinniup