Skip to content

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

@quinniup

Description

@quinniup

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!

Metadata

Metadata

Assignees

No one assigned

    Labels

    type/bugThe PR fixed a bug or issue reported a bug

    Type

    No type
    No fields configured for issues without a type.

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions