airflow-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From davy...@apache.org
Subject [2/3] incubator-airflow git commit: change TARGET_PARTITION_SIZE to DEFAULT_TARGET_PARTITION_SIZE
Date Mon, 16 May 2016 20:16:00 GMT
change TARGET_PARTITION_SIZE to DEFAULT_TARGET_PARTITION_SIZE


Project: http://git-wip-us.apache.org/repos/asf/incubator-airflow/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-airflow/commit/199e07a4
Tree: http://git-wip-us.apache.org/repos/asf/incubator-airflow/tree/199e07a4
Diff: http://git-wip-us.apache.org/repos/asf/incubator-airflow/diff/199e07a4

Branch: refs/heads/master
Commit: 199e07a455e77ceb33e06ab7646fa957a5fbd232
Parents: b565ef9
Author: Hongbo Zeng <hongbo.zeng@airbnb.com>
Authored: Mon May 16 11:20:49 2016 -0700
Committer: Hongbo Zeng <hongbo.zeng@airbnb.com>
Committed: Mon May 16 11:20:49 2016 -0700

----------------------------------------------------------------------
 airflow/hooks/druid_hook.py | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-airflow/blob/199e07a4/airflow/hooks/druid_hook.py
----------------------------------------------------------------------
diff --git a/airflow/hooks/druid_hook.py b/airflow/hooks/druid_hook.py
index 7c80c7c..bb6d9fa 100644
--- a/airflow/hooks/druid_hook.py
+++ b/airflow/hooks/druid_hook.py
@@ -10,7 +10,7 @@ from airflow.hooks.base_hook import BaseHook
 from airflow.exceptions import AirflowException
 
 LOAD_CHECK_INTERVAL = 5
-TARGET_PARTITION_SIZE = 5000000
+DEFAULT_TARGET_PARTITION_SIZE = 5000000
 
 class AirflowDruidLoadException(AirflowException):
     pass
@@ -64,7 +64,7 @@ class DruidHook(BaseHook):
         # and overwrites the num_shards
         if target_partition_size == -1:
             if num_shards == -1:
-                target_partition_size = TARGET_PARTITION_SIZE
+                target_partition_size = DEFAULT_TARGET_PARTITION_SIZE
         else:
             num_shards = -1
 


Mime
View raw message