Skip to content

A
AmendsenProject
Unverified Commit 4b7b147b authored by Palash Das's avatar Palash Das Committed by GitHub
Browse files
Options

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

This solves https://github.com/lyft/amundsen/issues/550
parent 24b3b0af
Show whitespace changes
Inline Side-by-side
Showing with 2 additions and 1 deletion
example/dags/hive_sample_dag.py
View file @ 4b7b147b
...@@ -66,7 +66,8 @@ def connection_string(): ...@@ -66,7 +66,8 @@ def connection_string():
def create_table_wm_job(**kwargs): def create_table_wm_job(**kwargs):
sql = textwrap.dedent(""" sql = textwrap.dedent("""
SELECT From_unixtime(A0.create_time) as create_time, 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, B0.tbl_name as table_name,
{func}(A0.part_name) as part_name, {func}(A0.part_name) as part_name,
{watermark} as part_type {watermark} as part_type
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment