Commit c8f0ab97 by chenyuanjie

no message

parent 2f9e51a4
...@@ -42,7 +42,7 @@ if __name__ == '__main__': ...@@ -42,7 +42,7 @@ if __name__ == '__main__':
) )
engine.sqoop_raw_import( engine.sqoop_raw_import(
query=f"SELECT {cols} FROM {import_table} WHERE 1=1 and $CONDITIONS", query=f"SELECT {cols} FROM {import_table} WHERE 1=1 and \$CONDITIONS",
hive_table=hive_table, hive_table=hive_table,
hdfs_path=hdfs_path, hdfs_path=hdfs_path,
partitions=partition_dict, partitions=partition_dict,
......
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