Merge pull request #390 from aws-samples/athena_v3

Athena v3 compatibility fix
aws-samples · Oct 24, 2022 · f5ec4d6 · f5ec4d6
2 parents 170f33f + 16bdd99
commit f5ec4d6
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 6 deletions.
diff --git a/cid/builtin/core/data/queries/cid/ri_sp_mapping_ri.sql b/cid/builtin/core/data/queries/cid/ri_sp_mapping_ri.sql
@@ -18,8 +18,8 @@
      WHEN ("reservation_reservation_a_r_n" <> '') THEN "reservation_reservation_a_r_n"
      ELSE '' END "ri_sp_arn_mapping"
  , CASE 
- -- WHEN ("savings_plan_savings_plan_a_r_n" <> '') THEN CAST(from_iso8601_timestamp("savings_plan_end_time") AS timestamp)
-     WHEN ("reservation_reservation_a_r_n" <> '' AND "reservation_end_time" <> '') THEN CAST(from_iso8601_timestamp("reservation_end_time") AS timestamp) 
+ -- WHEN ("savings_plan_savings_plan_a_r_n" <> '') THEN CAST(CAST(from_iso8601_timestamp("savings_plan_end_time") AS date) AS timestamp)
+     WHEN ("reservation_reservation_a_r_n" <> '' AND "reservation_end_time" <> '') THEN CAST(CAST(from_iso8601_timestamp("reservation_end_time") AS date) AS timestamp)  
      ELSE NULL END "ri_sp_end_date"
     FROM
      "${cur_table_name}"

diff --git a/cid/builtin/core/data/queries/cid/ri_sp_mapping_sp.sql b/cid/builtin/core/data/queries/cid/ri_sp_mapping_sp.sql
@@ -18,8 +18,8 @@
      -- WHEN ("reservation_reservation_a_r_n" <> '') THEN "reservation_reservation_a_r_n"
      ELSE '' END "ri_sp_arn_mapping"
  , CASE 
-     WHEN ("savings_plan_savings_plan_a_r_n" <> '') THEN CAST(from_iso8601_timestamp("savings_plan_end_time") AS timestamp)
-     -- WHEN ("reservation_reservation_a_r_n" <> '' AND "reservation_end_time" <> '') THEN CAST(from_iso8601_timestamp("reservation_end_time") AS timestamp) 
+     WHEN ("savings_plan_savings_plan_a_r_n" <> '') THEN CAST(CAST(from_iso8601_timestamp("savings_plan_end_time") AS date) AS timestamp)
+     -- WHEN ("reservation_reservation_a_r_n" <> '' AND "reservation_end_time" <> '') THEN CAST(CAST(from_iso8601_timestamp("reservation_end_time") AS date) AS timestamp  
      ELSE NULL END "ri_sp_end_date"
     FROM
      "${cur_table_name}"

diff --git a/cid/builtin/core/data/queries/cid/ri_sp_mapping_sp_ri.sql b/cid/builtin/core/data/queries/cid/ri_sp_mapping_sp_ri.sql
@@ -17,8 +17,8 @@
      WHEN ("savings_plan_savings_plan_a_r_n" <> '') THEN "savings_plan_savings_plan_a_r_n" 
      WHEN ("reservation_reservation_a_r_n" <> '') THEN "reservation_reservation_a_r_n"ELSE '' END "ri_sp_arn_mapping"
  , CASE 
-     WHEN ("savings_plan_savings_plan_a_r_n" <> '') THEN CAST(from_iso8601_timestamp("savings_plan_end_time") AS timestamp)
-     WHEN ("reservation_reservation_a_r_n" <> '' AND "reservation_end_time" <> '') THEN CAST(from_iso8601_timestamp("reservation_end_time") AS timestamp) ELSE NULL END "ri_sp_end_date"
+     WHEN ("savings_plan_savings_plan_a_r_n" <> '') THEN CAST(CAST(from_iso8601_timestamp("savings_plan_end_time") AS date) AS timestamp)
+     WHEN ("reservation_reservation_a_r_n" <> '' AND "reservation_end_time" <> '') THEN CAST(CAST(from_iso8601_timestamp("reservation_end_time") AS date) AS timestamp) ELSE NULL END "ri_sp_end_date"
     FROM
       "${cur_table_name}"
     WHERE (("line_item_line_item_type" = 'RIFee') OR ("line_item_line_item_type" = 'SavingsPlanRecurringFee'))