Build failed in Jenkins: beam_LoadTests_Go_GBK_Flink_Batch #1022

[Apache Jenkins Server]

See 
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/1022/display/redirect>

Changes:


------------------------------------------
[...truncated 67.31 KB...]
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/test/load/util.go>:87
 +0x33
github.com/apache/beam/sdks/v2/go/pkg/beam/register.registerDoFn3x0StructWrappersAndFuncs[...].func2.1({0xc000a24830,
 0x9, 0x9}, 0x46e3b2)
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/pkg/beam/register/register.go>:2469
 +0x92
github.com/apache/beam/sdks/v2/go/pkg/beam/register.(*caller3x0[...]).Call3x0(0xc00048fe40?,
 {0x13a8240?, 0xc000a21c68?}, {0x13a8240?, 0xc000a21c80?}, {0x13f8ae0?, 
0xc000557518?})
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/pkg/beam/register/register.go>:2458
 +0x70
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*invoker).initCall.func4({0x0,
 0x0, 0x0, 0x0, 0x0}, {0x2c78560?, 0x1?, 0x1?}, 0xffdf3b645a1cac09?)
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/fn_arity.go>:55
 +0x6f
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*invoker).invokeWithOpts(0xc000108a00,
 {0x1a8cb90?, 0xc000274fc0}, {0x0, 0x0, 0x0, 0x0, 0x0}, {0x2c78560, 0x1, ...}, 
...)
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/fn.go>:297
 +0xf90
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*ParDo).invokeProcessFn(0xc000482240,
 {0x1a8cb90, 0xc000274fc0}, {0x0, 0x0, 0x0, 0x0, 0x0}, {0x2c78560, 0x1, ...}, 
...)
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/pardo.go>:508
 +0x29f
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*ParDo).processSingleWindow(0xc000482240,
 0xc000a26ea0)
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/pardo.go>:194
 +0x8f
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*ParDo).processMainInput(0x42b0e0?,
 0x1a8cb90?)
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/pardo.go>:172
 +0x7f
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*ParDo).ProcessElement(0xc000482240,
 {0x18?, 0xc000074800?}, 0xc0002e8d48, {0x0, 0x0, 0x0})
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/pardo.go>:156
 +0x129
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*PCollection).ProcessElement(0xc000a24830?,
 {0x1a8cb90?, 0xc000274f80?}, 0x424b45?, {0x0?, 0x200?, 0x80?})
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/pcollection.go>:100
 +0x151
github.com/apache/beam/sdks/v2/go/pkg/beam/register.(*emit2[...]).invoke(0x1a8e2c0,
 {0xc000a24828, 0xc0004906d0?, 0x1a764e0?}, {0xc000a24830?, 0x9, 0x9})
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/pkg/beam/register/emitter.go>:80
 +0x1fa
github.com/apache/beam/sdks/v2/go/pkg/beam/io/synthetic.(*sourceFn).ProcessElement(0xc0004ad450,
 0x0?, {0xbebc200, 0x1, 0x1, 0x9, 0x0, 0x0}, 0xc000011938)
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/pkg/beam/io/synthetic/source.go>:151
 +0x116
github.com/apache/beam/sdks/v2/go/pkg/beam/register.registerDoFn3x1StructWrappersAndFuncs[...].func2.1({0xbebc200?,
 0x1, 0x1, 0x9, 0x0, 0x0}, 0xc0001cbb80)
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/pkg/beam/register/register.go>:3382
 +0xaa
