From 5935d126aa7827406ffd583aa9128b8fe13f2df3 Mon Sep 17 00:00:00 2001
From: davitbzh <44586065+davitbzh@users.noreply.github.com>
Date: Thu, 9 Nov 2023 20:03:07 +0100
Subject: [PATCH] [FSTORE-1065][APPEND] correct host address for the app (#208)

---
 integrations/java/beam/README.md  | 4 ++--
 integrations/java/flink/README.md | 4 ++--
 2 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/integrations/java/beam/README.md b/integrations/java/beam/README.md
index 79a89139..e14dced3 100644
--- 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).
\ No newline at end of file
+- 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
index 343fbacb..47ac9ea1 100644
--- 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