我正在运行一个作业的谷歌数据流编写的阿帕奇光束,从BigQuery表和文件读取。转换数据并将其写入其他BigQuery表。作业“通常”会成功,但有时当我从大型查询表中读取数据时,会随机得到空指针异常,并且作业会失败:at:297)
at com.google.cloud.dataflow.worker.runners.worker.
You can get help with CloudDataflow at https://cloud.google.com/dataflow/support.我用来运行此作业的代码如下:(函数ReconstructConversation()在进入函数体后立即返回) '--runner=DataflowRunnerbigquery_
我们有一个作业,它可以写入Bigtable (通过HBase API)。<init>(BigtableConnection.java:33) at com.google.cloud.bigtable.dataflow.CloudBigtableConnectionPool$1(CloudBigtableConnectionPool.java:72) at com.google.cloud.bigtable.dataflow.CloudBig