github.com/apache/beam/sdks/v2/go/pkg/beam/register.(*caller3x1[...]).Call3x1(0x10000?,
 {0x16dfa00?, 0xc000011908?}, {0x173d2a0?, 0xc000302d20?}, {0x13f8ae0?, 
0xc000011938?})
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/pkg/beam/register/register.go>:3371
 +0xaf
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*invoker).initCall.func13({0x0,
 0x0, 0x0, 0x0, 0x0}, {0x2c78560, 0x1, 0x1}, 0x0?)
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/fn_arity.go>:109
 +0xa9
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*invoker).invokeWithOpts(0xc000108b40,
 {0x1a8cb90?, 0xc000274f80}, {0x0, 0x0, 0x0, 0x0, 0x0}, {0x2c78560, 0x1, ...}, 
...)
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/fn.go>:297
 +0xf90
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*ParDo).invokeProcessFn(0xc000482480,
 {0x1a8cb90, 0xc000274f80}, {0x0, 0x0, 0x0, 0x0, 0x0}, {0x2c78560, 0x1, ...}, 
...)
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/pardo.go>:508
 +0x29f
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*ParDo).processSingleWindow(0xc000482480,
 0xc000420ea0)
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/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(0xc000502f00,
 {0x1a8cb90, 0xc000524440}, 0xc000195a40, {0x0, 0x0, 0x0})
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/sdf.go>:556
 +0x62f
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*DataSource).Process.func1(0xc000557530,
 {0xc000491328?, 0xc000501800?})
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/datasource.go>:240
 +0x223
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*DataSource).process(0xc00057c840,
 {0x1a8cb90, 0xc000524440}, 0xc000491618, 0xc0004915f8)
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/datasource.go>:146
 +0x4d3
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*DataSource).Process(0xc00057c840,
 {0x1a8cb90, 0xc000524440})
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/datasource.go>:214
 +0x20a
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*Plan).Execute.func2({0x1a8cb90?,
 0xc000524440?})
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/plan.go>:151
 +0x3b
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.callNoPanic({0x1a8cb90?,
 0xc000524440?}, 0x418488?)
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/util.go>:62
 +0x62
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*Plan).Execute(0xc000528000,
 {0x1a8cb90, 0xc000524440}, {0x2c1adb8, 0x1}, {{0x1a8b940?, 0xc000274e40?}, 
{0x1ac5378?, 0xc000146fc0?}})
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/plan.go>:150
 +0x3b8
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/harness.(*control).handleInstruction(0xc0003b2000,
 {0x1a8c780?, 0xc0002e6b10?}, 0xc0005314f0)
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/pkg/beam/core/runtime/harness/harness.go>:409
 +0x9f8
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/harness.MainWithOptions.func4({0x1a8c780?,
 0xc0002e6b10?}, 0x0?)
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/pkg/beam/core/runtime/harness/harness.go>:195
 +0x74
created by 
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/harness.MainWithOptions 
in goroutine 1
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/pkg/beam/core/runtime/harness/harness.go>:213
 +0xede
2023/09/21 08:08:40 
Job[load0tests0go0flink0batch0gbk0100921065408-root-0921080622-85ccf175_c99d924e-60d9-46fb-8e07-24a3303aef56]
 state: FAILED
2023/09/21 08:08:40 Failed to execute job: job 
load0tests0go0flink0batch0gbk0100921065408-root-0921080622-85ccf175_c99d924e-60d9-46fb-8e07-24a3303aef56
 failed:
java.lang.RuntimeException: Error received from SDK harness for instruction 3: 
process bundle failed for instruction 3 using plan 1-3 : panic: datamgr.go [{3 
fn/write/n4:0}]: error flushing buffer of length 4000000
        caused by:
rpc error: code = Unknown desc = 
Full error:
while executing Process for Plan[1-3]:
1: DataSource[S[fn/read/n2/SplitAndSize0:0@localhost:41719], local_output] 
Out:6 
Coder:W;fn/wire/n2/SplitAndSize0:0<KV;c5/SplitAndSize0<KV;c5/PairWithRestriction0<R;c5[synthetic.SourceConfig],KV;c9<offsetrange.Restriction[offsetrange.Restriction;c6];c7,bool;c8>>,double;DoubleCoder0>>!GWC
 
6: SDF.ProcessSizedElementsAndRestrictions[synthetic.sourceFn] UID:6 Out:[5]
5: PCollection[n3] Out:[4]
4: ParDo[load.RuntimeMonitor] Out:[2] Sig: func([]uint8, []uint8, func([]uint8, 
[]uint8)), SideInputs: []
3: PCollection[n4] Out:[2]
2: DataSink[S[fn/write/n4:0@localhost:41719]] 
Coder:W;fn/wire/n4:0<KV;c1<bytes;c0,bytes;c0>>!GWC
        caused by:
panic: datamgr.go [{3 fn/write/n4:0}]: error flushing buffer of length 4000000
        caused by:
rpc error: code = Unknown desc =  goroutine 14 [running]:
runtime/debug.Stack()
        /home/jenkins/sdk/go1.21.1/src/runtime/debug/stack.go:24 +0x5e
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.callNoPanic.func1()
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/util.go>:58
 +0x94
