Merge pull request #17 from awslabs/hotfix/bootstrap-stack-name

Hotfix/bootstrap stack name
awslabs · Aug 24, 2023 · 42c9714 · 42c9714
2 parents 23f7fcc + 8d018de
commit 42c9714
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 5 deletions.
diff --git a/apps/java-datastream/kds-to-s3-datastream-java/cdk-infra/cdk.json b/apps/java-datastream/kds-to-s3-datastream-java/cdk-infra/cdk.json
@@ -45,7 +45,7 @@
     "runtimeEnvironment": "",
     "glueDatabaseName": "",
     "flinkVersion": "1.15.2",
-    "zepFlinkVersion": "1.13.2",
+    "RuntimeEnvironment": "1.13.2",
     "deployDataGen": "false",
     "kdaLogGroup": "",
     "kdaLogStream": "",

diff --git a/python/lambda_create_studio_app.py b/python/lambda_create_studio_app.py
@@ -30,6 +30,7 @@ def handler(event, context):
         app_name = os.environ["app_name"]
         execution_role = os.environ["execution_role"]
         bootstrap_string = os.environ["bootstrap_string"]
+        bootstrap_stack_name = os.environ["bootstrapStackName"]
         subnet1 = os.environ["subnet_1"]
         source_topic = os.environ["source_topic_name"]
         security_group = os.environ["security_group"]
@@ -42,7 +43,7 @@ def handler(event, context):
         if event['RequestType'] == 'Create' or event['RequestType'] == 'Update':
             LOGGER.info('In Create')
 
-            create_app(client, app_name, execution_role, bootstrap_string, subnet1,
+            create_app(client, app_name, execution_role, bootstrap_string, bootstrap_stack_name, subnet1,
                        source_topic, security_group, glue_db_arn, log_stream_arn, zep_flink_version,
                        blueprint_name, stack_id)
             cfnresponse.send(event, context, cfnresponse.SUCCESS, {
@@ -58,7 +59,7 @@ def handler(event, context):
                          {"Message": str(e)})
 
 
-def create_app(client, app_name, execution_role, bootstrap_string, subnet1,
+def create_app(client, app_name, execution_role, bootstrap_string, bootstrap_stack_name, subnet1,
                source_topic, security_group, glue_db_arn, log_stream_arn, zep_flink_version,
                blueprint_name, stack_id):
 
@@ -94,7 +95,8 @@ def create_app(client, app_name, execution_role, bootstrap_string, subnet1,
                         'PropertyGroupId': 'BlueprintMetadata',
                         'PropertyMap': {
                             'StackId': stack_id,
-                            'BlueprintName': blueprint_name
+                            'BlueprintName': blueprint_name,
+                            'BootstrapStackName': bootstrap_stack_name
                         }
                     },
                 ]
@@ -218,7 +220,7 @@ def generate_code_content(app_name, execution_role, bootstrap_string, subnet1, s
 
     insert_datagen_content = {}
     insert_datagen_content["text"] = """%flink.ssql(parallelism=1)\nDROP TABLE IF EXISTS generate_stock_data;\nCREATE TABLE generate_stock_data(\n  ticker STRING,\n  event_time TIMESTAMP(3),\n  price DOUBLE\n)\nWITH (\n    'connector' = 'datagen',\n    'fields.price.kind' = 'random',\n    'fields.price.min' ='0.00',\n    'fields.price.max' = '1000.00'\n\n\n);\n\n\nINSERT INTO stock_table \nSELECT random_ticker_udf() as ticker, event_time, price from generate_stock_data;"""
-    insert_datagen_content["title"] = """<h3><font  color="#3071A9" >3) Please run this paragraph before running any additional event_time based queries in order to generate new data into the MSF topic</font></h3>"""
+    insert_datagen_content["title"] = """<h3><font  color="#3071A9" >3) Please run this paragraph before running any additional event_time based queries in order to generate new data into the MSK topic</font></h3>"""
     insert_datagen_content["config"] = {}
     insert_datagen_content["config"]["title"]= "true"