See
<https://ci-beam.apache.org/job/beam_LoadTests_Go_CoGBK_Flink_batch/959/display/redirect?page=changes>
Changes:
[noreply] Upgrade com.google.cloud.bigdataoss:gcsio dependency to latest
(#27679)
------------------------------------------
[...truncated 76.37 KB...]
<https://ci-beam.apache.org/job/beam_LoadTests_Go_CoGBK_Flink_batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/fn.go>:297
+0xfec
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*ParDo).invokeProcessFn(0xc0000287e0,
{0x1a5bb10, 0xc0002f38c0}, {0x0, 0x0, 0x0, 0x0, 0x0}, {0x2613070, 0x1, ...},
...)
<https://ci-beam.apache.org/job/beam_LoadTests_Go_CoGBK_Flink_batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/pardo.go>:508
+0x2b5
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*ParDo).processSingleWindow(0xc0000287e0,
0xc0000ce1b0)
<https://ci-beam.apache.org/job/beam_LoadTests_Go_CoGBK_Flink_batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/pardo.go>:194
+0x9b
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*ParDo).processMainInput(0x155?,
0x1a5bb10?)
<https://ci-beam.apache.org/job/beam_LoadTests_Go_CoGBK_Flink_batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/pardo.go>:172
+0x91
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*ParDo).ProcessElement(0xc0000287e0,
{0x18?, 0x2636ea0?}, 0xc000363638, {0x0, 0x0, 0x0})
<https://ci-beam.apache.org/job/beam_LoadTests_Go_CoGBK_Flink_batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/pardo.go>:156
+0x125
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*PCollection).ProcessElement(0xc000349a40?,
{0x1a5bb10?, 0xc0002f3880?}, 0x4214e7?, {0x0?, 0x55?, 0x40?})
<https://ci-beam.apache.org/job/beam_LoadTests_Go_CoGBK_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(0x1a5d220,
{0xc002210500, 0xc0002106e0?, 0x1a47308?}, {0xc000349a40?, 0x5a, 0x5a})
<https://ci-beam.apache.org/job/beam_LoadTests_Go_CoGBK_Flink_batch/ws/src/sdks/go/pkg/beam/register/emitter.go>:80
+0x20f
github.com/apache/beam/sdks/v2/go/pkg/beam/io/synthetic.(*sourceFn).ProcessElement(0xc0004c03b0,
0x7f81459c85b8?, {0x1312d00, 0x1, 0xa, 0x5a, 0x5, 0x3ff0000000000000},
0xc000385380)
<https://ci-beam.apache.org/job/beam_LoadTests_Go_CoGBK_Flink_batch/ws/src/sdks/go/pkg/beam/io/synthetic/source.go>:151
+0x123
github.com/apache/beam/sdks/v2/go/pkg/beam/register.registerDoFn3x1StructWrappersAndFuncs[...].func2.1({0x1312d00?,
0x1, 0xa, 0x5a, 0x5, 0x3ff0000000000000}, 0x0)
<https://ci-beam.apache.org/job/beam_LoadTests_Go_CoGBK_Flink_batch/ws/src/sdks/go/pkg/beam/register/register.go>:3382
+0xb0
github.com/apache/beam/sdks/v2/go/pkg/beam/register.(*caller3x1[...]).Call3x1(0x0?,
{0x16b3180?, 0xc000385350?}, {0x1716440?, 0xc0000af980?}, {0x13f6c40?,
0xc000385380?})
<https://ci-beam.apache.org/job/beam_LoadTests_Go_CoGBK_Flink_batch/ws/src/sdks/go/pkg/beam/register/register.go>:3371
+0xb6
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*invoker).initCall.func13({0x0,
0x0, 0x0, 0x0, 0x0}, {0x2613070, 0x1, 0x1}, 0x7f81459c85b8?)
<https://ci-beam.apache.org/job/beam_LoadTests_Go_CoGBK_Flink_batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/fn_arity.go>:109
+0xad
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*invoker).invokeWithOpts(0xc00059e3c0,
{0x1a5bb10?, 0xc0002f3880}, {0x0, 0x0, 0x0, 0x0, 0x0}, {0x2613070, 0x1, ...},
...)
<https://ci-beam.apache.org/job/beam_LoadTests_Go_CoGBK_Flink_batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/fn.go>:297
+0xfec
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*ParDo).invokeProcessFn(0xc000028a20,
{0x1a5bb10, 0xc0002f3880}, {0x0, 0x0, 0x0, 0x0, 0x0}, {0x2613070, 0x1, ...},
...)
<https://ci-beam.apache.org/job/beam_LoadTests_Go_CoGBK_Flink_batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/pardo.go>:508
+0x2b5
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*ParDo).processSingleWindow(0xc000028a20,
0xc00039a900)
<https://ci-beam.apache.org/job/beam_LoadTests_Go_CoGBK_Flink_batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/pardo.go>:194
+0x9b
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*ProcessSizedElementsAndRestrictions).ProcessElement(0xc00037d040,
{0x1a5bb10, 0xc000218740}, 0xc0002faaf0, {0x0, 0x0, 0x0})
<https://ci-beam.apache.org/job/beam_LoadTests_Go_CoGBK_Flink_batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/sdf.go>:556
+0x63d
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*DataSource).Process.func1(0xc000384738,
{0xc000371338?, 0xc0004a9a20?})
<https://ci-beam.apache.org/job/beam_LoadTests_Go_CoGBK_Flink_batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/datasource.go>:241
+0x21e
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*DataSource).process(0xc00013e420,
{0x1a5bb10, 0xc000218740}, 0xc000211628, 0xc000211608)
<https://ci-beam.apache.org/job/beam_LoadTests_Go_CoGBK_Flink_batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/datasource.go>:147
+0x4f6
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*DataSource).Process(0xc00013e420,
{0x1a5bb10, 0xc000218740})
<https://ci-beam.apache.org/job/beam_LoadTests_Go_CoGBK_Flink_batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/datasource.go>:215
+0x226
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*Plan).Execute.func2({0x1a5bb10?,
0xc000218740?})
<https://ci-beam.apache.org/job/beam_LoadTests_Go_CoGBK_Flink_batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/plan.go>:151
+0x42
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.callNoPanic({0x1a5bb10?,
0xc000218740?}, 0x415d70?)
<https://ci-beam.apache.org/job/beam_LoadTests_Go_CoGBK_Flink_batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/util.go>:62
+0x6c
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*Plan).Execute(0xc0003795f0,
{0x1a5bb10, 0xc000218740}, {0x25ba028, 0x1}, {{0x1a4af70?, 0xc0002f37c0?},
{0x1a90218?, 0xc000388270?}})
<https://ci-beam.apache.org/job/beam_LoadTests_Go_CoGBK_Flink_batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/plan.go>:150
+0x3df
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/harness.(*control).handleInstruction(0xc000190000,
{0x1a5b9f8?, 0xc0005e0cf0?}, 0xc000002730)
<https://ci-beam.apache.org/job/beam_LoadTests_Go_CoGBK_Flink_batch/ws/src/sdks/go/pkg/beam/core/runtime/harness/harness.go>:409
+0xa37
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/harness.MainWithOptions.func4({0x1a5b9f8?,
0xc0005e0cf0?}, 0x0?)
<https://ci-beam.apache.org/job/beam_LoadTests_Go_CoGBK_Flink_batch/ws/src/sdks/go/pkg/beam/core/runtime/harness/harness.go>:195
+0x7a
created by
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/harness.MainWithOptions
<https://ci-beam.apache.org/job/beam_LoadTests_Go_CoGBK_Flink_batch/ws/src/sdks/go/pkg/beam/core/runtime/harness/harness.go>:213
+0xf1d
2023/07/31 22:32:51 Job state: FAILED
2023/07/31 22:32:51 Failed to execute job: job
load0tests0go0flink0batch0cogbk0200731221245-root-0731223040-9d7da70e_69705533-36b8-42a4-ac60-e34bf3720301
failed:
java.lang.RuntimeException: Error received from SDK harness for instruction 9:
process bundle failed for instruction 9 using plan 1-7 : panic: datamgr.go [{9
fn/write/n9_flatten:1:0}]: error flushing buffer of length 3999964
caused by:
rpc error: code = Unknown desc =
Full error:
while executing Process for Plan[1-7]:
2: DataSink[S[fn/write/n9_flatten:1:0@localhost:38603]]
Coder:W;fn/wire/n9_flatten:1:0<KV;c6<bytes;c0,KV;c5<int[varintz;c3];c4,bytes;c0>>>!GWC
3: PCollection[n9_flatten:1] Out:[2]
4: Flatten[1]. Out:DataSink[S[fn/write/n9_flatten:1:0@localhost:38603]]
Coder:W;fn/wire/n9_flatten:1:0<KV;c6<bytes;c0,KV;c5<int[varintz;c3];c4,bytes;c0>>>!GWC
5: PCollection[n4_e9_inject0] Out:[4]
6: Inject[0]. Out:5
7: PCollection[n4] Out:[6]
8: ParDo[load.RuntimeMonitor] Out:[7] Sig: func([]uint8, []uint8, func([]uint8,
[]uint8)), SideInputs: []
9: PCollection[n3] Out:[8]
10: SDF.ProcessSizedElementsAndRestrictions[synthetic.sourceFn] UID:10 Out:[9]
1: DataSource[S[fn/read/n2/SplitAndSize0:0@localhost:38603], local_output]
Out:10
Coder:W;fn/wire/n2/SplitAndSize0:0<KV;c13/SplitAndSize0<KV;c13/PairWithRestriction0<R;c13[synthetic.SourceConfig],KV;c17<offsetrange.Restriction[offsetrange.Restriction;c14];c15,bool;c16>>,double;DoubleCoder0>>!GWC
caused by:
panic: datamgr.go [{9 fn/write/n9_flatten:1:0}]: error flushing buffer of
length 3999964
caused by:
rpc error: code = Unknown desc = goroutine 49 [running]:
runtime/debug.Stack()
/home/jenkins/sdk/go1.20.6/src/runtime/debug/stack.go:24 +0x65
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.callNoPanic.func1()
<https://ci-beam.apache.org/job/beam_LoadTests_Go_CoGBK_Flink_batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/util.go>:58
+0xa5
panic({0x15c4720, 0xc000639100})
/home/jenkins/sdk/go1.20.6/src/runtime/panic.go:884 +0x213
github.com/apache/beam/sdks/v2/go/pkg/beam/register.(*emit2[...]).invoke(0x1a5d220,
{0xc002210500, 0x40a92d?, 0x46c7a1?}, {0xc000349a40?, 0x5a, 0x5a})
<https://ci-beam.apache.org/job/beam_LoadTests_Go_CoGBK_Flink_batch/ws/src/sdks/go/pkg/beam/register/emitter.go>:81
+0x22f
github.com/apache/beam/sdks/v2/go/test/load.(*RuntimeMonitor).ProcessElement(0x0?,
{0xc002210500?, 0x0?, 0xc0000028c0?}, {0xc000349a40?, 0xc0004d7020?,
0xc000664030?}, 0x0?)
<https://ci-beam.apache.org/job/beam_LoadTests_Go_CoGBK_Flink_batch/ws/src/sdks/go/test/load/util.go>:87
+0x39
github.com/apache/beam/sdks/v2/go/pkg/beam/register.registerDoFn3x0StructWrappersAndFuncs[...].func2.1({0xc000349a40,
0x5a, 0x5a}, 0x46f00a)
<https://ci-beam.apache.org/job/beam_LoadTests_Go_CoGBK_Flink_batch/ws/src/sdks/go/pkg/beam/register/register.go>:2469
+0x9c
github.com/apache/beam/sdks/v2/go/pkg/beam/register.(*caller3x0[...]).Call3x0(0x46c883?,
{0x13c48e0?, 0xc0018f4d68?}, {0x13c48e0?, 0xc0018f4d80?}, {0x13f6c40?,
0xc000384720?})
<https://ci-beam.apache.org/job/beam_LoadTests_Go_CoGBK_Flink_batch/ws/src/sdks/go/pkg/beam/register/register.go>:2458
+0x7f
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*invoker).initCall.func4({0x0,
0x0, 0x0, 0x0, 0x0}, {0x2613070?, 0x1?, 0x1?}, 0xffdf3b645a1cac09?)
<https://ci-beam.apache.org/job/beam_LoadTests_Go_CoGBK_Flink_batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/fn_arity.go>:55
+0x75
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*invoker).invokeWithOpts(0xc00059e280,
{0x1a5bb10?, 0xc0002f38c0}, {0x0, 0x0, 0x0, 0x0, 0x0}, {0x2613070, 0x1, ...},
...)
<https://ci-beam.apache.org/job/beam_LoadTests_Go_CoGBK_Flink_batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/fn.go>:297
+0xfec
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*ParDo).invokeProcessFn(0xc0000287e0,
{0x1a5bb10, 0xc0002f38c0}, {0x0, 0x0, 0x0, 0x0, 0x0}, {0x2613070, 0x1, ...},
...)
<https://ci-beam.apache.org/job/beam_LoadTests_Go_CoGBK_Flink_batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/pardo.go>:508
+0x2b5
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*ParDo).processSingleWindow(0xc0000287e0,
0xc0000ce1b0)
<https://ci-beam.apache.org/job/beam_LoadTests_Go_CoGBK_Flink_batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/pardo.go>:194
+0x9b
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*ParDo).processMainInput(0x155?,
0x1a5bb10?)
<https://ci-beam.apache.org/job/beam_LoadTests_Go_CoGBK_Flink_batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/pardo.go>:172
+0x91
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*ParDo).ProcessElement(0xc0000287e0,
{0x18?, 0x2636ea0?}, 0xc000363638, {0x0, 0x0, 0x0})
<https://ci-beam.apache.org/job/beam_LoadTests_Go_CoGBK_Flink_batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/pardo.go>:156
+0x125
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*PCollection).ProcessElement(0xc000349a40?,
{0x1a5bb10?, 0xc0002f3880?}, 0x4214e7?, {0x0?, 0x55?, 0x40?})
<https://ci-beam.apache.org/job/beam_LoadTests_Go_CoGBK_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(0x1a5d220,
{0xc002210500, 0xc0002106e0?, 0x1a47308?}, {0xc000349a40?, 0x5a, 0x5a})
<https://ci-beam.apache.org/job/beam_LoadTests_Go_CoGBK_Flink_batch/ws/src/sdks/go/pkg/beam/register/emitter.go>:80
+0x20f
github.com/apache/beam/sdks/v2/go/pkg/beam/io/synthetic.(*sourceFn).ProcessElement(0xc0004c03b0,
0x7f81459c85b8?, {0x1312d00, 0x1, 0xa, 0x5a, 0x5, 0x3ff0000000000000},
0xc000385380)
<https://ci-beam.apache.org/job/beam_LoadTests_Go_CoGBK_Flink_batch/ws/src/sdks/go/pkg/beam/io/synthetic/source.go>:151
+0x123
github.com/apache/beam/sdks/v2/go/pkg/beam/register.registerDoFn3x1StructWrappersAndFuncs[...].func2.1({0x1312d00?,
0x1, 0xa, 0x5a, 0x5, 0x3ff0000000000000}, 0x0)
<https://ci-beam.apache.org/job/beam_LoadTests_Go_CoGBK_Flink_batch/ws/src/sdks/go/pkg/beam/register/register.go>:3382
+0xb0
github.com/apache/beam/sdks/v2/go/pkg/beam/register.(*caller3x1[...]).Call3x1(0x0?,
{0x16b3180?, 0xc000385350?}, {0x1716440?, 0xc0000af980?}, {0x13f6c40?,
0xc000385380?})
<https://ci-beam.apache.org/job/beam_LoadTests_Go_CoGBK_Flink_batch/ws/src/sdks/go/pkg/beam/register/register.go>:3371
+0xb6
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*invoker).initCall.func13({0x0,
0x0, 0x0, 0x0, 0x0}, {0x2613070, 0x1, 0x1}, 0x7f81459c85b8?)
<https://ci-beam.apache.org/job/beam_LoadTests_Go_CoGBK_Flink_batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/fn_arity.go>:109
+0xad
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*invoker).invokeWithOpts(0xc00059e3c0,
{0x1a5bb10?, 0xc0002f3880}, {0x0, 0x0, 0x0, 0x0, 0x0}, {0x2613070, 0x1, ...},
...)
<https://ci-beam.apache.org/job/beam_LoadTests_Go_CoGBK_Flink_batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/fn.go>:297
+0xfec
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*ParDo).invokeProcessFn(0xc000028a20,
{0x1a5bb10, 0xc0002f3880}, {0x0, 0x0, 0x0, 0x0, 0x0}, {0x2613070, 0x1, ...},
...)
<https://ci-beam.apache.org/job/beam_LoadTests_Go_CoGBK_Flink_batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/pardo.go>:508
+0x2b5
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*ParDo).processSingleWindow(0xc000028a20,
0xc00039a900)
<https://ci-beam.apache.org/job/beam_LoadTests_Go_CoGBK_Flink_batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/pardo.go>:194
+0x9b
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*ProcessSizedElementsAndRestrictions).ProcessElement(0xc00037d040,
{0x1a5bb10, 0xc000218740}, 0xc0002faaf0, {0x0, 0x0, 0x0})
<https://ci-beam.apache.org/job/beam_LoadTests_Go_CoGBK_Flink_batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/sdf.go>:556
+0x63d
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*DataSource).Process.func1(0xc000384738,
{0xc000371338?, 0xc0004a9a20?})
<https://ci-beam.apache.org/job/beam_LoadTests_Go_CoGBK_Flink_batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/datasource.go>:241
+0x21e
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*DataSource).process(0xc00013e420,
{0x1a5bb10, 0xc000218740}, 0xc000211628, 0xc000211608)
<https://ci-beam.apache.org/job/beam_LoadTests_Go_CoGBK_Flink_batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/datasource.go>:147
+0x4f6
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*DataSource).Process(0xc00013e420,
{0x1a5bb10, 0xc000218740})
<https://ci-beam.apache.org/job/beam_LoadTests_Go_CoGBK_Flink_batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/datasource.go>:215
+0x226
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*Plan).Execute.func2({0x1a5bb10?,
0xc000218740?})
<https://ci-beam.apache.org/job/beam_LoadTests_Go_CoGBK_Flink_batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/plan.go>:151
+0x42
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.callNoPanic({0x1a5bb10?,
0xc000218740?}, 0x415d70?)
<https://ci-beam.apache.org/job/beam_LoadTests_Go_CoGBK_Flink_batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/util.go>:62
+0x6c
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*Plan).Execute(0xc0003795f0,
{0x1a5bb10, 0xc000218740}, {0x25ba028, 0x1}, {{0x1a4af70?, 0xc0002f37c0?},
{0x1a90218?, 0xc000388270?}})
<https://ci-beam.apache.org/job/beam_LoadTests_Go_CoGBK_Flink_batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/plan.go>:150
+0x3df
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/harness.(*control).handleInstruction(0xc000190000,
{0x1a5b9f8?, 0xc0005e0cf0?}, 0xc000002730)
<https://ci-beam.apache.org/job/beam_LoadTests_Go_CoGBK_Flink_batch/ws/src/sdks/go/pkg/beam/core/runtime/harness/harness.go>:409
+0xa37
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/harness.MainWithOptions.func4({0x1a5b9f8?,
0xc0005e0cf0?}, 0x0?)
<https://ci-beam.apache.org/job/beam_LoadTests_Go_CoGBK_Flink_batch/ws/src/sdks/go/pkg/beam/core/runtime/harness/harness.go>:195
+0x7a
created by
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/harness.MainWithOptions
<https://ci-beam.apache.org/job/beam_LoadTests_Go_CoGBK_Flink_batch/ws/src/sdks/go/pkg/beam/core/runtime/harness/harness.go>:213
+0xf1d
panic: Failed to execute job: job
load0tests0go0flink0batch0cogbk0200731221245-root-0731223040-9d7da70e_69705533-36b8-42a4-ac60-e34bf3720301
failed:
java.lang.RuntimeException: Error received from SDK harness for instruction 9:
process bundle failed for instruction 9 using plan 1-7 : panic: datamgr.go [{9
fn/write/n9_flatten:1:0}]: error flushing buffer of length 3999964
caused by:
rpc error: code = Unknown desc =
Full error:
while executing Process for Plan[1-7]:
2: DataSink[S[fn/write/n9_flatten:1:0@localhost:38603]]
Coder:W;fn/wire/n9_flatten:1:0<KV;c6<bytes;c0,KV;c5<int[varintz;c3];c4,bytes;c0>>>!GWC
3: PCollection[n9_flatten:1] Out:[2]
4: Flatten[1]. Out:DataSink[S[fn/write/n9_flatten:1:0@localhost:38603]]
Coder:W;fn/wire/n9_flatten:1:0<KV;c6<bytes;c0,KV;c5<int[varintz;c3];c4,bytes;c0>>>!GWC
5: PCollection[n4_e9_inject0] Out:[4]
6: Inject[0]. Out:5
7: PCollection[n4] Out:[6]
8: ParDo[load.RuntimeMonitor] Out:[7] Sig: func([]uint8, []uint8, func([]uint8,
[]uint8)), SideInputs: []
9: PCollection[n3] Out:[8]
10: SDF.ProcessSizedElementsAndRestrictions[synthetic.sourceFn] UID:10 Out:[9]
1: DataSource[S[fn/read/n2/SplitAndSize0:0@localhost:38603], local_output]
Out:10
Coder:W;fn/wire/n2/SplitAndSize0:0<KV;c13/SplitAndSize0<KV;c13/PairWithRestriction0<R;c13[synthetic.SourceConfig],KV;c17<offsetrange.Restriction[offsetrange.Restriction;c14];c15,bool;c16>>,double;DoubleCoder0>>!GWC
caused by:
panic: datamgr.go [{9 fn/write/n9_flatten:1:0}]: error flushing buffer of
length 3999964
caused by:
rpc error: code = Unknown desc = goroutine 49 [running]:
runtime/debug.Stack()
/home/jenkins/sdk/go1.20.6/src/runtime/debug/stack.go:24 +0x65
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.callNoPanic.func1()
<https://ci-beam.apache.org/job/beam_LoadTests_Go_CoGBK_Flink_batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/util.go>:58
+0xa5
panic({0x15c4720, 0xc000639100})
/home/jenkins/sdk/go1.20.6/src/runtime/panic.go:884 +0x213
github.com/apache/beam/sdks/v2/go/pkg/beam/register.(*emit2[...]).invoke(0x1a5d220,
{0xc002210500, 0x40a92d?, 0x46c7a1?}, {0xc000349a40?, 0x5a, 0x5a})
<https://ci-beam.apache.org/job/beam_LoadTests_Go_CoGBK_Flink_batch/ws/src/sdks/go/pkg/beam/register/emitter.go>:81
+0x22f
github.com/apache/beam/sdks/v2/go/test/load.(*RuntimeMonitor).ProcessElement(0x0?,
{0xc002210500?, 0x0?, 0xc0000028c0?}, {0xc000349a40?, 0xc0004d7020?,
0xc000664030?}, 0x0?)
<https://ci-beam.apache.org/job/beam_LoadTests_Go_CoGBK_Flink_batch/ws/src/sdks/go/test/load/util.go>:87
+0x39
github.com/apache/beam/sdks/v2/go/pkg/beam/register.registerDoFn3x0StructWrappersAndFuncs[...].func2.1({0xc000349a40,
0x5a, 0x5a}, 0x46f00a)
<https://ci-beam.apache.org/job/beam_LoadTests_Go_CoGBK_Flink_batch/ws/src/sdks/go/pkg/beam/register/register.go>:2469
+0x9c
github.com/apache/beam/sdks/v2/go/pkg/beam/register.(*caller3x0[...]).Call3x0(0x46c883?,
{0x13c48e0?, 0xc0018f4d68?}, {0x13c48e0?, 0xc0018f4d80?}, {0x13f6c40?,
0xc000384720?})
<https://ci-beam.apache.org/job/beam_LoadTests_Go_CoGBK_Flink_batch/ws/src/sdks/go/pkg/beam/register/register.go>:2458
+0x7f
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*invoker).initCall.func4({0x0,
0x0, 0x0, 0x0, 0x0}, {0x2613070?, 0x1?, 0x1?}, 0xffdf3b645a1cac09?)
<https://ci-beam.apache.org/job/beam_LoadTests_Go_CoGBK_Flink_batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/fn_arity.go>:55
+0x75
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*invoker).invokeWithOpts(0xc00059e280,
{0x1a5bb10?, 0xc0002f38c0}, {0x0, 0x0, 0x0, 0x0, 0x0}, {0x2613070, 0x1, ...},
...)
<https://ci-beam.apache.org/job/beam_LoadTests_Go_CoGBK_Flink_batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/fn.go>:297
+0xfec
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*ParDo).invokeProcessFn(0xc0000287e0,
{0x1a5bb10, 0xc0002f38c0}, {0x0, 0x0, 0x0, 0x0, 0x0}, {0x2613070, 0x1, ...},
...)
<https://ci-beam.apache.org/job/beam_LoadTests_Go_CoGBK_Flink_batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/pardo.go>:508
+0x2b5
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*ParDo).processSingleWindow(0xc0000287e0,
0xc0000ce1b0)
<https://ci-beam.apache.org/job/beam_LoadTests_Go_CoGBK_Flink_batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/pardo.go>:194
+0x9b
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*ParDo).processMainInput(0x155?,
0x1a5bb10?)
<https://ci-beam.apache.org/job/beam_LoadTests_Go_CoGBK_Flink_batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/pardo.go>:172
+0x91
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*ParDo).ProcessElement(0xc0000287e0,
{0x18?, 0x2636ea0?}, 0xc000363638, {0x0, 0x0, 0x0})
<https://ci-beam.apache.org/job/beam_LoadTests_Go_CoGBK_Flink_batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/pardo.go>:156
+0x125
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*PCollection).ProcessElement(0xc000349a40?,
{0x1a5bb10?, 0xc0002f3880?}, 0x4214e7?, {0x0?, 0x55?, 0x40?})
<https://ci-beam.apache.org/job/beam_LoadTests_Go_CoGBK_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(0x1a5d220,
{0xc002210500, 0xc0002106e0?, 0x1a47308?}, {0xc000349a40?, 0x5a, 0x5a})
<https://ci-beam.apache.org/job/beam_LoadTests_Go_CoGBK_Flink_batch/ws/src/sdks/go/pkg/beam/register/emitter.go>:80
+0x20f
github.com/apache/beam/sdks/v2/go/pkg/beam/io/synthetic.(*sourceFn).ProcessElement(0xc0004c03b0,
0x7f81459c85b8?, {0x1312d00, 0x1, 0xa, 0x5a, 0x5, 0x3ff0000000000000},
0xc000385380)
<https://ci-beam.apache.org/job/beam_LoadTests_Go_CoGBK_Flink_batch/ws/src/sdks/go/pkg/beam/io/synthetic/source.go>:151
+0x123
github.com/apache/beam/sdks/v2/go/pkg/beam/register.registerDoFn3x1StructWrappersAndFuncs[...].func2.1({0x1312d00?,
0x1, 0xa, 0x5a, 0x5, 0x3ff0000000000000}, 0x0)
<https://ci-beam.apache.org/job/beam_LoadTests_Go_CoGBK_Flink_batch/ws/src/sdks/go/pkg/beam/register/register.go>:3382
+0xb0
github.com/apache/beam/sdks/v2/go/pkg/beam/register.(*caller3x1[...]).Call3x1(0x0?,
{0x16b3180?, 0xc000385350?}, {0x1716440?, 0xc0000af980?}, {0x13f6c40?,
0xc000385380?})
<https://ci-beam.apache.org/job/beam_LoadTests_Go_CoGBK_Flink_batch/ws/src/sdks/go/pkg/beam/register/register.go>:3371
+0xb6
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*invoker).initCall.func13({0x0,
0x0, 0x0, 0x0, 0x0}, {0x2613070, 0x1, 0x1}, 0x7f81459c85b8?)
<https://ci-beam.apache.org/job/beam_LoadTests_Go_CoGBK_Flink_batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/fn_arity.go>:109
+0xad
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*invoker).invokeWithOpts(0xc00059e3c0,
{0x1a5bb10?, 0xc0002f3880}, {0x0, 0x0, 0x0, 0x0, 0x0}, {0x2613070, 0x1, ...},
...)
<https://ci-beam.apache.org/job/beam_LoadTests_Go_CoGBK_Flink_batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/fn.go>:297
+0xfec
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*ParDo).invokeProcessFn(0xc000028a20,
{0x1a5bb10, 0xc0002f3880}, {0x0, 0x0, 0x0, 0x0, 0x0}, {0x2613070, 0x1, ...},
...)
<https://ci-beam.apache.org/job/beam_LoadTests_Go_CoGBK_Flink_batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/pardo.go>:508
+0x2b5
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*ParDo).processSingleWindow(0xc000028a20,
0xc00039a900)
<https://ci-beam.apache.org/job/beam_LoadTests_Go_CoGBK_Flink_batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/pardo.go>:194
+0x9b
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*ProcessSizedElementsAndRestrictions).ProcessElement(0xc00037d040,
{0x1a5bb10, 0xc000218740}, 0xc0002faaf0, {0x0, 0x0, 0x0})
<https://ci-beam.apache.org/job/beam_LoadTests_Go_CoGBK_Flink_batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/sdf.go>:556
+0x63d
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*DataSource).Process.func1(0xc000384738,
{0xc000371338?, 0xc0004a9a20?})
<https://ci-beam.apache.org/job/beam_LoadTests_Go_CoGBK_Flink_batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/datasource.go>:241
+0x21e
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*DataSource).process(0xc00013e420,
{0x1a5bb10, 0xc000218740}, 0xc000211628, 0xc000211608)
<https://ci-beam.apache.org/job/beam_LoadTests_Go_CoGBK_Flink_batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/datasource.go>:147
+0x4f6
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*DataSource).Process(0xc00013e420,
{0x1a5bb10, 0xc000218740})
<https://ci-beam.apache.org/job/beam_LoadTests_Go_CoGBK_Flink_batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/datasource.go>:215
+0x226
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*Plan).Execute.func2({0x1a5bb10?,
0xc000218740?})
<https://ci-beam.apache.org/job/beam_LoadTests_Go_CoGBK_Flink_batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/plan.go>:151
+0x42
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.callNoPanic({0x1a5bb10?,
0xc000218740?}, 0x415d70?)
<https://ci-beam.apache.org/job/beam_LoadTests_Go_CoGBK_Flink_batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/util.go>:62
+0x6c
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/exec.(*Plan).Execute(0xc0003795f0,
{0x1a5bb10, 0xc000218740}, {0x25ba028, 0x1}, {{0x1a4af70?, 0xc0002f37c0?},
{0x1a90218?, 0xc000388270?}})
<https://ci-beam.apache.org/job/beam_LoadTests_Go_CoGBK_Flink_batch/ws/src/sdks/go/pkg/beam/core/runtime/exec/plan.go>:150
+0x3df
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/harness.(*control).handleInstruction(0xc000190000,
{0x1a5b9f8?, 0xc0005e0cf0?}, 0xc000002730)
<https://ci-beam.apache.org/job/beam_LoadTests_Go_CoGBK_Flink_batch/ws/src/sdks/go/pkg/beam/core/runtime/harness/harness.go>:409
+0xa37
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/harness.MainWithOptions.func4({0x1a5b9f8?,
0xc0005e0cf0?}, 0x0?)
<https://ci-beam.apache.org/job/beam_LoadTests_Go_CoGBK_Flink_batch/ws/src/sdks/go/pkg/beam/core/runtime/harness/harness.go>:195
+0x7a
created by
github.com/apache/beam/sdks/v2/go/pkg/beam/core/runtime/harness.MainWithOptions
<https://ci-beam.apache.org/job/beam_LoadTests_Go_CoGBK_Flink_batch/ws/src/sdks/go/pkg/beam/core/runtime/harness/harness.go>:213
+0xf1d
goroutine 1 [running]:
github.com/apache/beam/sdks/v2/go/pkg/beam/log.Fatalf({0x1a5b988,
0xc000192000}, {0x18cab80?, 0x26659d0?}, {0xc00015be60?, 0x0?, 0x3e8?})
<https://ci-beam.apache.org/job/beam_LoadTests_Go_CoGBK_Flink_batch/ws/src/sdks/go/pkg/beam/log/log.go>:162
+0x8c
main.main()
<https://ci-beam.apache.org/job/beam_LoadTests_Go_CoGBK_Flink_batch/ws/src/sdks/go/test/load/cogbk/cogbk.go>:103
+0x4bb
> 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_CoGBK_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 45s
12 actionable tasks: 6 executed, 4 from cache, 2 up-to-date
Publishing build scan...
https://ge.apache.org/s/xpcszhepfgn3c
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
