|
@@ -8,7 +8,7 @@ def run(inputs: dict, outputs: list):
|
|
|
for k, tb_name in inputs.items():
|
|
|
script=script.replace(k,tb_name)
|
|
|
ss = SparkSession.builder.config('hive.metastore.uris',
|
|
|
- 'thrift://192.168.199.27:9083').enableHiveSupport().getOrCreate()
|
|
|
+ '{{ hive_metastore_uris }}').enableHiveSupport().getOrCreate()
|
|
|
ret_df = ss.sql(script)
|
|
|
ret_df.write.mode("overwrite").saveAsTable(outputs[0])
|
|
|
|