shunping opened a new issue, #36224: URL: https://github.com/apache/beam/issues/36224
### What happened? https://github.com/apache/beam/actions/runs/17885391589/job/50858382037?pr=36219 Looks like a deadlock. ``` 2025/09/20 22:14:50 Unsuccessful split: failed to split DataSource (at index: 0, last index: 0) at fraction 0.0000 with requested splits (2 indices from 0 to 3) 2025/09/20 22:14:50 Unsuccessful split: failed to split DataSource (at index: 0, last index: 9223372036854775807) at fraction 0.0000 with requested splits (1 indices from 0 to 0) 2025/09/20 22:14:50 Unsuccessful split: failed to split DataSource (at index: 5, last index: 9223372036854775807) at fraction 0.0000 with requested splits (1 indices from 0 to 0) 2025/09/20 22:14:50 Unsuccessful split: failed to split DataSource (at index: 5, last index: 0) at fraction 0.0000 with requested splits (1 indices from 0 to 0) panic: test timed out after 10m0s running tests: TestDynamicSplit (9m57s) TestDynamicSplit/BlockOnSplit (9m57s) goroutine 225 [running]: testing.(*M).startAlarm.func1() /home/runner/sdk/go1.24.4/src/testing/testing.go:2484 +0x394 created by time.goFunc /home/runner/sdk/go1.24.4/src/time/sleep.go:215 +0x2d goroutine 1 [chan receive, 9 minutes]: testing.(*T).Run(0xc000003a40, {0xc5deac?, 0xc0001cdb30?}, 0xc95f48) /home/runner/sdk/go1.24.4/src/testing/testing.go:1859 +0x431 testing.runTests.func1(0xc000003a40) /home/runner/sdk/go1.24.4/src/testing/testing.go:2279 +0x37 testing.tRunner(0xc000003a40, 0xc0001cdc70) /home/runner/sdk/go1.24.4/src/testing/testing.go:1792 +0xf4 testing.runTests(0xc00000ebb8, {0x12b3820, 0x44, 0x44}, {0x12bef40?, 0x7?, 0x12bdb20?}) /home/runner/sdk/go1.24.4/src/testing/testing.go:2277 +0x4b4 testing.(*M).Run(0xc0001e80a0) /home/runner/sdk/go1.24.4/src/testing/testing.go:2142 +0x64a main.main() _testmain.go:213 +0x9b goroutine 214 [chan receive, 9 minutes]: testing.(*T).Run(0xc00053ae00, {0xc5b179?, 0xdbc993?}, 0xc000540c20) /home/runner/sdk/go1.24.4/src/testing/testing.go:1859 +0x431 github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.TestDynamicSplit(0xc00053ae00) /runner/_work/beam/beam/sdks/go/pkg/beam/core/runtime/exec/dynsplit_test.go:67 +0xc7 testing.tRunner(0xc00053ae00, 0xc95f48) /home/runner/sdk/go1.24.4/src/testing/testing.go:1792 +0xf4 created by testing.(*T).Run in goroutine 1 /home/runner/sdk/go1.24.4/src/testing/testing.go:1851 +0x413 goroutine 219 [chan receive, 9 minutes]: github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.splitBlockingDriver({0xd638c8, 0x12ded20}, 0xc00054c990, {{0xd622c8?, 0xc000546f50?}, {0x0?, 0x0?}}, 0xc000546c40) /runner/_work/beam/beam/sdks/go/pkg/beam/core/runtime/exec/dynsplit_test.go:181 +0x218 github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.TestDynamicSplit.func1(0xc00053b180) /runner/_work/beam/beam/sdks/go/pkg/beam/core/runtime/exec/dynsplit_test.go:84 +0x46f testing.tRunner(0xc00053b180, 0xc000540c20) /home/runner/sdk/go1.24.4/src/testing/testing.go:1792 +0xf4 created by testing.(*T).Run in goroutine 214 /home/runner/sdk/go1.24.4/src/testing/testing.go:1851 +0x413 goroutine 222 [chan send, 9 minutes]: github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*splitTestRTracker).TrySplit(0xc00051d9c0, 0x3fe0000000000000) /runner/_work/beam/beam/sdks/go/pkg/beam/core/runtime/exec/dynsplit_test.go:401 +0x8c github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*ProcessSizedElementsAndRestrictions).singleWindowSplit(0xc000564640, {0xd638c8, 0x12ded20}, 0x3fe0000000000000, {0xaf8240, 0xd784c0}, {0xaf8240, 0xd784c0}) /runner/_work/beam/beam/sdks/go/pkg/beam/core/runtime/exec/sdf.go:733 +0x90 github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*ProcessSizedElementsAndRestrictions).Split(0xc000564640, {0xd638c8, 0x12ded20}, 0x3fe0000000000000) /runner/_work/beam/beam/sdks/go/pkg/beam/core/runtime/exec/sdf.go:695 +0x315 github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*DataSource).Split(0xc0000e7980, {0xd638c8, 0x12ded20}, {0x0?, 0x0, 0x0}, 0x3fe0000000000000?, 0x1) /runner/_work/beam/beam/sdks/go/pkg/beam/core/runtime/exec/datasource.go:609 +0x432 github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*Plan).Split(0xc00054cb40?, {0xd638c8?, 0x12ded20?}, {{0x0, 0x0, 0x0}, 0x3fe0000000000000, 0x1}) /runner/_work/beam/beam/sdks/go/pkg/beam/core/runtime/exec/plan.go:307 +0x148 github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.splitPlan(...) /runner/_work/beam/beam/sdks/go/pkg/beam/core/runtime/exec/dynsplit_test.go:337 created by github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.splitBlockingDriver in goroutine 219 /runner/_work/beam/beam/sdks/go/pkg/beam/core/runtime/exec/dynsplit_test.go:177 +0x1f6 goroutine 221 [sync.Mutex.Lock, 9 minutes]: internal/sync.runtime_SemacquireMutex(0x0?, 0x0?, 0x0?) /home/runner/sdk/go1.24.4/src/runtime/sema.go:95 +0x25 internal/sync.(*Mutex).lockSlow(0xc00051d9c0) /home/runner/sdk/go1.24.4/src/internal/sync/mutex.go:149 +0x15d internal/sync.(*Mutex).Lock(...) /home/runner/sdk/go1.24.4/src/internal/sync/mutex.go:70 sync.(*Mutex).Lock(...) /home/runner/sdk/go1.24.4/src/sync/mutex.go:46 github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*splitTestRTracker).GetRestriction(0x4?) /runner/_work/beam/beam/sdks/go/pkg/beam/core/runtime/exec/dynsplit_test.go:422 +0x47 github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*splitTestSdf).ProcessElement(0xc000546c40, 0xc00051d9c0, 0x48b07d?, 0xc0005535f0) /runner/_work/beam/beam/sdks/go/pkg/beam/core/runtime/exec/dynsplit_test.go:443 +0x29 reflect.Value.call({0xb29880?, 0xc00051d680?, 0x20?}, {0xc545f7, 0x4}, {0xc00052cf50, 0x3, 0x6020eb?}) /home/runner/sdk/go1.24.4/src/reflect/value.go:584 +0xca6 reflect.Value.Call({0xb29880?, 0xc00051d680?, 0xc53120?}, {0xc00052cf50?, 0xc00052bbc0?, 0xc000410f88?}) /home/runner/sdk/go1.24.4/src/reflect/value.go:368 +0xb9 github.com/apache/beam/sdks/v2/go/pkg/beam/core/util/reflectx.(*reflectFunc).Call(0xc00053edc8, {0xc000553560?, 0xc0004114d0?, 0x4fc41c?}) /runner/_work/beam/beam/sdks/go/pkg/beam/core/util/reflectx/call.go:87 +0x53 github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*invoker).initCall.func46({0x0, 0x0, 0x0, 0x0, 0x0}, {0x129ca70, 0x1, 0x1}, 0x0) /runner/_work/beam/beam/sdks/go/pkg/beam/core/runtime/exec/fn_arity.go:307 +0x87 github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*invoker).invokeWithOpts(0xc0002d57c0, {0xd63af8, 0xc00051d940}, {0x0, 0x0, 0x0, 0x0, 0x0}, {0x129ca70, 0x1, ...}, ...) /runner/_work/beam/beam/sdks/go/pkg/beam/core/runtime/exec/fn.go:297 +0xf29 github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*ParDo).invokeProcessFn(0xc000503d40, {0xd63af8, 0xc00051d940}, {0x0, 0x0, 0x0, 0x0, 0x0}, {0x129ca70, 0x1, ...}, ...) /runner/_work/beam/beam/sdks/go/pkg/beam/core/runtime/exec/pardo.go:508 +0x2bf github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*ParDo).processSingleWindow(0xc000503d40, 0xc00054cc60) /runner/_work/beam/beam/sdks/go/pkg/beam/core/runtime/exec/pardo.go:194 +0x8f github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*ProcessSizedElementsAndRestrictions).ProcessElement(0xc000564640, {0xd638c8, 0x12ded20}, 0xc00055f0a0, {0x0, 0x0, 0x0}) /runner/_work/beam/beam/sdks/go/pkg/beam/core/runtime/exec/sdf.go:556 +0x605 github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*DataSource).Process.func1(0xc00053ef18, {0xc5b155, 0xc}) /runner/_work/beam/beam/sdks/go/pkg/beam/core/runtime/exec/datasource.go:244 +0x264 github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*DataSource).process(0xc0000e7980, {0xd638c8, 0x12ded20}, 0xc0001c1c98, 0xc0001c1c78) /runner/_work/beam/beam/sdks/go/pkg/beam/core/runtime/exec/datasource.go:143 +0x463 github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*DataSource).Process(0xc0000e7980, {0xd638c8, 0x12ded20}) /runner/_work/beam/beam/sdks/go/pkg/beam/core/runtime/exec/datasource.go:214 +0x2c5 github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*Plan).Execute.func2({0xd638c8?, 0x12ded20?}) /runner/_work/beam/beam/sdks/go/pkg/beam/core/runtime/exec/plan.go:151 +0x38 github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.callNoPanic({0xd638c8?, 0x12ded20?}, 0xc000035808?) /runner/_work/beam/beam/sdks/go/pkg/beam/core/runtime/exec/util.go:62 +0x5b github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*Plan).Execute(0xc00054c990, {0xd638c8, 0x12ded20}, {0xc000524c90, 0x2a}, {{0xd622c8?, 0xc000546f50?}, {0x0?, 0x0?}}) /runner/_work/beam/beam/sdks/go/pkg/beam/core/runtime/exec/plan.go:150 +0x36a github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.processPlan(0xc00054c990, {{0xd622c8?, 0xc000546f50?}, {0x0?, 0x0?}}, 0xc00054ea10) /runner/_work/beam/beam/sdks/go/pkg/beam/core/runtime/exec/dynsplit_test.go:320 +0xb9 created by github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.splitBlockingDriver in goroutine 219 /runner/_work/beam/beam/sdks/go/pkg/beam/core/runtime/exec/dynsplit_test.go:172 +0x134 goroutine 160 [chan receive, 9 minutes]: github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.TestDataSource_Split.func3.1.2() /runner/_work/beam/beam/sdks/go/pkg/beam/core/runtime/exec/datasource_test.go:389 +0x54 created by github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.TestDataSource_Split.func3.1 in goroutine 142 /runner/_work/beam/beam/sdks/go/pkg/beam/core/runtime/exec/datasource_test.go:387 +0x275 FAIL github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec 600.112s ``` ### Issue Failure Failure: Test is flaky ### Issue Priority Priority: 1 (unhealthy code / failing or flaky postcommit so we cannot be sure the product is healthy) ### Issue Components - [ ] Component: Python SDK - [ ] Component: Java SDK - [ ] Component: Go SDK - [ ] Component: Typescript SDK - [ ] Component: IO connector - [ ] Component: Beam YAML - [ ] Component: Beam examples - [ ] Component: Beam playground - [ ] Component: Beam katas - [ ] Component: Website - [ ] Component: Infrastructure - [ ] Component: Spark Runner - [ ] Component: Flink Runner - [ ] Component: Samza Runner - [ ] Component: Twister2 Runner - [ ] Component: Hazelcast Jet Runner - [ ] Component: Google Cloud Dataflow Runner -- 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]