panic({0x15db7c0?, 0xc000275300?})
        /home/jenkins/sdk/go1.21.1/src/runtime/panic.go:914 +0x21f
github.com/apache/beam/sdks/v2/go/pkg/beam/register.(*emit2[...]).invoke(0x1a8e2c0,
 {0xc000a24828, 0x40d39a?, 0x0?}, {0xc000a24830?, 0x9, 0x9})
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/pkg/beam/register/emitter.go>:81
 +0x213
github.com/apache/beam/sdks/v2/go/test/load.(*RuntimeMonitor).ProcessElement(0x2ccd4c0?,
 {0xc000a24828?, 0x1?, 0x1?}, {0xc000a24830?, 0x9?, 0x9?}, 0xc000557518?)
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/test/load/util.go>:87
 +0x33
github.com/apache/beam/sdks/v2/go/pkg/beam/register.registerDoFn3x0StructWrappersAndFuncs[...].func2.1({0xc000a24830,
 0x9, 0x9}, 0x46e3b2)
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/pkg/beam/register/register.go>:2469
 +0x92
github.com/apache/beam/sdks/v2/go/pkg/beam/register.(*caller3x0[...]).Call3x0(0xc00048fe40?,
 {0x13a8240?, 0xc000a21c68?}, {0x13a8240?, 0xc000a21c80?}, {0x13f8ae0?, 
0xc000557518?})
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/pkg/beam/register/register.go>:2458
 +0x70
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*invoker).initCall.func4({0x0,
 0x0, 0x0, 0x0, 0x0}, {0x2c78560?, 0x1?, 0x1?}, 0xffdf3b645a1cac09?)
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/fn_arity.go>:55
 +0x6f
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*invoker).invokeWithOpts(0xc000108a00,
 {0x1a8cb90?, 0xc000274fc0}, {0x0, 0x0, 0x0, 0x0, 0x0}, {0x2c78560, 0x1, ...}, 
...)
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/fn.go>:297
 +0xf90
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*ParDo).invokeProcessFn(0xc000482240,
 {0x1a8cb90, 0xc000274fc0}, {0x0, 0x0, 0x0, 0x0, 0x0}, {0x2c78560, 0x1, ...}, 
...)
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/pardo.go>:508
 +0x29f
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*ParDo).processSingleWindow(0xc000482240,
 0xc000a26ea0)
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/pardo.go>:194
 +0x8f
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*ParDo).processMainInput(0x42b0e0?,
 0x1a8cb90?)
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/pardo.go>:172
 +0x7f
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*ParDo).ProcessElement(0xc000482240,
 {0x18?, 0xc000074800?}, 0xc0002e8d48, {0x0, 0x0, 0x0})
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/pardo.go>:156
 +0x129
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*PCollection).ProcessElement(0xc000a24830?,
 {0x1a8cb90?, 0xc000274f80?}, 0x424b45?, {0x0?, 0x200?, 0x80?})
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/pcollection.go>:100
 +0x151
github.com/apache/beam/sdks/v2/go/pkg/beam/register.(*emit2[...]).invoke(0x1a8e2c0,
 {0xc000a24828, 0xc0004906d0?, 0x1a764e0?}, {0xc000a24830?, 0x9, 0x9})
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/pkg/beam/register/emitter.go>:80
 +0x1fa
github.com/apache/beam/sdks/v2/go/pkg/beam/io/synthetic.(*sourceFn).ProcessElement(0xc0004ad450,
 0x0?, {0xbebc200, 0x1, 0x1, 0x9, 0x0, 0x0}, 0xc000011938)
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/pkg/beam/io/synthetic/source.go>:151
 +0x116
github.com/apache/beam/sdks/v2/go/pkg/beam/register.registerDoFn3x1StructWrappersAndFuncs[...].func2.1({0xbebc200?,
 0x1, 0x1, 0x9, 0x0, 0x0}, 0xc0001cbb80)
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/pkg/beam/register/register.go>:3382
 +0xaa
