diff --git a/Streaming Analytics into BigQuery Challenge Lab/quicklabarc106.sh b/Streaming Analytics into BigQuery Challenge Lab/quicklabarc106.sh index 11b953e..573bed5 100644 --- a/Streaming Analytics into BigQuery Challenge Lab/quicklabarc106.sh +++ b/Streaming Analytics into BigQuery Challenge Lab/quicklabarc106.sh @@ -15,7 +15,7 @@ gcloud pubsub topics create $TOPIC_NAME gcloud pubsub subscriptions create $TOPIC_NAME-sub --topic=$TOPIC_NAME -gcloud dataflow flex-template run $JOB_NAME --template-file-gcs-location gs://dataflow-templates-$REGION/latest/flex/PubSub_to_BigQuery_Flex --region $REGION --temp-location gs://$DEVSHELL_PROJECT_ID/temp/ --parameters outputTableSpec=$DEVSHELL_PROJECT_ID:$DATASET_NAME.$TABLE_NAME,inputTopic=projects/$DEVSHELL_PROJECT_ID/topics/$TOPIC_NAME,outputDeadletterTable=$DEVSHELL_PROJECT_ID:$DATASET_NAME.$TABLE_NAME,javascriptTextTransformReloadIntervalMinutes=0,useStorageWriteApi=false,useStorageWriteApiAtLeastOnce=false,numStorageWriteApiStreams=0 +gcloud dataflow jobs run $JOB_NAME --gcs-location gs://dataflow-templates-$REGION/latest/PubSub_to_BigQuery --region $REGION --staging-location gs://$DEVSHELL_PROJECT_ID/temp --parameters inputTopic=projects/$DEVSHELL_PROJECT_ID/topics/$TOPIC_NAME,outputTableSpec=$DEVSHELL_PROJECT_ID:$DATASET_NAME.$TABLE_NAME while true; do