This is an automated email from the ASF dual-hosted git repository.
curth pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/arrow-adbc.git
The following commit(s) were added to refs/heads/main by this push:
new 455947708 fix(csharp/src/Drivers/BigQuery): Use job reference instead
of job id to get job to avoid interference between different locations (#2433)
455947708 is described below
commit 455947708430f6db66f8b0eab77a471266f61f26
Author: qifanzhang-ms <[email protected]>
AuthorDate: Tue Jan 14 00:30:06 2025 +0800
fix(csharp/src/Drivers/BigQuery): Use job reference instead of job id to
get job to avoid interference between different locations (#2433)
…between different locations.
---
csharp/src/Drivers/BigQuery/BigQueryStatement.cs | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/csharp/src/Drivers/BigQuery/BigQueryStatement.cs
b/csharp/src/Drivers/BigQuery/BigQueryStatement.cs
index ab7764b03..dfccc16e4 100644
--- a/csharp/src/Drivers/BigQuery/BigQueryStatement.cs
+++ b/csharp/src/Drivers/BigQuery/BigQueryStatement.cs
@@ -83,7 +83,7 @@ namespace Apache.Arrow.Adbc.Drivers.BigQuery
BigQueryJob firstQueryJob = new BigQueryJob(client,
job.Resource);
foreach (BigQueryJob childJob in joblist)
{
- var tempJob = client.GetJob(childJob.Reference.JobId);
+ var tempJob = client.GetJob(childJob.Reference);
var query = tempJob.Resource?.Configuration?.Query;
if (query != null && query.DestinationTable != null &&
query.DestinationTable.ProjectId != null && query.DestinationTable.DatasetId !=
null && query.DestinationTable.TableId != null)
{
