shunping commented on issue #33815:
URL: https://github.com/apache/beam/issues/33815#issuecomment-2816467324
Going back to the go pipeline, I see the following related goroutine
stacktrace from debugz
```
1 @ 0x102883ea8 0x102fbf89c 0x102fbf7e9 0x102fba364 0x102fb43c8 0x1028e8d24
# 0x102fbf89b
github.com/apache/beam/sdks/v2/go/pkg/beam/runners/prism/internal/engine.(*stageState).minPendingTimestampLocked+0x1ab
./Projects/beam-dev-go-prism/sdks/go/pkg/beam/runners/prism/internal/engine/elementmanager.go:1928
# 0x102fbf7e8
github.com/apache/beam/sdks/v2/go/pkg/beam/runners/prism/internal/engine.(*stageState).updateWatermarks+0xf8
./Projects/beam-dev-go-prism/sdks/go/pkg/beam/runners/prism/internal/engine/elementmanager.go:1948
# 0x102fba363
github.com/apache/beam/sdks/v2/go/pkg/beam/runners/prism/internal/engine.(*ElementManager).refreshWatermarks+0x133
./Projects/beam-dev-go-prism/sdks/go/pkg/beam/runners/prism/internal/engine/elementmanager.go:1073
# 0x102fb43c7
github.com/apache/beam/sdks/v2/go/pkg/beam/runners/prism/internal/engine.(*ElementManager).Bundles.func2+0x147
./Projects/beam-dev-go-prism/sdks/go/pkg/beam/runners/prism/internal/engine/elementmanager.go:407
1 @ 0x1028e0d08 0x1028c1094 0x10308ed70 0x10308d984 0x1028e8d24
# 0x10308ed6f
github.com/apache/beam/sdks/v2/go/pkg/beam/runners/prism/internal.executePipeline+0xf9f
./Projects/beam-dev-go-prism/sdks/go/pkg/beam/runners/prism/internal/execute.go:341
# 0x10308d983
github.com/apache/beam/sdks/v2/go/pkg/beam/runners/prism/internal.RunPipeline+0x393
./Projects/beam-dev-go-prism/sdks/go/pkg/beam/runners/prism/internal/execute.go:84
1 @ 0x1028e0d08 0x1028c1f04 0x1028c1ee5 0x1028e2288 0x1028f1ed0 0x1028f296c
0x1028f2919 0x102fba09c 0x102fb85fc 0x10309c978 0x103090950 0x103088404
0x1028e8d24
# 0x1028e2287 internal/sync.runtime_SemacquireMutex+0x27
./go/pkg/mod/golang.org/[email protected]/src/runtime/sema.go:95
# 0x1028f1ecf internal/sync.(*Mutex).lockSlow+0x16f
./go/pkg/mod/golang.org/[email protected]/src/internal/sync/mutex.go:149
# 0x1028f296b internal/sync.(*Mutex).Lock+0x6b
./go/pkg/mod/golang.org/[email protected]/src/internal/sync/mutex.go:70
# 0x1028f2918 sync.(*Mutex).Lock+0x18
./go/pkg/mod/golang.org/[email protected]/src/sync/mutex.go:46
# 0x102fba09b
github.com/apache/beam/sdks/v2/go/pkg/beam/runners/prism/internal/engine.(*ElementManager).markChangedAndClearBundle+0x4b
./Projects/beam-dev-go-prism/sdks/go/pkg/beam/runners/prism/internal/engine/elementmanager.go:1048
# 0x102fb85fb
github.com/apache/beam/sdks/v2/go/pkg/beam/runners/prism/internal/engine.(*ElementManager).PersistBundle+0xb2b
./Projects/beam-dev-go-prism/sdks/go/pkg/beam/runners/prism/internal/engine/elementmanager.go:933
# 0x10309c977
github.com/apache/beam/sdks/v2/go/pkg/beam/runners/prism/internal.(*stage).Execute+0x1a87
./Projects/beam-dev-go-prism/sdks/go/pkg/beam/runners/prism/internal/stage.go:333
# 0x10309094f
github.com/apache/beam/sdks/v2/go/pkg/beam/runners/prism/internal.executePipeline.func4+0xbf
./Projects/beam-dev-go-prism/sdks/go/pkg/beam/runners/prism/internal/execute.go:355
# 0x103088403 golang.org/x/sync/errgroup.(*Group).Go.func1+0x53
./go/pkg/mod/golang.org/x/[email protected]/errgroup/errgroup.go:79
1 @ 0x1028e0d08 0x1028c1f04 0x1028c1ee5 0x1028e23ac 0x1028f4460 0x102fb4ea4
0x1028e8d24
# 0x1028e23ab sync.runtime_SemacquireWaitGroup+0x2b
./go/pkg/mod/golang.org/[email protected]/src/runtime/sema.go:110
# 0x1028f445f sync.(*WaitGroup).Wait+0x6f
./go/pkg/mod/golang.org/[email protected]/src/sync/waitgroup.go:118
# 0x102fb4ea3
github.com/apache/beam/sdks/v2/go/pkg/beam/runners/prism/internal/engine.(*ElementManager).Bundles.func1+0x33
./Projects/beam-dev-go-prism/sdks/go/pkg/beam/runners/prism/internal/engine/elementmanager.go:350
```
--
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]
