damccorm commented on PR #24228:
URL: https://github.com/apache/beam/pull/24228#issuecomment-1319995187
(this version worked, though a different test failed for seemingly unrelated
reasons)
```
FAIL: TestKafkaIO_BasicReadWrite (0.01s)
08:02:41 panic: tried cross-language for
beam:transform:org.apache.beam:kafka_write:v1 against localhost:44319 and failed
08:02:41 expanding external transform
08:02:41 expanding transform with ExpansionRequest:
components:{pcollections:{key:"n4" value:{unique_name:"n4"
coder_id:"c1@ErKwBRUxvv" is_bounded:BOUNDED
windowing_strategy_id:"w0@ErKwBRUxvv"}}
windowing_strategies:{key:"w0@ErKwBRUxvv"
value:{window_fn:{urn:"beam:window_fn:global_windows:v1"}
merge_status:NON_MERGING window_coder_id:"c2@ErKwBRUxvv" trigger:{default:{}}
accumulation_mode:DISCARDING output_time:END_OF_WINDOW
closing_behavior:EMIT_IF_NONEMPTY on_time_behavior:FIRE_IF_NONEMPTY
environment_id:"go"}} coders:{key:"c0@ErKwBRUxvv"
value:{spec:{urn:"beam:coder:bytes:v1"}}} coders:{key:"c1@ErKwBRUxvv"
value:{spec:{urn:"beam:coder:kv:v1"} component_coder_ids:"c0@ErKwBRUxvv"
component_coder_ids:"c0@ErKwBRUxvv"}} coders:{key:"c2@ErKwBRUxvv"
value:{spec:{urn:"beam:coder:global_window:v1"}}}}
transform:{unique_name:"External"
spec:{urn:"beam:transform:org.apache.beam:kafka_write:v1"
payload:"\n}\n\x1c\n\x0eProducerConfig\x1a\n*\x08\n\x02\x10\x07\x12\x02
\x10\x07\n\x0b\n\x05Topic\x1a\x02\x10\x07\n\x13\n\rKeySerializer\x1a\x02\x10\x07\n\x15\n\x0fValueSerializer\x1a\x02\x10\x07\x12$d97fbd8d-dde2-46d8-babd-f5372b6ab5e6\x12\xda\x01\x04\x00\x00\x00\x00\x01\x11bootstrap.servers\x0flocalhost:37919=xlang_kafkaio_basic_test_364cd506-46f5-49dc-aeb4-4f84e1ea3e739org.apache.kafka.common.serialization.ByteArraySerializer9org.apache.kafka.common.serialization.ByteArraySerializer"}
inputs:{key:"i0" value:"n4"} environment_id:"go"} namespace:"ErKwBRUxvv"
08:02:41 expansion failed
08:02:41 caused by:
08:02:41 rpc error: code = Unavailable desc = connection error: desc =
"transport: Error while dialing dial tcp 127.0.0.1:44319: connect: connection
refused" [recovered]
08:02:41 panic: tried cross-language for
beam:transform:org.apache.beam:kafka_write:v1 against localhost:44319 and failed
08:02:41 expanding external transform
08:02:41 expanding transform with ExpansionRequest:
components:{pcollections:{key:"n4" value:{unique_name:"n4"
coder_id:"c1@ErKwBRUxvv" is_bounded:BOUNDED
windowing_strategy_id:"w0@ErKwBRUxvv"}}
windowing_strategies:{key:"w0@ErKwBRUxvv"
value:{window_fn:{urn:"beam:window_fn:global_windows:v1"}
merge_status:NON_MERGING window_coder_id:"c2@ErKwBRUxvv" trigger:{default:{}}
accumulation_mode:DISCARDING output_time:END_OF_WINDOW
closing_behavior:EMIT_IF_NONEMPTY on_time_behavior:FIRE_IF_NONEMPTY
environment_id:"go"}} coders:{key:"c0@ErKwBRUxvv"
value:{spec:{urn:"beam:coder:bytes:v1"}}} coders:{key:"c1@ErKwBRUxvv"
value:{spec:{urn:"beam:coder:kv:v1"} component_coder_ids:"c0@ErKwBRUxvv"
component_coder_ids:"c0@ErKwBRUxvv"}} coders:{key:"c2@ErKwBRUxvv"
value:{spec:{urn:"beam:coder:global_window:v1"}}}}
transform:{unique_name:"External"
spec:{urn:"beam:transform:org.apache.beam:kafka_write:v1"
payload:"\n}\n\x1c\n\x0eProducerConfig\x1a\n*\x08\n\x02\x10\x07\x12\x02
\x10\x07\n\x0b\n\x05Topic\x1a\x02\x10\x07\n\x13\n\rKeySerializer\x1a\x02\x10\x07\n\x15\n\x0fValueSerializer\x1a\x02\x10\x07\x12$d97fbd8d-dde2-46d8-babd-f5372b6ab5e6\x12\xda\x01\x04\x00\x00\x00\x00\x01\x11bootstrap.servers\x0flocalhost:37919=xlang_kafkaio_basic_test_364cd506-46f5-49dc-aeb4-4f84e1ea3e739org.apache.kafka.common.serialization.ByteArraySerializer9org.apache.kafka.common.serialization.ByteArraySerializer"}
inputs:{key:"i0" value:"n4"} environment_id:"go"} namespace:"ErKwBRUxvv"
08:02:41 expansion failed
08:02:41 caused by:
08:02:41 rpc error: code = Unavailable desc = connection error: desc =
"transport: Error while dialing dial tcp 127.0.0.1:44319: connect: connection
refused"
08:02:41
08:02:41 goroutine 11 [running]:
08:02:41 testing.tRunner.func1.2({0xda55a0, 0xc00069ca40})
08:02:41 /home/jenkins/sdk/go1.19.3/src/testing/testing.go:1396 +0x24e
08:02:41 testing.tRunner.func1()
08:02:41 /home/jenkins/sdk/go1.19.3/src/testing/testing.go:1399 +0x39f
08:02:41 panic({0xda55a0, 0xc00069ca40})
08:02:41 /home/jenkins/sdk/go1.19.3/src/runtime/panic.go:884 +0x212
08:02:41
github.com/apache/beam/sdks/v2/go/pkg/beam.CrossLanguage({0xc000489680?,
0xc0004b9c70?}, {0xee06b4, 0x2d}, {0xc00013c6e0?, 0xcfaf20?, 0xc0001b54c0?},
{0xc00048b310, 0xf}, 0xc000169c60, ...)
08:02:41
/home/jenkins/jenkins-slave/workspace/beam_PostCommit_XVR_Flink_PR/src/sdks/go/pkg/beam/xlang.go:162
+0x136
08:02:41
github.com/apache/beam/sdks/v2/go/pkg/beam/io/xlang/kafkaio.Write({0xc000489420?,
0xc0004b9c70?}, {0xc00048b310, 0xf}, {0xc00048b2d0, 0xf}, {0xc0004b6e80,
0x3d}, {0xc000169e60?}, {0x0, ...})
08:02:41
/home/jenkins/jenkins-slave/workspace/beam_PostCommit_XVR_Flink_PR/src/sdks/go/pkg/beam/io/xlang/kafkaio/kafka.go:278
+0x4cb
08:02:41
github.com/apache/beam/sdks/v2/go/test/integration/io/xlang/kafka.writeInts({0xc000489400?,
0xc0004b9c70?}, {0xc00048b310, 0xf}, {0xc00048b2d0, 0xf}, {0xc0004b6e80,
0x3d}, {0xc0000f8000, 0x3e8, ...})
08:02:41
/home/jenkins/jenkins-slave/workspace/beam_PostCommit_XVR_Flink_PR/src/sdks/go/test/integration/io/xlang/kafka/kafka.go:48
+0x24d
08:02:41
github.com/apache/beam/sdks/v2/go/test/integration/io/xlang/kafka.WritePipeline({0xc00048b310,
0xf}, {0xc00048b2d0, 0xf}, {0xc0004b6e80, 0x3d}, {0xc0000f8000, 0x3e8, 0x3e8})
08:02:41
/home/jenkins/jenkins-slave/workspace/beam_PostCommit_XVR_Flink_PR/src/sdks/go/test/integration/io/xlang/kafka/kafka.go:70
+0x157
08:02:41
github.com/apache/beam/sdks/v2/go/test/integration/io/xlang/kafka.TestKafkaIO_BasicReadWrite(0xc000491860)
08:02:41
/home/jenkins/jenkins-slave/workspace/beam_PostCommit_XVR_Flink_PR/src/sdks/go/test/integration/io/xlang/kafka/kafka_test.go:61
+0xed
08:02:41 testing.tRunner(0xc000491860, 0xf18ff0)
08:02:41 /home/jenkins/sdk/go1.19.3/src/testing/testing.go:1446 +0x10b
08:02:41 created by testing.(*T).Run
08:02:41 /home/jenkins/sdk/go1.19.3/src/testing/testing.go:1493 +0x35f
08:02:41 FAIL
github.com/apache/beam/sdks/v2/go/test/integration/io/xlang/kafka 6.051s
```
--
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]
