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

This solves amundsen-io/amundsen#550
pPanda-beta · Jul 19, 2020 · 9faf470 · 9faf470
1 parent 24b3b0a
commit 9faf470
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