0gap commented on issue #15100:
URL: https://github.com/apache/pulsar/issues/15100#issuecomment-1102845237
Just to clarify a bit. I am seeing some of the messages when starting the
function, but after a few of them, I end up with the SIGSEGV:
```
Filtering radar for custom-data: 12345
map[count:1 msg:test msg: 18:57:28 test_id:3 producerID:Producer 1]
custom-data is 12345Input message in topic is: {"test_id":2,"msg":"test msg:
16:10:13", "count":1, "producerID":"Producer 2"}
Filtering radar for custom-data: 12345
map[count:1 msg:test msg: 16:10:13 test_id:2 producerID:Producer 2]
custom-data is 12345Input message in topic is: {"test_id":2,"msg":"test msg:
16:10:13", "count":2, "producerID":"Producer 2"}
Filtering radar for custom-data: 12345
map[count:2 msg:test msg: 16:10:13 test_id:2 producerID:Producer 2]
custom-data is 12345Input message in topic is: {"test_id":3,"msg":"test msg:
16:30:39", "count":1, "producerID":"Producer 1"}
Filtering radar for custom-data: 12345
map[count:1 msg:test msg: 16:30:39 test_id:3 producerID:Producer 1]
2022/04/19 16:15:02.729 log.go:46: [info] Starting metrics server on port
38229
2022/04/19 16:15:02.737 once.go:68: [warning] [Connection was closed]
producer_name=standalone-3-89 producerID=2 cnx=127.0.0.1:58704 ->
127.0.0.1:6650 topic=non-persistent://zerogap/test-nam/filtered-msgs-partition-1
2022/04/19 16:15:02.737 once.go:68: [warning] [Connection was closed]
topic=non-persistent://zerogap/test-nam/filtered-msgs-partition-0
producer_name=standalone-3-88 producerID=1 cnx=127.0.0.1:58704 -> 127.0.0.1:6650
2022/04/19 16:15:02.737 once.go:68: [warning] [Connection was closed]
topic=persistent://public/default/func-logs producerID=3
producer_name=standalone-3-90 cnx=127.0.0.1:58704 -> 127.0.0.1:6650
panic: runtime error: invalid memory address or nil pointer dereference
[signal SIGSEGV: segmentation violation code=0x1 addr=0x18 pc=0xaece73]
goroutine 91 [running]:
github.com/apache/pulsar/pulsar-function-go/pf.(*goInstance).ackInputMessage(0xc0001fca00,
{0xe75e80, 0xc0001ec1e0})
/home/zerogap/go/pkg/mod/github.com/apache/pulsar/[email protected]/pf/instance.go:396
+0xb3
github.com/apache/pulsar/pulsar-function-go/pf.(*goInstance).processResult.func1({0xd11780?,
0x3f814d471f6813ff?}, 0x1?, {0x0?, 0x0?})
/home/zerogap/go/pkg/mod/github.com/apache/pulsar/[email protected]/pf/instance.go:378
+0x112
github.com/apache/pulsar-client-go/pulsar.(*partitionProducer).ReceivedSendReceipt(0xc000160000,
0xc000225740)
/home/zerogap/go/pkg/mod/github.com/apache/[email protected]/pulsar/producer_partition.go:830
+0x7f0
github.com/apache/pulsar-client-go/pulsar/internal.(*connection).handleSendReceipt(0xc0000f9ce0,
0xc000225740)
/home/zerogap/go/pkg/mod/github.com/apache/[email protected]/pulsar/internal/connection.go:673
+0xe8
github.com/apache/pulsar-client-go/pulsar/internal.(*connection).internalReceivedCommand(0xc0000f9ce0,
0xc000311e00, {0x0?, 0x0})
/home/zerogap/go/pkg/mod/github.com/apache/[email protected]/pulsar/internal/connection.go:558
+0x14a
github.com/apache/pulsar-client-go/pulsar/internal.(*connection).run(0xc0000f9ce0)
/home/zerogap/go/pkg/mod/github.com/apache/[email protected]/pulsar/internal/connection.go:415
+0x3a5
github.com/apache/pulsar-client-go/pulsar/internal.(*connection).start.func1()
/home/zerogap/go/pkg/mod/github.com/apache/[email protected]/pulsar/internal/connection.go:227
+0x65
created by
github.com/apache/pulsar-client-go/pulsar/internal.(*connection).start
/home/zerogap/go/pkg/mod/github.com/apache/[email protected]/pulsar/internal/connection.go:223
+0x70
```
--
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.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
