fix: Fix sql for missing columns and mysql based dialects (#550) (#305)

This solves amundsen-io/amundsen#550
amundsen-io · Jul 20, 2020 · 4b7b147 · 4b7b147
1 parent 24b3b0a
commit 4b7b147
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/example/dags/hive_sample_dag.py b/example/dags/hive_sample_dag.py
@@ -66,7 +66,8 @@ def connection_string():
 def create_table_wm_job(**kwargs):
     sql = textwrap.dedent("""
         SELECT From_unixtime(A0.create_time) as create_time,
-               C0.NAME as schema,
+               'hive'                        as `database`,
+               C0.NAME                       as `schema`,
                B0.tbl_name as table_name,
                {func}(A0.part_name) as part_name,
                {watermark} as part_type