codelipenghui commented on issue #2330: Functions localrun quit by can't get
the reason
URL:
https://github.com/apache/incubator-pulsar/issues/2330#issuecomment-411298133
Topic of plat.correctness.verification is a partitioned topic with six
partitions.
When i set input to plat.correctness.verification local run will quit.
When i set input to plat.correctness.verification-partition-0 local run can
process success.
```shell
# Local run success
bin/pulsar-admin functions localrun --jar
target/function-starter-1.0.0-all.jar --className
com.codelipenghui.pulsar.function.WordCountFunction --inputs
persistent://public/default/plat.correctness.verification-partition-0 --output
persistent://public/default/plat.correctness.verification.wordcount.output
--name plat-correctness-verification-wordcount
```
```shell
# Local run quit
bin/pulsar-admin functions localrun --jar
target/function-starter-1.0.0-all.jar --className
com.codelipenghui.pulsar.function.WordCountFunction --inputs
persistent://public/default/plat.correctness.verification --output
persistent://public/default/plat.correctness.verification.wordcount.output
--name plat-correctness-verification-wordcount
```
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
With regards,
Apache Git Services