[
https://issues.apache.org/jira/browse/BEAM-13293?focusedWorklogId=715159&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-715159
]
ASF GitHub Bot logged work on BEAM-13293:
-----------------------------------------
Author: ASF GitHub Bot
Created on: 25/Jan/22 17:39
Start Date: 25/Jan/22 17:39
Worklog Time Spent: 10m
Work Description: 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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
Issue Time Tracking
-------------------
Worklog Id: (was: 715159)
Time Spent: 7h 10m (was: 7h)
> Go SDK JDBC IO XLang Transform
> ------------------------------
>
> Key: BEAM-13293
> URL: https://issues.apache.org/jira/browse/BEAM-13293
> Project: Beam
> Issue Type: New Feature
> Components: cross-language, sdk-go
> Reporter: Ritesh Ghorse
> Assignee: Ritesh Ghorse
> Priority: P2
> Time Spent: 7h 10m
> Remaining Estimate: 0h
>
> Add a cross language transform support in Go SDK for JDBC IO.
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