github.com/apache/beam/sdks/v2/go/pkg/beam/register.(*caller3x1[...]).Call3x1(0x10000?,
 {0x16dfa00?, 0xc000011908?}, {0x173d2a0?, 0xc000302d20?}, {0x13f8ae0?, 
0xc000011938?})
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/pkg/beam/register/register.go>:3371
 +0xaf
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*invoker).initCall.func13({0x0,
 0x0, 0x0, 0x0, 0x0}, {0x2c78560, 0x1, 0x1}, 0x0?)
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/fn_arity.go>:109
 +0xa9
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*invoker).invokeWithOpts(0xc000108b40,
 {0x1a8cb90?, 0xc000274f80}, {0x0, 0x0, 0x0, 0x0, 0x0}, {0x2c78560, 0x1, ...}, 
...)
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/fn.go>:297
 +0xf90
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*ParDo).invokeProcessFn(0xc000482480,
 {0x1a8cb90, 0xc000274f80}, {0x0, 0x0, 0x0, 0x0, 0x0}, {0x2c78560, 0x1, ...}, 
...)
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/pardo.go>:508
 +0x29f
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*ParDo).processSingleWindow(0xc000482480,
 0xc000420ea0)
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/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(0xc000502f00,
 {0x1a8cb90, 0xc000524440}, 0xc000195a40, {0x0, 0x0, 0x0})
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/sdf.go>:556
 +0x62f
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*DataSource).Process.func1(0xc000557530,
 {0xc000491328?, 0xc000501800?})
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/datasource.go>:240
 +0x223
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*DataSource).process(0xc00057c840,
 {0x1a8cb90, 0xc000524440}, 0xc000491618, 0xc0004915f8)
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/datasource.go>:146
 +0x4d3
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*DataSource).Process(0xc00057c840,
 {0x1a8cb90, 0xc000524440})
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/datasource.go>:214
 +0x20a
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*Plan).Execute.func2({0x1a8cb90?,
 0xc000524440?})
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/plan.go>:151
 +0x3b
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.callNoPanic({0x1a8cb90?,
 0xc000524440?}, 0x418488?)
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/util.go>:62
 +0x62
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*Plan).Execute(0xc000528000,
 {0x1a8cb90, 0xc000524440}, {0x2c1adb8, 0x1}, {{0x1a8b940?, 0xc000274e40?}, 
{0x1ac5378?, 0xc000146fc0?}})
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/plan.go>:150
 +0x3b8
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/harness.(*control).handleInstruction(0xc0003b2000,
 {0x1a8c780?, 0xc0002e6b10?}, 0xc0005314f0)
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/pkg/beam/core/runtime/harness/harness.go>:409
 +0x9f8
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/harness.MainWithOptions.func4({0x1a8c780?,
 0xc0002e6b10?}, 0x0?)
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/pkg/beam/core/runtime/harness/harness.go>:195
 +0x74
created by 
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/harness.MainWithOptions 
in goroutine 1
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/pkg/beam/core/runtime/harness/harness.go>:213
 +0xede
panic: Failed to execute job: job 
load0tests0go0flink0batch0gbk0100921065408-root-0921080622-85ccf175_c99d924e-60d9-46fb-8e07-24a3303aef56
 failed:
java.lang.RuntimeException: Error received from SDK harness for instruction 3: 
process bundle failed for instruction 3 using plan 1-3 : panic: datamgr.go [{3 
fn/write/n4:0}]: error flushing buffer of length 4000000
        caused by:
rpc error: code = Unknown desc = 
Full error:
while executing Process for Plan[1-3]:
1: DataSource[S[fn/read/n2/SplitAndSize0:0@localhost:41719], local_output] 
Out:6 
Coder:W;fn/wire/n2/SplitAndSize0:0<KV;c5/SplitAndSize0<KV;c5/PairWithRestriction0<R;c5[synthetic.SourceConfig],KV;c9<offsetrange.Restriction[offsetrange.Restriction;c6];c7,bool;c8>>,double;DoubleCoder0>>!GWC
 
6: SDF.ProcessSizedElementsAndRestrictions[synthetic.sourceFn] UID:6 Out:[5]
5: PCollection[n3] Out:[4]
4: ParDo[load.RuntimeMonitor] Out:[2] Sig: func([]uint8, []uint8, func([]uint8, 
[]uint8)), SideInputs: []
3: PCollection[n4] Out:[2]
2: DataSink[S[fn/write/n4:0@localhost:41719]] 
Coder:W;fn/wire/n4:0<KV;c1<bytes;c0,bytes;c0>>!GWC
        caused by:
