You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by GitBox <gi...@apache.org> on 2022/11/02 10:36:33 UTC
[GitHub] [pulsar-client-go] nodece opened a new issue, #882: Flaky-test:
nodece opened a new issue, #882:
URL: https://github.com/apache/pulsar-client-go/issues/882
See https://github.com/apache/pulsar-client-go/actions/runs/3304118256/jobs/5604378042
```
time="2022-11-02T10:04:16Z" level=info msg="Created consumer" consumerID=4 name=zkjpl subscription=sub01-1667383455 topic="persistent://public/default/sub01-1667383455-RETRY"
time="2022-11-02T10:04:16Z" level=info msg="Connected producer" cnx="127.0.0.1:60616 -> 127.0.0.1:6650" epoch=0 topic="persistent://public/default/sub01-1667383455-RETRY"
time="2022-11-02T10:04:16Z" level=info msg="Created producer" cnx="127.0.0.1:60616 -> 127.0.0.1:6650" producerID=4 producer_name=standalone-0-137 topic="persistent://public/default/sub01-1667383455-RETRY"
time="2022-11-02T10:04:16Z" level=info msg="Connected producer" cnx="127.0.0.1:60616 -> 127.0.0.1:6650" epoch=0 topic="persistent://public/default/sub01-1667383455-DLQ"
time="2022-11-02T10:04:16Z" level=info msg="Created producer" cnx="127.0.0.1:60616 -> 127.0.0.1:6650" producerID=5 producer_name=standalone-0-138 topic="persistent://public/default/sub01-1667383455-DLQ"
retry consumed: 300
time="2022-11-02T10:04:17Z" level=info msg="Connected consumer" consumerID=5 name=vqwac subscription=sub01-1667383455 topic="persistent://public/default/sub01-1667383455-DLQ"
time="2022-11-02T10:04:17Z" level=info msg="Created consumer" consumerID=5 name=vqwac subscription=sub01-1667383455 topic="persistent://public/default/sub01-1667383455-DLQ"
coverage: 48.6% of statements
panic: test timed out after 20m0s
goroutine 5188 [running]:
testing.(*M).startAlarm.func1()
/usr/local/go/src/testing/testing.go:2036 +0xbb
created by time.goFunc
/usr/local/go/src/time/sleep.go:176 +0x48
goroutine 1 [chan receive, 17 minutes]:
testing.(*T).Run(0xc00019a340, {0x113f4a1, 0x7}, 0x1196608)
/usr/local/go/src/testing/testing.go:1494 +0x789
testing.runTests.func1(0x0?)
/usr/local/go/src/testing/testing.go:1846 +0x9a
testing.tRunner(0xc00019a340, 0xc000111b68)
/usr/local/go/src/testing/testing.go:1446 +0x217
testing.runTests(0xc0001980a0?, {0x17aa560, 0xb1, 0xb1}, {0x40?, 0x7f9467774528?, 0x17f99c0?})
/usr/local/go/src/testing/testing.go:1844 +0x7ed
testing.(*M).Run(0xc0001980a0)
/usr/local/go/src/testing/testing.go:1726 +0xa85
main.main()
_testmain.go:513 +0x3bd
goroutine 2572 [select]:
github.com/apache/pulsar-client-go/pulsar/internal.(*connection).run(0xc0001b4f20)
/pulsar-client-go/pulsar/internal/connection.go:411 +0x67b
github.com/apache/pulsar-client-go/pulsar/internal.(*connection).start.func1()
/pulsar-client-go/pulsar/internal/connection.go:227 +0xac
created by github.com/apache/pulsar-client-go/pulsar/internal.(*connection).start
/pulsar-client-go/pulsar/internal/connection.go:223 +0xb1
goroutine 2499 [IO wait]:
internal/poll.runtime_pollWait(0x7f9466fb4d28, 0x72)
/usr/local/go/src/runtime/netpoll.go:305 +0x89
internal/poll.(*pollDesc).wait(0xc000214998, 0xc0006dd000?, 0x0)
/usr/local/go/src/internal/poll/fd_poll_runtime.go:84 +0xbd
internal/poll.(*pollDesc).waitRead(...)
/usr/local/go/src/internal/poll/fd_poll_runtime.go:89
internal/poll.(*FD).Read(0xc000214980, {0xc0006dd000, 0x1000, 0x1000})
/usr/local/go/src/internal/poll/fd_unix.go:167 +0x415
net.(*netFD).Read(0xc000214980, {0xc0006dd000, 0x1000, 0x1000})
/usr/local/go/src/net/fd_posix.go:55 +0x51
net.(*conn).Read(0xc00020cdf8, {0xc0006dd000, 0x1000, 0x1000})
/usr/local/go/src/net/net.go:183 +0xb1
io.ReadAtLeast({0x12fafa0, 0xc00020cdf8}, {0xc0006dd000, 0x1000, 0x1000}, 0x4)
/usr/local/go/src/io/io.go:332 +0xde
github.com/apache/pulsar-client-go/pulsar/internal.(*connectionReader).readAtLeast(0xc0006ce880, 0x4)
/pulsar-client-go/pulsar/internal/connection_reader.go:125 +0x215
github.com/apache/pulsar-client-go/pulsar/internal.(*connectionReader).readSingleCommand(0xc0006ce880)
/pulsar-client-go/pulsar/internal/connection_reader.go:71 +0xd4
github.com/apache/pulsar-client-go/pulsar/internal.(*connectionReader).readFromConnection(0xc0006ce880)
/pulsar-client-go/pulsar/internal/connection_reader.go:45 +0x85
created by github.com/apache/pulsar-client-go/pulsar/internal.(*connection).run
/pulsar-client-go/pulsar/internal/connection.go:388 +0x1ba
goroutine 983 [chan receive, 19 minutes]:
github.com/apache/pulsar-client-go/pulsar.(*partitionConsumer).runEventsLoop(0xc0004c4c40)
/pulsar-client-go/pulsar/consumer_partition.go:1078 +0x245
created by github.com/apache/pulsar-client-go/pulsar.newPartitionConsumer
/pulsar-client-go/pulsar/consumer_partition.go:291 +0x1812
goroutine 2452 [select]:
github.com/apache/pulsar-client-go/pulsar/internal.(*connection).runPingCheck(0xc00024fce0, 0xc000409450)
/pulsar-client-go/pulsar/internal/connection.go:431 +0xf0
created by github.com/apache/pulsar-client-go/pulsar/internal.(*connection).run
/pulsar-client-go/pulsar/internal/connection.go:389 +0x28a
goroutine 2453 [select, 19 minutes]:
github.com/apache/pulsar-client-go/pulsar/internal.(*connection).run.func2()
/pulsar-client-go/pulsar/internal/connection.go:396 +0xf7
created by github.com/apache/pulsar-client-go/pulsar/internal.(*connection).run
/pulsar-client-go/pulsar/internal/connection.go:394 +0x4dd
goroutine 2451 [IO wait]:
internal/poll.runtime_pollWait(0x7f9466fb51d8, 0x72)
/usr/local/go/src/runtime/netpoll.go:305 +0x89
internal/poll.(*pollDesc).wait(0xc000214618, 0xc0006ba000?, 0x0)
/usr/local/go/src/internal/poll/fd_poll_runtime.go:84 +0xbd
internal/poll.(*pollDesc).waitRead(...)
/usr/local/go/src/internal/poll/fd_poll_runtime.go:89
internal/poll.(*FD).Read(0xc000214600, {0xc0006ba000, 0x1000, 0x1000})
/usr/local/go/src/internal/poll/fd_unix.go:167 +0x415
net.(*netFD).Read(0xc000214600, {0xc0006ba000, 0x1000, 0x1000})
/usr/local/go/src/net/fd_posix.go:55 +0x51
net.(*conn).Read(0xc000014e78, {0xc0006ba000, 0x1000, 0x1000})
/usr/local/go/src/net/net.go:183 +0xb1
io.ReadAtLeast({0x12fafa0, 0xc000014e78}, {0xc0006ba000, 0x1000, 0x1000}, 0x4)
/usr/local/go/src/io/io.go:332 +0xde
github.com/apache/pulsar-client-go/pulsar/internal.(*connectionReader).readAtLeast(0xc000194f40, 0x4)
/pulsar-client-go/pulsar/internal/connection_reader.go:125 +0x215
github.com/apache/pulsar-client-go/pulsar/internal.(*connectionReader).readSingleCommand(0xc000194f40)
/pulsar-client-go/pulsar/internal/connection_reader.go:71 +0xd4
github.com/apache/pulsar-client-go/pulsar/internal.(*connectionReader).readFromConnection(0xc000194f40)
/pulsar-client-go/pulsar/internal/connection_reader.go:45 +0x85
created by github.com/apache/pulsar-client-go/pulsar/internal.(*connection).run
/pulsar-client-go/pulsar/internal/connection.go:388 +0x1ba
goroutine 982 [select, 19 minutes]:
github.com/apache/pulsar-client-go/pulsar.(*partitionConsumer).dispatcher(0xc0004c4c40)
/pulsar-client-go/pulsar/consumer_partition.go:933 +0x725
created by github.com/apache/pulsar-client-go/pulsar.newPartitionConsumer
/pulsar-client-go/pulsar/consumer_partition.go:289 +0x1792
goroutine 2577 [select]:
github.com/apache/pulsar-client-go/pulsar/internal.(*connection).runPingCheck(0xc0001b4f20, 0xc000316820)
/pulsar-client-go/pulsar/internal/connection.go:431 +0xf0
created by github.com/apache/pulsar-client-go/pulsar/internal.(*connection).run
/pulsar-client-go/pulsar/internal/connection.go:389 +0x28a
goroutine 2204 [select]:
github.com/apache/pulsar-client-go/pulsar/internal.(*connection).run(0xc0002c3ce0)
/pulsar-client-go/pulsar/internal/connection.go:411 +0x67b
github.com/apache/pulsar-client-go/pulsar/internal.(*connection).start.func1()
/pulsar-client-go/pulsar/internal/connection.go:227 +0xac
created by github.com/apache/pulsar-client-go/pulsar/internal.(*connection).start
/pulsar-client-go/pulsar/internal/connection.go:223 +0xb1
goroutine 984 [select, 19 minutes]:
github.com/apache/pulsar-client-go/pulsar.(*partitionConsumer).runEventsLoop.func2()
/pulsar-client-go/pulsar/consumer_partition.go:1066 +0x148
created by github.com/apache/pulsar-client-go/pulsar.(*partitionConsumer).runEventsLoop
/pulsar-client-go/pulsar/consumer_partition.go:1064 +0x1be
goroutine 2209 [select]:
github.com/apache/pulsar-client-go/pulsar/internal.(*connection).runPingCheck(0xc0002c3ce0, 0xc000508cd0)
/pulsar-client-go/pulsar/internal/connection.go:431 +0xf0
created by github.com/apache/pulsar-client-go/pulsar/internal.(*connection).run
/pulsar-client-go/pulsar/internal/connection.go:389 +0x28a
goroutine 2210 [select, 19 minutes]:
github.com/apache/pulsar-client-go/pulsar/internal.(*connection).run.func2()
/pulsar-client-go/pulsar/internal/connection.go:396 +0xf7
created by github.com/apache/pulsar-client-go/pulsar/internal.(*connection).run
/pulsar-client-go/pulsar/internal/connection.go:394 +0x4dd
goroutine 2208 [IO wait]:
internal/poll.runtime_pollWait(0x7f9466fb50e8, 0x72)
/usr/local/go/src/runtime/netpoll.go:305 +0x89
internal/poll.(*pollDesc).wait(0xc000107518, 0xc00064c000?, 0x0)
/usr/local/go/src/internal/poll/fd_poll_runtime.go:84 +0xbd
internal/poll.(*pollDesc).waitRead(...)
/usr/local/go/src/internal/poll/fd_poll_runtime.go:89
internal/poll.(*FD).Read(0xc000107500, {0xc00064c000, 0x1000, 0x1000})
/usr/local/go/src/internal/poll/fd_unix.go:167 +0x415
net.(*netFD).Read(0xc000107500, {0xc00064c000, 0x1000, 0x1000})
/usr/local/go/src/net/fd_posix.go:55 +0x51
net.(*conn).Read(0xc000014bb8, {0xc00064c000, 0x1000, 0x1000})
/usr/local/go/src/net/net.go:183 +0xb1
io.ReadAtLeast({0x12fafa0, 0xc000014bb8}, {0xc00064c000, 0x1000, 0x1000}, 0x4)
/usr/local/go/src/io/io.go:332 +0xde
github.com/apache/pulsar-client-go/pulsar/internal.(*connectionReader).readAtLeast(0xc000352500, 0x4)
/pulsar-client-go/pulsar/internal/connection_reader.go:125 +0x215
github.com/apache/pulsar-client-go/pulsar/internal.(*connectionReader).readSingleCommand(0xc000352500)
/pulsar-client-go/pulsar/internal/connection_reader.go:71 +0xd4
github.com/apache/pulsar-client-go/pulsar/internal.(*connectionReader).readFromConnection(0xc000352500)
/pulsar-client-go/pulsar/internal/connection_reader.go:45 +0x85
created by github.com/apache/pulsar-client-go/pulsar/internal.(*connection).run
/pulsar-client-go/pulsar/internal/connection.go:388 +0x1ba
goroutine 1414 [select, 19 minutes]:
github.com/apache/pulsar-client-go/pulsar.(*partitionConsumer).runEventsLoop.func2()
/pulsar-client-go/pulsar/consumer_partition.go:1066 +0x148
created by github.com/apache/pulsar-client-go/pulsar.(*partitionConsumer).runEventsLoop
/pulsar-client-go/pulsar/consumer_partition.go:1064 +0x1be
goroutine 1412 [select, 19 minutes]:
github.com/apache/pulsar-client-go/pulsar.(*partitionConsumer).dispatcher(0xc00012d6c0)
/pulsar-client-go/pulsar/consumer_partition.go:933 +0x725
created by github.com/apache/pulsar-client-go/pulsar.newPartitionConsumer
/pulsar-client-go/pulsar/consumer_partition.go:289 +0x1792
goroutine 1413 [chan receive, 19 minutes]:
github.com/apache/pulsar-client-go/pulsar.(*partitionConsumer).runEventsLoop(0xc00012d6c0)
/pulsar-client-go/pulsar/consumer_partition.go:1078 +0x245
created by github.com/apache/pulsar-client-go/pulsar.newPartitionConsumer
/pulsar-client-go/pulsar/consumer_partition.go:291 +0x1812
goroutine 5063 [chan receive, 17 minutes]:
github.com/apache/pulsar-client-go/pulsar.(*partitionConsumer).runEventsLoop(0xc0001e5180)
/pulsar-client-go/pulsar/consumer_partition.go:1078 +0x245
created by github.com/apache/pulsar-client-go/pulsar.newPartitionConsumer
/pulsar-client-go/pulsar/consumer_partition.go:291 +0x1812
goroutine [2390](https://github.com/apache/pulsar-client-go/actions/runs/3304118256/jobs/5604378042#step:5:2391) [select]:
github.com/apache/pulsar-client-go/pulsar/internal.(*connection).run(0xc00046fa20)
/pulsar-client-go/pulsar/internal/connection.go:411 +0x67b
github.com/apache/pulsar-client-go/pulsar/internal.(*connection).start.func1()
/pulsar-client-go/pulsar/internal/connection.go:227 +0xac
created by github.com/apache/pulsar-client-go/pulsar/internal.(*connection).start
/pulsar-client-go/pulsar/internal/connection.go:223 +0xb1
goroutine 2394 [IO wait]:
internal/poll.runtime_pollWait(0x7f9466fb4ff8, 0x72)
/usr/local/go/src/runtime/netpoll.go:305 +0x89
internal/poll.(*pollDesc).wait(0xc000469c98, 0xc00068a000?, 0x0)
/usr/local/go/src/internal/poll/fd_poll_runtime.go:84 +0xbd
internal/poll.(*pollDesc).waitRead(...)
/usr/local/go/src/internal/poll/fd_poll_runtime.go:89
internal/poll.(*FD).Read(0xc000469c80, {0xc00068a000, 0x1000, 0x1000})
/usr/local/go/src/internal/poll/fd_unix.go:167 +0x415
net.(*netFD).Read(0xc000469c80, {0xc00068a000, 0x1000, 0x1000})
/usr/local/go/src/net/fd_posix.go:55 +0x51
net.(*conn).Read(0xc00020cb48, {0xc00068a000, 0x1000, 0x1000})
/usr/local/go/src/net/net.go:183 +0xb1
io.ReadAtLeast({0x12fafa0, 0xc00020cb48}, {0xc00068a000, 0x1000, 0x1000}, 0x4)
/usr/local/go/src/io/io.go:332 +0xde
github.com/apache/pulsar-client-go/pulsar/internal.(*connectionReader).readAtLeast(0xc0000749c0, 0x4)
/pulsar-client-go/pulsar/internal/connection_reader.go:125 +0x215
github.com/apache/pulsar-client-go/pulsar/internal.(*connectionReader).readSingleCommand(0xc0000749c0)
/pulsar-client-go/pulsar/internal/connection_reader.go:71 +0xd4
github.com/apache/pulsar-client-go/pulsar/internal.(*connectionReader).readFromConnection(0xc0000749c0)
/pulsar-client-go/pulsar/internal/connection_reader.go:45 +0x85
created by github.com/apache/pulsar-client-go/pulsar/internal.(*connection).run
/pulsar-client-go/pulsar/internal/connection.go:388 +0x1ba
goroutine [2395](https://github.com/apache/pulsar-client-go/actions/runs/3304118256/jobs/5604378042#step:5:2396) [select]:
github.com/apache/pulsar-client-go/pulsar/internal.(*connection).runPingCheck(0xc00046fa20, 0xc00049be00)
/pulsar-client-go/pulsar/internal/connection.go:431 +0xf0
created by github.com/apache/pulsar-client-go/pulsar/internal.(*connection).run
/pulsar-client-go/pulsar/internal/connection.go:389 +0x28a
goroutine [2396](https://github.com/apache/pulsar-client-go/actions/runs/3304118256/jobs/5604378042#step:5:2397) [select, 19 minutes]:
github.com/apache/pulsar-client-go/pulsar/internal.(*connection).run.func2()
/pulsar-client-go/pulsar/internal/connection.go:396 +0xf7
created by github.com/apache/pulsar-client-go/pulsar/internal.(*connection).run
/pulsar-client-go/pulsar/internal/connection.go:394 +0x4dd
goroutine 2501 [select, 19 minutes]:
github.com/apache/pulsar-client-go/pulsar/internal.(*connection).run.func2()
/pulsar-client-go/pulsar/internal/connection.go:396 +0xf7
created by github.com/apache/pulsar-client-go/pulsar/internal.(*connection).run
/pulsar-client-go/pulsar/internal/connection.go:394 +0x4dd
goroutine 2450 [select]:
github.com/apache/pulsar-client-go/pulsar/internal.(*connection).run(0xc00024fce0)
/pulsar-client-go/pulsar/internal/connection.go:411 +0x67b
github.com/apache/pulsar-client-go/pulsar/internal.(*connection).start.func1()
/pulsar-client-go/pulsar/internal/connection.go:227 +0xac
created by github.com/apache/pulsar-client-go/pulsar/internal.(*connection).start
/pulsar-client-go/pulsar/internal/connection.go:223 +0xb1
goroutine 2497 [select]:
github.com/apache/pulsar-client-go/pulsar/internal.(*connection).run(0xc0000a6f20)
/pulsar-client-go/pulsar/internal/connection.go:411 +0x67b
github.com/apache/pulsar-client-go/pulsar/internal.(*connection).start.func1()
/pulsar-client-go/pulsar/internal/connection.go:227 +0xac
created by github.com/apache/pulsar-client-go/pulsar/internal.(*connection).start
/pulsar-client-go/pulsar/internal/connection.go:223 +0xb1
goroutine 2500 [select]:
github.com/apache/pulsar-client-go/pulsar/internal.(*connection).runPingCheck(0xc0000a6f20, 0xc0006caa00)
/pulsar-client-go/pulsar/internal/connection.go:431 +0xf0
created by github.com/apache/pulsar-client-go/pulsar/internal.(*connection).run
/pulsar-client-go/pulsar/internal/connection.go:389 +0x28a
goroutine 2578 [select, 19 minutes]:
github.com/apache/pulsar-client-go/pulsar/internal.(*connection).run.func2()
/pulsar-client-go/pulsar/internal/connection.go:396 +0xf7
created by github.com/apache/pulsar-client-go/pulsar/internal.(*connection).run
/pulsar-client-go/pulsar/internal/connection.go:394 +0x4dd
goroutine 2576 [IO wait]:
internal/poll.runtime_pollWait(0x7f9466fb4c38, 0x72)
/usr/local/go/src/runtime/netpoll.go:305 +0x89
internal/poll.(*pollDesc).wait(0xc000214518, 0xc0005fd000?, 0x0)
/usr/local/go/src/internal/poll/fd_poll_runtime.go:84 +0xbd
internal/poll.(*pollDesc).waitRead(...)
/usr/local/go/src/internal/poll/fd_poll_runtime.go:89
internal/poll.(*FD).Read(0xc000214500, {0xc0005fd000, 0x1000, 0x1000})
/usr/local/go/src/internal/poll/fd_unix.go:167 +0x415
net.(*netFD).Read(0xc000214500, {0xc0005fd000, 0x1000, 0x1000})
/usr/local/go/src/net/fd_posix.go:55 +0x51
net.(*conn).Read(0xc0000144c8, {0xc0005fd000, 0x1000, 0x1000})
/usr/local/go/src/net/net.go:183 +0xb1
io.ReadAtLeast({0x12fafa0, 0xc0000144c8}, {0xc0005fd000, 0x1000, 0x1000}, 0x4)
/usr/local/go/src/io/io.go:332 +0xde
github.com/apache/pulsar-client-go/pulsar/internal.(*connectionReader).readAtLeast(0xc000496320, 0x4)
/pulsar-client-go/pulsar/internal/connection_reader.go:125 +0x215
github.com/apache/pulsar-client-go/pulsar/internal.(*connectionReader).readSingleCommand(0xc000496320)
/pulsar-client-go/pulsar/internal/connection_reader.go:71 +0xd4
github.com/apache/pulsar-client-go/pulsar/internal.(*connectionReader).readFromConnection(0xc000496320)
/pulsar-client-go/pulsar/internal/connection_reader.go:45 +0x85
created by github.com/apache/pulsar-client-go/pulsar/internal.(*connection).run
/pulsar-client-go/pulsar/internal/connection.go:388 +0x1ba
goroutine 5077 [select, 17 minutes]:
github.com/apache/pulsar-client-go/pulsar.(*partitionProducer).runEventsLoop.func1()
/pulsar-client-go/pulsar/producer_partition.go:437 +0x147
created by github.com/apache/pulsar-client-go/pulsar.(*partitionProducer).runEventsLoop
/pulsar-client-go/pulsar/producer_partition.go:435 +0xbe
goroutine 5037 [chan receive]:
github.com/apache/pulsar-client-go/pulsar.(*partitionProducer).failTimeoutMessages(0xc00087fb00)
/pulsar-client-go/pulsar/producer_partition.go:660 +0x1d8
created by github.com/apache/pulsar-client-go/pulsar.newPartitionProducer
/pulsar-client-go/pulsar/producer_partition.go:190 +0x13e8
goroutine 4945 [select, 17 minutes]:
github.com/apache/pulsar-client-go/pulsar.(*consumer).Receive(0xc00037e3c0, {0x1300b70, 0xc00003c078})
/pulsar-client-go/pulsar/consumer_impl.go:433 +0x18a
github.com/apache/pulsar-client-go/pulsar.TestRLQ(0x0?)
/pulsar-client-go/pulsar/consumer_test.go:1349 +0xd02
testing.tRunner(0xc000946680, 0x1196608)
/usr/local/go/src/testing/testing.go:1446 +0x217
created by testing.(*T).Run
/usr/local/go/src/testing/testing.go:1493 +0x75e
goroutine 5181 [select]:
github.com/apache/pulsar-client-go/pulsar.(*consumer).runBackgroundPartitionDiscovery.func1()
/pulsar-client-go/pulsar/consumer_impl.go:258 +0x1c9
created by github.com/apache/pulsar-client-go/pulsar.(*consumer).runBackgroundPartitionDiscovery
/pulsar-client-go/pulsar/consumer_impl.go:255 +0x1d3
goroutine 4980 [select]:
github.com/apache/pulsar-client-go/pulsar.(*partitionProducer).runEventsLoop(0xc00087f900)
/pulsar-client-go/pulsar/producer_partition.go:449 +0x1c9
created by github.com/apache/pulsar-client-go/pulsar.newPartitionProducer
/pulsar-client-go/pulsar/producer_partition.go:193 +0x1474
goroutine 5052 [select]:
github.com/apache/pulsar-client-go/pulsar.(*producer).runBackgroundPartitionDiscovery.func1()
/pulsar-client-go/pulsar/producer_impl.go:168 +0x1c9
created by github.com/apache/pulsar-client-go/pulsar.(*producer).runBackgroundPartitionDiscovery
/pulsar-client-go/pulsar/producer_impl.go:165 +0x1d3
goroutine 5032 [select]:
github.com/apache/pulsar-client-go/pulsar/internal.(*connection).runPingCheck(0xc000746160, 0xc0009b34f0)
/pulsar-client-go/pulsar/internal/connection.go:431 +0xf0
created by github.com/apache/pulsar-client-go/pulsar/internal.(*connection).run
/pulsar-client-go/pulsar/internal/connection.go:389 +0x28a
goroutine 5071 [select, 17 minutes]:
github.com/apache/pulsar-client-go/pulsar.(*partitionConsumer).dispatcher(0xc000556e00)
/pulsar-client-go/pulsar/consumer_partition.go:933 +0x725
created by github.com/apache/pulsar-client-go/pulsar.newPartitionConsumer
/pulsar-client-go/pulsar/consumer_partition.go:289 +0x1792
goroutine 5064 [select, 17 minutes]:
github.com/apache/pulsar-client-go/pulsar.(*partitionConsumer).runEventsLoop.func2()
/pulsar-client-go/pulsar/consumer_partition.go:1066 +0x148
created by github.com/apache/pulsar-client-go/pulsar.(*partitionConsumer).runEventsLoop
/pulsar-client-go/pulsar/consumer_partition.go:1064 +0x1be
goroutine 4984 [select]:
github.com/apache/pulsar-client-go/pulsar.(*producer).runBackgroundPartitionDiscovery.func1()
/pulsar-client-go/pulsar/producer_impl.go:168 +0x1c9
created by github.com/apache/pulsar-client-go/pulsar.(*producer).runBackgroundPartitionDiscovery
/pulsar-client-go/pulsar/producer_impl.go:165 +0x1d3
goroutine 5073 [select, 17 minutes]:
github.com/apache/pulsar-client-go/pulsar.(*partitionConsumer).runEventsLoop.func2()
/pulsar-client-go/pulsar/consumer_partition.go:1066 +0x148
created by github.com/apache/pulsar-client-go/pulsar.(*partitionConsumer).runEventsLoop
/pulsar-client-go/pulsar/consumer_partition.go:1064 +0x1be
goroutine 4987 [select, 17 minutes]:
github.com/apache/pulsar-client-go/pulsar.(*retryRouter).run(0xc000a1e2d0)
/pulsar-client-go/pulsar/retry_router.go:84 +0x16d
created by github.com/apache/pulsar-client-go/pulsar.newRetryRouter
/pulsar-client-go/pulsar/retry_router.go:73 +0x490
goroutine 5031 [IO wait]:
internal/poll.runtime_pollWait(0x7f9466fb4b48, 0x72)
/usr/local/go/src/runtime/netpoll.go:305 +0x89
internal/poll.(*pollDesc).wait(0xc0008fb418, 0xc0004ff000?, 0x0)
/usr/local/go/src/internal/poll/fd_poll_runtime.go:84 +0xbd
internal/poll.(*pollDesc).waitRead(...)
/usr/local/go/src/internal/poll/fd_poll_runtime.go:89
internal/poll.(*FD).Read(0xc0008fb400, {0xc0004ff000, 0x1000, 0x1000})
/usr/local/go/src/internal/poll/fd_unix.go:167 +0x415
net.(*netFD).Read(0xc0008fb400, {0xc0004ff000, 0x1000, 0x1000})
/usr/local/go/src/net/fd_posix.go:55 +0x51
net.(*conn).Read(0xc00020c420, {0xc0004ff000, 0x1000, 0x1000})
/usr/local/go/src/net/net.go:183 +0xb1
io.ReadAtLeast({0x12fafa0, 0xc00020c420}, {0xc0004ff000, 0x1000, 0x1000}, 0x4)
/usr/local/go/src/io/io.go:332 +0xde
github.com/apache/pulsar-client-go/pulsar/internal.(*connectionReader).readAtLeast(0xc00088fac0, 0x4)
/pulsar-client-go/pulsar/internal/connection_reader.go:125 +0x215
github.com/apache/pulsar-client-go/pulsar/internal.(*connectionReader).readSingleCommand(0xc00088fac0)
/pulsar-client-go/pulsar/internal/connection_reader.go:71 +0xd4
github.com/apache/pulsar-client-go/pulsar/internal.(*connectionReader).readFromConnection(0xc00088fac0)
/pulsar-client-go/pulsar/internal/connection_reader.go:45 +0x85
created by github.com/apache/pulsar-client-go/pulsar/internal.(*connection).run
/pulsar-client-go/pulsar/internal/connection.go:388 +0x1ba
goroutine 5078 [select]:
github.com/apache/pulsar-client-go/pulsar.(*producer).runBackgroundPartitionDiscovery.func1()
/pulsar-client-go/pulsar/producer_impl.go:168 +0x1c9
created by github.com/apache/pulsar-client-go/pulsar.(*producer).runBackgroundPartitionDiscovery
/pulsar-client-go/pulsar/producer_impl.go:165 +0x1d3
goroutine 4985 [select, 17 minutes]:
github.com/apache/pulsar-client-go/pulsar.(*partitionProducer).runEventsLoop.func1()
/pulsar-client-go/pulsar/producer_partition.go:437 +0x147
created by github.com/apache/pulsar-client-go/pulsar.(*partitionProducer).runEventsLoop
/pulsar-client-go/pulsar/producer_partition.go:435 +0xbe
goroutine 5074 [select]:
github.com/apache/pulsar-client-go/pulsar.(*consumer).runBackgroundPartitionDiscovery.func1()
/pulsar-client-go/pulsar/consumer_impl.go:258 +0x1c9
created by github.com/apache/pulsar-client-go/pulsar.(*consumer).runBackgroundPartitionDiscovery
/pulsar-client-go/pulsar/consumer_impl.go:255 +0x1d3
goroutine 5049 [chan receive]:
github.com/apache/pulsar-client-go/pulsar.(*partitionProducer).failTimeoutMessages(0xc000120800)
/pulsar-client-go/pulsar/producer_partition.go:660 +0x1d8
created by github.com/apache/pulsar-client-go/pulsar.newPartitionProducer
/pulsar-client-go/pulsar/producer_partition.go:190 +0x13e8
goroutine 5051 [select, 17 minutes]:
github.com/apache/pulsar-client-go/pulsar.(*partitionProducer).runEventsLoop.func1()
/pulsar-client-go/pulsar/producer_partition.go:437 +0x147
created by github.com/apache/pulsar-client-go/pulsar.(*partitionProducer).runEventsLoop
/pulsar-client-go/pulsar/producer_partition.go:435 +0xbe
goroutine 5072 [chan receive, 17 minutes]:
github.com/apache/pulsar-client-go/pulsar.(*partitionConsumer).runEventsLoop(0xc000556e00)
/pulsar-client-go/pulsar/consumer_partition.go:1078 +0x245
created by github.com/apache/pulsar-client-go/pulsar.newPartitionConsumer
/pulsar-client-go/pulsar/consumer_partition.go:291 +0x1812
goroutine 5045 [select, 17 minutes]:
github.com/apache/pulsar-client-go/pulsar.(*partitionConsumer).dispatcher(0xc000556c40)
/pulsar-client-go/pulsar/consumer_partition.go:933 +0x725
created by github.com/apache/pulsar-client-go/pulsar.newPartitionConsumer
/pulsar-client-go/pulsar/consumer_partition.go:289 +0x1792
goroutine 5068 [select, 17 minutes]:
github.com/apache/pulsar-client-go/pulsar.(*partitionConsumer).runEventsLoop.func2()
/pulsar-client-go/pulsar/consumer_partition.go:1066 +0x148
created by github.com/apache/pulsar-client-go/pulsar.(*partitionConsumer).runEventsLoop
/pulsar-client-go/pulsar/consumer_partition.go:1064 +0x1be
goroutine 5186 [chan send, 17 minutes]:
github.com/apache/pulsar-client-go/pulsar.(*partitionConsumer).dispatcher(0xc000556000)
/pulsar-client-go/pulsar/consumer_partition.go:969 +0xd5e
created by github.com/apache/pulsar-client-go/pulsar.newPartitionConsumer
/pulsar-client-go/pulsar/consumer_partition.go:289 +0x1792
goroutine 5040 [select]:
github.com/apache/pulsar-client-go/pulsar.(*negativeAcksTracker).track(0xc000206e70)
/pulsar-client-go/pulsar/negative_acks_tracker.go:118 +0x13c
created by github.com/apache/pulsar-client-go/pulsar.newNegativeAcksTracker
/pulsar-client-go/pulsar/negative_acks_tracker.go:64 +0x3e5
goroutine 5047 [select, 17 minutes]:
github.com/apache/pulsar-client-go/pulsar.(*partitionConsumer).runEventsLoop.func2()
/pulsar-client-go/pulsar/consumer_partition.go:1066 +0x148
created by github.com/apache/pulsar-client-go/pulsar.(*partitionConsumer).runEventsLoop
/pulsar-client-go/pulsar/consumer_partition.go:1064 +0x1be
goroutine 5152 [select]:
github.com/apache/pulsar-client-go/pulsar.(*negativeAcksTracker).track(0xc0006d61c0)
/pulsar-client-go/pulsar/negative_acks_tracker.go:118 +0x13c
created by github.com/apache/pulsar-client-go/pulsar.newNegativeAcksTracker
/pulsar-client-go/pulsar/negative_acks_tracker.go:64 +0x3e5
goroutine 5060 [select]:
github.com/apache/pulsar-client-go/pulsar.(*negativeAcksTracker).track(0xc000207030)
/pulsar-client-go/pulsar/negative_acks_tracker.go:118 +0x13c
created by github.com/apache/pulsar-client-go/pulsar.newNegativeAcksTracker
/pulsar-client-go/pulsar/negative_acks_tracker.go:64 +0x3e5
goroutine 5062 [select, 17 minutes]:
github.com/apache/pulsar-client-go/pulsar.(*partitionConsumer).dispatcher(0xc0001e5180)
/pulsar-client-go/pulsar/consumer_partition.go:933 +0x725
created by github.com/apache/pulsar-client-go/pulsar.newPartitionConsumer
/pulsar-client-go/pulsar/consumer_partition.go:289 +0x1792
goroutine 5066 [select, 17 minutes]:
github.com/apache/pulsar-client-go/pulsar.(*partitionConsumer).dispatcher(0xc000556a80)
/pulsar-client-go/pulsar/consumer_partition.go:933 +0x725
created by github.com/apache/pulsar-client-go/pulsar.newPartitionConsumer
/pulsar-client-go/pulsar/consumer_partition.go:289 +0x1792
goroutine 5050 [select]:
github.com/apache/pulsar-client-go/pulsar.(*partitionProducer).runEventsLoop(0xc000120800)
/pulsar-client-go/pulsar/producer_partition.go:449 +0x1c9
created by github.com/apache/pulsar-client-go/pulsar.newPartitionProducer
/pulsar-client-go/pulsar/producer_partition.go:193 +0x1474
goroutine 5033 [select]:
github.com/apache/pulsar-client-go/pulsar/internal.(*connection).run.func2()
/pulsar-client-go/pulsar/internal/connection.go:396 +0xf7
created by github.com/apache/pulsar-client-go/pulsar/internal.(*connection).run
/pulsar-client-go/pulsar/internal/connection.go:394 +0x4dd
goroutine 5041 [select]:
github.com/apache/pulsar-client-go/pulsar.(*negativeAcksTracker).track(0xc000206f50)
/pulsar-client-go/pulsar/negative_acks_tracker.go:118 +0x13c
created by github.com/apache/pulsar-client-go/pulsar.newNegativeAcksTracker
/pulsar-client-go/pulsar/negative_acks_tracker.go:64 +0x3e5
goroutine 5075 [chan receive]:
github.com/apache/pulsar-client-go/pulsar.(*partitionProducer).failTimeoutMessages(0xc00087fc00)
/pulsar-client-go/pulsar/producer_partition.go:660 +0x1d8
created by github.com/apache/pulsar-client-go/pulsar.newPartitionProducer
/pulsar-client-go/pulsar/producer_partition.go:190 +0x13e8
goroutine 5187 [chan receive, 17 minutes]:
github.com/apache/pulsar-client-go/pulsar.(*partitionConsumer).runEventsLoop(0xc000556000)
/pulsar-client-go/pulsar/consumer_partition.go:1078 +0x245
created by github.com/apache/pulsar-client-go/pulsar.newPartitionConsumer
/pulsar-client-go/pulsar/consumer_partition.go:291 +0x1812
goroutine 5027 [select]:
github.com/apache/pulsar-client-go/pulsar/internal.(*connection).run(0xc000746160)
/pulsar-client-go/pulsar/internal/connection.go:411 +0x67b
github.com/apache/pulsar-client-go/pulsar/internal.(*connection).start.func1()
/pulsar-client-go/pulsar/internal/connection.go:227 +0xac
created by github.com/apache/pulsar-client-go/pulsar/internal.(*connection).start
/pulsar-client-go/pulsar/internal/connection.go:223 +0xb1
goroutine 4979 [chan receive]:
github.com/apache/pulsar-client-go/pulsar.(*partitionProducer).failTimeoutMessages(0xc00087f900)
/pulsar-client-go/pulsar/producer_partition.go:660 +0x1d8
created by github.com/apache/pulsar-client-go/pulsar.newPartitionProducer
/pulsar-client-go/pulsar/producer_partition.go:190 +0x13e8
goroutine 4981 [select, 17 minutes]:
github.com/apache/pulsar-client-go/pulsar.(*partitionProducer).runEventsLoop.func1()
/pulsar-client-go/pulsar/producer_partition.go:437 +0x147
created by github.com/apache/pulsar-client-go/pulsar.(*partitionProducer).runEventsLoop
/pulsar-client-go/pulsar/producer_partition.go:435 +0xbe
goroutine 5043 [select]:
github.com/apache/pulsar-client-go/pulsar.(*negativeAcksTracker).track(0xc00017d2d0)
/pulsar-client-go/pulsar/negative_acks_tracker.go:118 +0x13c
created by github.com/apache/pulsar-client-go/pulsar.newNegativeAcksTracker
/pulsar-client-go/pulsar/negative_acks_tracker.go:64 +0x3e5
goroutine 4986 [select, 17 minutes]:
github.com/apache/pulsar-client-go/pulsar.(*dlqRouter).run(0xc000a1e280)
/pulsar-client-go/pulsar/dlq_router.go:89 +0x16e
created by github.com/apache/pulsar-client-go/pulsar.newDlqRouter
/pulsar-client-go/pulsar/dlq_router.go:56 +0x457
goroutine 5038 [select]:
github.com/apache/pulsar-client-go/pulsar.(*partitionProducer).runEventsLoop(0xc00087fb00)
/pulsar-client-go/pulsar/producer_partition.go:449 +0x1c9
created by github.com/apache/pulsar-client-go/pulsar.newPartitionProducer
/pulsar-client-go/pulsar/producer_partition.go:193 +0x1474
goroutine 4982 [chan receive]:
github.com/apache/pulsar-client-go/pulsar.(*partitionProducer).failTimeoutMessages(0xc00087fa00)
/pulsar-client-go/pulsar/producer_partition.go:660 +0x1d8
created by github.com/apache/pulsar-client-go/pulsar.newPartitionProducer
/pulsar-client-go/pulsar/producer_partition.go:190 +0x13e8
goroutine 5039 [select, 17 minutes]:
github.com/apache/pulsar-client-go/pulsar.(*partitionProducer).runEventsLoop.func1()
/pulsar-client-go/pulsar/producer_partition.go:437 +0x147
created by github.com/apache/pulsar-client-go/pulsar.(*partitionProducer).runEventsLoop
/pulsar-client-go/pulsar/producer_partition.go:435 +0xbe
goroutine 5069 [select]:
github.com/apache/pulsar-client-go/pulsar.(*consumer).runBackgroundPartitionDiscovery.func1()
/pulsar-client-go/pulsar/consumer_impl.go:258 +0x1c9
created by github.com/apache/pulsar-client-go/pulsar.(*consumer).runBackgroundPartitionDiscovery
/pulsar-client-go/pulsar/consumer_impl.go:255 +0x1d3
goroutine 5067 [chan receive, 17 minutes]:
github.com/apache/pulsar-client-go/pulsar.(*partitionConsumer).runEventsLoop(0xc000556a80)
/pulsar-client-go/pulsar/consumer_partition.go:1078 +0x245
created by github.com/apache/pulsar-client-go/pulsar.newPartitionConsumer
/pulsar-client-go/pulsar/consumer_partition.go:291 +0x1812
goroutine 5076 [select]:
github.com/apache/pulsar-client-go/pulsar.(*partitionProducer).runEventsLoop(0xc00087fc00)
/pulsar-client-go/pulsar/producer_partition.go:449 +0x1c9
created by github.com/apache/pulsar-client-go/pulsar.newPartitionProducer
/pulsar-client-go/pulsar/producer_partition.go:193 +0x1474
goroutine 5046 [chan receive, 17 minutes]:
github.com/apache/pulsar-client-go/pulsar.(*partitionConsumer).runEventsLoop(0xc000556c40)
/pulsar-client-go/pulsar/consumer_partition.go:1078 +0x245
created by github.com/apache/pulsar-client-go/pulsar.newPartitionConsumer
/pulsar-client-go/pulsar/consumer_partition.go:291 +0x1812
goroutine 4983 [select]:
github.com/apache/pulsar-client-go/pulsar.(*partitionProducer).runEventsLoop(0xc00087fa00)
/pulsar-client-go/pulsar/producer_partition.go:449 +0x1c9
created by github.com/apache/pulsar-client-go/pulsar.newPartitionProducer
/pulsar-client-go/pulsar/producer_partition.go:193 +0x1474
goroutine 5180 [select, 17 minutes]:
github.com/apache/pulsar-client-go/pulsar.(*partitionConsumer).runEventsLoop.func2()
/pulsar-client-go/pulsar/consumer_partition.go:1066 +0x148
created by github.com/apache/pulsar-client-go/pulsar.(*partitionConsumer).runEventsLoop
/pulsar-client-go/pulsar/consumer_partition.go:1064 +0x1be
FAIL github.com/apache/pulsar-client-go/pulsar 1200.061s
```
--
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: commits-unsubscribe@pulsar.apache.org.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [pulsar-client-go] Gleiphir2769 commented on issue #882: [BUG] goroutine blocked
Posted by GitBox <gi...@apache.org>.
Gleiphir2769 commented on issue #882:
URL: https://github.com/apache/pulsar-client-go/issues/882#issuecomment-1302863404
@nodece Hi, this problem may have been fixed in #875 . You can rebase to master and try to run CI again.
--
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: commits-unsubscribe@pulsar.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [pulsar-client-go] nodece closed issue #882: [BUG] goroutine blocked
Posted by GitBox <gi...@apache.org>.
nodece closed issue #882: [BUG] goroutine blocked
URL: https://github.com/apache/pulsar-client-go/issues/882
--
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: commits-unsubscribe@pulsar.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [pulsar-client-go] nodece commented on issue #882: [BUG] goroutine blocked
Posted by GitBox <gi...@apache.org>.
nodece commented on issue #882:
URL: https://github.com/apache/pulsar-client-go/issues/882#issuecomment-1302892412
Closed by #875.
--
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: commits-unsubscribe@pulsar.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org