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] goroutine blocked #882

Closed
nodece opened this issue Nov 2, 2022 · 2 comments
Closed

[BUG] goroutine blocked #882

nodece opened this issue Nov 2, 2022 · 2 comments

Comments

@nodece
Copy link
Member

nodece commented Nov 2, 2022

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
@nodece nodece changed the title Flaky-test: [BUG] goroutine blocked Nov 2, 2022
@Gleiphir2769
Copy link
Contributor

@nodece Hi, this problem may have been fixed in #875 . You can rebase to master and try to run CI again.

@nodece
Copy link
Member Author

nodece commented Nov 4, 2022

Closed by #875.

@nodece nodece closed this as completed Nov 4, 2022
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Assignees
No one assigned
Labels
None yet
Projects
None yet
Milestone
No milestone
Development

No branches or pull requests
2 participants
@nodece @Gleiphir2769