Repository: incubator-airflow Updated Branches: refs/heads/master 7c19ed02b -> 3dabd8f03
[AIRFLOW-2754] Fix invalid static path in case of using HDP. Closes #3607 from happyjulie/AIRFLOW-2754 Project: http://git-wip-us.apache.org/repos/asf/incubator-airflow/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-airflow/commit/3dabd8f0 Tree: http://git-wip-us.apache.org/repos/asf/incubator-airflow/tree/3dabd8f0 Diff: http://git-wip-us.apache.org/repos/asf/incubator-airflow/diff/3dabd8f0 Branch: refs/heads/master Commit: 3dabd8f03d8cb58e7fea1af54b0462f700ec53f3 Parents: 7c19ed0 Author: juhwi.lee <[email protected]> Authored: Mon Jul 16 10:12:24 2018 +0200 Committer: Fokko Driesprong <[email protected]> Committed: Mon Jul 16 10:12:24 2018 +0200 ---------------------------------------------------------------------- airflow/operators/hive_to_druid.py | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-airflow/blob/3dabd8f0/airflow/operators/hive_to_druid.py ---------------------------------------------------------------------- diff --git a/airflow/operators/hive_to_druid.py b/airflow/operators/hive_to_druid.py index f39f2c9..859515d 100644 --- a/airflow/operators/hive_to_druid.py +++ b/airflow/operators/hive_to_druid.py @@ -129,9 +129,7 @@ class HiveToDruidTransfer(BaseOperator): columns = [col.name for col in t.sd.cols] # Get the path on hdfs - hdfs_uri = m.get_table(hive_table).sd.location - pos = hdfs_uri.find('/user') - static_path = hdfs_uri[pos:] + static_path = m.get_table(hive_table).sd.location schema, table = hive_table.split('.')
