dedocibula commented on PR #32474:
URL: https://github.com/apache/beam/pull/32474#issuecomment-2533001909

   Tested with BigQuery template and sdf checkpoint interval = 80s. There don't 
seem to be deadline exceeded anymore and data freshness by state oscillates 
between 40-50s
   
   gcloud dataflow flex-template run $DATAFLOW_JOB --template-file-gcs-location 
gs://$BUCKET_NAME/templates/flex/Spanner_Change_Streams_to_BigQuery --region 
us-central1 --parameters spannerInstanceId=$INSTANCE --parameters 
spannerDatabase=$DATABASE --parameters spannerMetadataInstanceId=$INSTANCE 
--parameters spannerMetadataDatabase=$META_DATABASE --parameters 
spannerChangeStreamName=$CHANGE_STREAM --parameters 
bigQueryDataset=$BIG_QUERY_DATASET --parameters 
deadLetterQueueDirectory=gs://$BUCKET_NAME/dlq/try1 --parameters 
experiments=sdf_checkpoint_after_duration=80s


-- 
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]

Reply via email to