[FSTORE-1065][APPEND] correct host address for the app (#208)

logicalclocks · Nov 9, 2023 · 5935d12 · 5935d12
1 parent 8219d98
commit 5935d12
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/integrations/java/beam/README.md b/integrations/java/beam/README.md
@@ -51,7 +51,7 @@ have Hopsworks cluster host address, hopsworks project name and [api key](https:
 Once you have the above define environment variables:
 
 ```bash
-HOPSWORKS_HOST=app.hopsworks.ai
+HOPSWORKS_HOST=c.app.hopsworks.ai
 HOPSWORKS_API_KEY=REPLACE_WITH_YOUR_HOPSWORKS_API_KEY
 HOPSWORKS_PROJECT_NAME=REPLACE_WITH_YOUR_HOPSWORKS_PROJECT_NAME
 ```
@@ -156,4 +156,4 @@ python3 ./materialization_job_client.py --api_key $HOPSWORKS_API_KEY --jobname $
   `DataflowRunner`.
 - Stop the Dataflow job in [GCP Console Dataflow page]. Cancel the job instead of draining it. This may take some 
   minutes.
-- make sure to delete all VMs created by DataflowRunner (if any).
+- make sure to delete all VMs created by DataflowRunner (if any).
diff --git a/integrations/java/flink/README.md b/integrations/java/flink/README.md
@@ -67,7 +67,7 @@ HOPSWORKS_PROJECT_NAME=REPLACE_WITH_YOUR_HOPSWORKS_PROJECT_NAME
 ### Create Source kafka topic and Feature Group
 
 ```python
-python ./flink/setup/feature_groups.py
+python ./flink/setup/feature_group.py
 python ./flink/setup/kafka_topic.py
 ```
 ### Simulate card transactions and write to source topic
@@ -143,7 +143,7 @@ To submit flink pipeline that computes aggregates on 10 minute window and writes
 feature group execute the following command.
 
 ```bash
-python3 ./flink/jobs_flink_client.py --host $HOPSWORKS_HOST --api_key $HOPSWORKS_API_KEY --project $HOPSWORKS_PROJECT_NAME --job transactionConsumer --jar ./flink/target/flink-3.4.0-SNAPSHOT.jar --main "com.hopsworks.tutorials.flink.TransactionFraudExample" --job_arguments "-featureGroupName card_transactions_10m_agg -featureGroupVersion 1 -sourceTopic credit_card_transactions -windowLength 10 -parallelism 1"
+python3 ./flink/jobs_flink_client.py --host $HOPSWORKS_HOST --api_key $HOPSWORKS_API_KEY --project $HOPSWORKS_PROJECT_NAME --job transactionConsumer --jar ./flink/target/flink-3.4.2.jar --main "com.hopsworks.tutorials.flink.TransactionFraudExample" --job_arguments "-featureGroupName card_transactions_10m_agg -featureGroupVersion 1 -sourceTopic credit_card_transactions -windowLength 10 -parallelism 1"
 ```
 
 #### Backfill feature data to offline feature group