You are viewing a plain text version of this content. The canonical link for it is here.
Posted to github@beam.apache.org by GitBox <gi...@apache.org> on 2022/01/25 17:39:07 UTC
[GitHub] [beam] lostluck commented on pull request #16111: [BEAM-13293] XLang Jdbc IO for Go SDK
lostluck commented on pull request #16111:
URL: https://github.com/apache/beam/pull/16111#issuecomment-1021443374
FYI Go Portable failed with the new test. Looking at the code now for any insights I can provide.
```
--- FAIL: TestJDBCIO_BasicReadWrite (8.57s)
panic: tried cross-language for beam:transform:org.apache.beam:schemaio_jdbc_write:v1 against localhost:9000 and failed
expanding external transform
expanding transform with ExpansionRequest: components:{pcollections:{key:"n2" value:{unique_name:"n2" coder_id:"c0@nhyUeOslCm" is_bounded:BOUNDED windowing_strategy_id:"w0@nhyUeOslCm"}} windowing_strategies:{key:"w0@nhyUeOslCm" value:{window_fn:{urn:"beam:window_fn:global_windows:v1"} merge_status:NON_MERGING window_coder_id:"c1@nhyUeOslCm" trigger:{default:{}} accumulation_mode:DISCARDING output_time:END_OF_WINDOW closing_behavior:EMIT_IF_NONEMPTY OnTimeBehavior:FIRE_IF_NONEMPTY environment_id:"go"}} coders:{key:"c0@nhyUeOslCm" value:{spec:{urn:"beam:coder:row:v1" payload:"\n\r\n\x07role_id\x1a\x02\x10\x03\x12$abc5e222-ab8f-4f6f-800a-a58bb0f45675"}}} coders:{key:"c1@nhyUeOslCm" value:{spec:{urn:"beam:coder:global_window:v1"}}} environments:{key:"go" value:{}}} transform:{unique_name:"External" spec:{urn:"beam:transform:org.apache.beam:schemaio_jdbc_write:v1" payload:"\nX\n\x0e\n\x08location\x1a\x02\x10\x07\n\x0c\n\x06config\x1a\x02\x10\t\n\x12\n\ndataSchema\x1a\x04\x08\x01\x10\t
\x12$853bc92e-cc52-429e-bf30-f534bebcedce\x12`\x03\x01\x04\x05rolesV\n\x02\xf0\x03\x15org.postgresql.Driver*jdbc:postgresql://localhost:56085/postjdbc\x07newuser\x08password"} inputs:{key:"i0" value:"n2"} environment_id:"go"} namespace:"nhyUeOslCm"
expansion failed
caused by:
rpc error: code = Unavailable desc = connection error: desc = "transport: Error while dialing dial tcp 127.0.0.1:9000: connect: connection refused" [recovered]
panic: tried cross-language for beam:transform:org.apache.beam:schemaio_jdbc_write:v1 against localhost:9000 and failed
expanding external transform
expanding transform with ExpansionRequest: components:{pcollections:{key:"n2" value:{unique_name:"n2" coder_id:"c0@nhyUeOslCm" is_bounded:BOUNDED windowing_strategy_id:"w0@nhyUeOslCm"}} windowing_strategies:{key:"w0@nhyUeOslCm" value:{window_fn:{urn:"beam:window_fn:global_windows:v1"} merge_status:NON_MERGING window_coder_id:"c1@nhyUeOslCm" trigger:{default:{}} accumulation_mode:DISCARDING output_time:END_OF_WINDOW closing_behavior:EMIT_IF_NONEMPTY OnTimeBehavior:FIRE_IF_NONEMPTY environment_id:"go"}} coders:{key:"c0@nhyUeOslCm" value:{spec:{urn:"beam:coder:row:v1" payload:"\n\r\n\x07role_id\x1a\x02\x10\x03\x12$abc5e222-ab8f-4f6f-800a-a58bb0f45675"}}} coders:{key:"c1@nhyUeOslCm" value:{spec:{urn:"beam:coder:global_window:v1"}}} environments:{key:"go" value:{}}} transform:{unique_name:"External" spec:{urn:"beam:transform:org.apache.beam:schemaio_jdbc_write:v1" payload:"\nX\n\x0e\n\x08location\x1a\x02\x10\x07\n\x0c\n\x06config\x1a\x02\x10\t\n\x12\n\ndataSchema\x1a\x04\x08\x01\x10\t
\x12$853bc92e-cc52-429e-bf30-f534bebcedce\x12`\x03\x01\x04\x05rolesV\n\x02\xf0\x03\x15org.postgresql.Driver*jdbc:postgresql://localhost:56085/postjdbc\x07newuser\x08password"} inputs:{key:"i0" value:"n2"} environment_id:"go"} namespace:"nhyUeOslCm"
expansion failed
caused by:
rpc error: code = Unavailable desc = connection error: desc = "transport: Error while dialing dial tcp 127.0.0.1:9000: connect: connection refused"
goroutine 13 [running]:
testing.tRunner.func1.2(0xe57340, 0xc0000acb80)
/home/jenkins/sdk/go1.16.12/src/testing/testing.go:1143 +0x332
testing.tRunner.func1(0xc000102c00)
/home/jenkins/sdk/go1.16.12/src/testing/testing.go:1146 +0x4b6
panic(0xe57340, 0xc0000acb80)
/home/jenkins/sdk/go1.16.12/src/runtime/panic.go:965 +0x1b9
github.com/apache/beam/sdks/v2/go/pkg/beam.CrossLanguage(0xc000454ca0, 0xc0000b82d0, 0xfa2085, 0x35, 0xc000182240, 0xbc, 0xbc, 0x7ffee806128c, 0xe, 0xc0006b3b38, ...)
/home/jenkins/jenkins-slave/workspace/beam_PreCommit_GoPortable_Commit/src/sdks/go/pkg/beam/xlang.go:162 +0x1f7
github.com/apache/beam/sdks/v2/go/pkg/beam/io/xlang/jdbcio.Write(0xc000454c80, 0xc0000b82d0, 0x7ffee806128c, 0xe, 0xf74220, 0x5, 0xf84670, 0x15, 0xc00055a840, 0x2a, ...)
/home/jenkins/jenkins-slave/workspace/beam_PreCommit_GoPortable_Commit/src/sdks/go/pkg/beam/io/xlang/jdbcio/jdbc.go:129 +0x4c7
github.com/apache/beam/sdks/v2/go/test/integration/io/xlang/jdbc.writeRows(0xc000454be0, 0xc0000b82d0, 0x7ffee806128c, 0xe, 0xf74220, 0x5, 0xf84670, 0x15, 0xc00055a840, 0x2a, ...)
/home/jenkins/jenkins-slave/workspace/beam_PreCommit_GoPortable_Commit/src/sdks/go/test/integration/io/xlang/jdbc/jdbc.go:39 +0x1be
github.com/apache/beam/sdks/v2/go/test/integration/io/xlang/jdbc.WritePipeline(0x7ffee806128c, 0xe, 0xf74220, 0x5, 0xf84670, 0x15, 0xc00055a840, 0x2a, 0xf76805, 0x7, ...)
/home/jenkins/jenkins-slave/workspace/beam_PreCommit_GoPortable_Commit/src/sdks/go/test/integration/io/xlang/jdbc/jdbc.go:49 +0x20d
github.com/apache/beam/sdks/v2/go/test/integration/io/xlang/jdbc.TestJDBCIO_BasicReadWrite(0xc000102c00)
/home/jenkins/jenkins-slave/workspace/beam_PreCommit_GoPortable_Commit/src/sdks/go/test/integration/io/xlang/jdbc/jdbc_test.go:105 +0x227
testing.tRunner(0xc000102c00, 0xfb8480)
/home/jenkins/sdk/go1.16.12/src/testing/testing.go:1193 +0xef
created by testing.(*T).Run
/home/jenkins/sdk/go1.16.12/src/testing/testing.go:1238 +0x2b3
FAIL github.com/apache/beam/sdks/v2/go/test/integration/io/xlang/jdbc 8.597s
```
--
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: github-unsubscribe@beam.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org