PaulVasilenko opened a new issue, #22172: URL: https://github.com/apache/beam/issues/22172
### What happened? I am using Go SDK and `github.com/apache/beam/sdks/v2/go/pkg/beam/io/xlang/bigqueryio` package. When i am running a pipeline which writes to BigQuery using `xlang` package, it always fails with error ``` Error message from worker: java.lang.IllegalArgumentException: unable to deserialize Custom DoFn With Execution Info ... Caused by: java.lang.ClassNotFoundException: org.apache.beam.sdk.io.gcp.bigquery.StorageApiWriteUnshardedRecords$WriteRecordsDoFn ``` That is also reproducable with this wordcount example: https://github.com/apache/beam/blob/master/sdks/go/examples/xlang/bigquery/wordcount.go ``` Error message from worker: java.lang.IllegalArgumentException: unable to deserialize Custom DoFn With Execution Info ... Caused by: java.lang.ClassNotFoundException: org.apache.beam.sdk.io.gcp.bigquery.BigQueryIO$TypedRead$4 ``` I might be doing something wrong, but that looks to me as lack of Java SDK on runner or some kind of other runner issues. ### Issue Priority Priority: 2 ### Issue Component Component: cross-language -- 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]
