java.lang.NullPointerException on BigQuery.IO.Write in a str

Question

在数据流 SDK 2.1.0中从流式处理管道BigQuery.IO.Write出现以下错误

java.lang.NullPointerException org.apache.beam.sdk.io.gcp.bigquery.BigQueryServicesImpl$DatasetServiceImpl.insertAll(BigQueryServicesImpl.java：759( org.apache.beam.sdk.io.gcp.bigquery.BigQueryServicesImpl$DatasetServiceImpl.insertAll(BigQueryServicesImpl.java：809( org.apache.beam.sdk.io.gcp.bigquery.StreamingWriteFn.flushRows(StreamingWriteFn.java：126( org.apache.beam.sdk.io.gcp.bigquery.StreamingWriteFn.finishBundle(StreamingWriteFn.java：96(

爪哇代码：

PCollection<TableRow> tableRows = ...
    tableRows.apply("WriteToBQ",
            BigQueryIO.writeTableRows()
            .to(String.format("%1$s.%2$s",bqDataSet, bqTable))
            .withSchema(Schema.get())
            .withWriteDisposition(BigQueryIO.Write.WriteDisposition.WRITE_APPEND));

Answer 1

这是在

Beam 2.2.0 中修复的 https://issues.apache.org/jira/browse/BEAM-2834。