panic: datamgr.go [{3 fn/write/n4:0}]: error flushing buffer of length 4000000
        caused by:
rpc error: code = Unknown desc =  goroutine 14 [running]:
runtime/debug.Stack()
        /home/jenkins/sdk/go1.21.1/src/runtime/debug/stack.go:24 +0x5e
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.callNoPanic.func1()
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/util.go>:58
 +0x94
panic({0x15db7c0?, 0xc000275300?})
        /home/jenkins/sdk/go1.21.1/src/runtime/panic.go:914 +0x21f
github.com/apache/beam/sdks/v2/go/pkg/beam/register.(*emit2[...]).invoke(0x1a8e2c0,
 {0xc000a24828, 0x40d39a?, 0x0?}, {0xc000a24830?, 0x9, 0x9})
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/pkg/beam/register/emitter.go>:81
 +0x213
github.com/apache/beam/sdks/v2/go/test/load.(*RuntimeMonitor).ProcessElement(0x2ccd4c0?,
 {0xc000a24828?, 0x1?, 0x1?}, {0xc000a24830?, 0x9?, 0x9?}, 0xc000557518?)
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/test/load/util.go>:87
 +0x33
github.com/apache/beam/sdks/v2/go/pkg/beam/register.registerDoFn3x0StructWrappersAndFuncs[...].func2.1({0xc000a24830,
 0x9, 0x9}, 0x46e3b2)
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/pkg/beam/register/register.go>:2469
 +0x92
github.com/apache/beam/sdks/v2/go/pkg/beam/register.(*caller3x0[...]).Call3x0(0xc00048fe40?,
 {0x13a8240?, 0xc000a21c68?}, {0x13a8240?, 0xc000a21c80?}, {0x13f8ae0?, 
0xc000557518?})
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/pkg/beam/register/register.go>:2458
 +0x70
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*invoker).initCall.func4({0x0,
 0x0, 0x0, 0x0, 0x0}, {0x2c78560?, 0x1?, 0x1?}, 0xffdf3b645a1cac09?)
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/fn_arity.go>:55
 +0x6f
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*invoker).invokeWithOpts(0xc000108a00,
 {0x1a8cb90?, 0xc000274fc0}, {0x0, 0x0, 0x0, 0x0, 0x0}, {0x2c78560, 0x1, ...}, 
...)
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/fn.go>:297
 +0xf90
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*ParDo).invokeProcessFn(0xc000482240,
 {0x1a8cb90, 0xc000274fc0}, {0x0, 0x0, 0x0, 0x0, 0x0}, {0x2c78560, 0x1, ...}, 
...)
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/pardo.go>:508
 +0x29f
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*ParDo).processSingleWindow(0xc000482240,
 0xc000a26ea0)
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/pardo.go>:194
 +0x8f
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*ParDo).processMainInput(0x42b0e0?,
 0x1a8cb90?)
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/pardo.go>:172
 +0x7f
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*ParDo).ProcessElement(0xc000482240,
 {0x18?, 0xc000074800?}, 0xc0002e8d48, {0x0, 0x0, 0x0})
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/pardo.go>:156
 +0x129
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*PCollection).ProcessElement(0xc000a24830?,
 {0x1a8cb90?, 0xc000274f80?}, 0x424b45?, {0x0?, 0x200?, 0x80?})
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/pcollection.go>:100
 +0x151
github.com/apache/beam/sdks/v2/go/pkg/beam/register.(*emit2[...]).invoke(0x1a8e2c0,
 {0xc000a24828, 0xc0004906d0?, 0x1a764e0?}, {0xc000a24830?, 0x9, 0x9})
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/pkg/beam/register/emitter.go>:80
 +0x1fa
github.com/apache/beam/sdks/v2/go/pkg/beam/io/synthetic.(*sourceFn).ProcessElement(0xc0004ad450,
 0x0?, {0xbebc200, 0x1, 0x1, 0x9, 0x0, 0x0}, 0xc000011938)
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/pkg/beam/io/synthetic/source.go>:151
 +0x116
github.com/apache/beam/sdks/v2/go/pkg/beam/register.registerDoFn3x1StructWrappersAndFuncs[...].func2.1({0xbebc200?,
 0x1, 0x1, 0x9, 0x0, 0x0}, 0xc0001cbb80)
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/pkg/beam/register/register.go>:3382
 +0xaa
