From 4b7b147b1d32cd8fce6aa7c24fa1db8d823b8038 Mon Sep 17 00:00:00 2001
From: Palash Das <palashkok3@gmail.com>
Date: Mon, 20 Jul 2020 22:08:07 +0530
Subject: [PATCH] fix: Fix sql for missing columns and mysql based dialects
 (#550) (#305)

This solves https://github.com/lyft/amundsen/issues/550
---
 example/dags/hive_sample_dag.py | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/example/dags/hive_sample_dag.py b/example/dags/hive_sample_dag.py
index 0cfed726b..44143932b 100644
--- 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