Temporal join fails with "unexpected correlate variable $cor0 in the plan"

Hi all, I'm trying to join the following two tables using a temporal join: *table_1* ( `f0` STRING NOT NULL, `f1` DOUBLE NOT NULL, `rowtime` TIMESTAMP(3) METADATA, WATERMARK FOR `rowtime`: TIMESTAMP(3) AS rowtime - INTERVAL '10' SECOND ) *table_2:* ( `f0` STRING NOT NULL, `f1` DOUBLE

Re: BigQuery connector debugging

End()" returns false? > > > On Tue, Apr 5, 2022 at 9:42 AM Matthew Brown wrote: > >> Hi all, >> >> I'm attempting to build a Table API connector for BigQuery using the >> BigQuery Storage API ( >> https://cloud.google.com/bigquery/docs/reference/sto

BigQuery connector debugging

Hi all, I'm attempting to build a Table API connector for BigQuery using the BigQuery Storage API ( https://cloud.google.com/bigquery/docs/reference/storage). I've got a base structure built out at https://github.com/mnbbrown/bigquery-connector There's a couple of things I have to do yet like cor