github.com/apache/beam/sdks/v2/go/pkg/beam/register.(*caller3x1[...]).Call3x1(0x10000?,
 {0x16dfa00?, 0xc000011908?}, {0x173d2a0?, 0xc000302d20?}, {0x13f8ae0?, 
0xc000011938?})
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/pkg/beam/register/register.go>:3371
 +0xaf
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*invoker).initCall.func13({0x0,
 0x0, 0x0, 0x0, 0x0}, {0x2c78560, 0x1, 0x1}, 0x0?)
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/fn_arity.go>:109
 +0xa9
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*invoker).invokeWithOpts(0xc000108b40,
 {0x1a8cb90?, 0xc000274f80}, {0x0, 0x0, 0x0, 0x0, 0x0}, {0x2c78560, 0x1, ...}, 
...)
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/fn.go>:297
 +0xf90
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*ParDo).invokeProcessFn(0xc000482480,
 {0x1a8cb90, 0xc000274f80}, {0x0, 0x0, 0x0, 0x0, 0x0}, {0x2c78560, 0x1, ...}, 
...)
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/pardo.go>:508
 +0x29f
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*ParDo).processSingleWindow(0xc000482480,
 0xc000420ea0)
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/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(0xc000502f00,
 {0x1a8cb90, 0xc000524440}, 0xc000195a40, {0x0, 0x0, 0x0})
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/sdf.go>:556
 +0x62f
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*DataSource).Process.func1(0xc000557530,
 {0xc000491328?, 0xc000501800?})
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/datasource.go>:240
 +0x223
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*DataSource).process(0xc00057c840,
 {0x1a8cb90, 0xc000524440}, 0xc000491618, 0xc0004915f8)
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/datasource.go>:146
 +0x4d3
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*DataSource).Process(0xc00057c840,
 {0x1a8cb90, 0xc000524440})
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/datasource.go>:214
 +0x20a
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*Plan).Execute.func2({0x1a8cb90?,
 0xc000524440?})
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/plan.go>:151
 +0x3b
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.callNoPanic({0x1a8cb90?,
 0xc000524440?}, 0x418488?)
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/util.go>:62
 +0x62
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*Plan).Execute(0xc000528000,
 {0x1a8cb90, 0xc000524440}, {0x2c1adb8, 0x1}, {{0x1a8b940?, 0xc000274e40?}, 
{0x1ac5378?, 0xc000146fc0?}})
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/plan.go>:150
 +0x3b8
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/harness.(*control).handleInstruction(0xc0003b2000,
 {0x1a8c780?, 0xc0002e6b10?}, 0xc0005314f0)
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/pkg/beam/core/runtime/harness/harness.go>:409
 +0x9f8
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/harness.MainWithOptions.func4({0x1a8c780?,
 0xc0002e6b10?}, 0x0?)
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/pkg/beam/core/runtime/harness/harness.go>:195
 +0x74
created by 
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/harness.MainWithOptions 
in goroutine 1
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/pkg/beam/core/runtime/harness/harness.go>:213
 +0xede


goroutine 1 [running]:
github.com/apache/beam/sdks/v2/go/pkg/beam/log.Fatalf({0x1a8c748, 0x2ccd4c0}, 
{0x18f485d?, 0x2ccd4c0?}, {0xc00063fe30?, 0x0?, 0x0?})
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/pkg/beam/log/log.go>:162
 +0x7d
main.main()
        
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/test/load/group_by_key/group_by_key.go>:98
 +0x3d3

> Task :sdks:go:test:load:run FAILED

FAILURE: Build failed with an exception.

* Where:
Build file 
'<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/sdks/go/test/load/build.gradle'>
 line: 31

* What went wrong:
Execution failed for task ':sdks:go:test:load:run'.
> Process 'command 'sh'' finished with non-zero exit value 2

* Try:
> Run with --stacktrace option to get the stack trace.
> Run with --info or --debug option to get more log output.

* Get more help at https://help.gradle.org

BUILD FAILED in 3m 8s
12 actionable tasks: 6 executed, 4 from cache, 2 up-to-date

Publishing build scan...
https://ge.apache.org/s/hwxhud2nueapq

Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure

---------------------------------------------------------------------
To unsubscribe, e-mail: builds-unsubscr...@beam.apache.org
For additional commands, e-mail: builds-h...@beam.apache.org