azkaban-developers

update sql clauses to 3.10.0 (#824) * update sql clauses to …

1/4/2017 10:32:25 PM

3.10.0

* remove schedules table since it is no longer used for long time

* removing unused file

* restore the file to github repo

* adding upload time index in table execution_logs

Liang Tang

Commit: d93fd75

Tree: c3bae7c

Parents: 6b32da3

Changes

azkaban-sql/src/sql/create.active_executing_flows.sql 4(+1 -3)

azkaban-sql/src/sql/create.execution_flows.sql 2(+2 -0)

azkaban-sql/src/sql/create.execution_logs.sql 3(+2 -1)

azkaban-sql/src/sql/create.schedules.sql 19(+0 -19)

azkaban-sql/src/sql/database.properties 2(+1 -1)

azkaban-sql/src/sql/update.active_executing_flows.3.0.sql 2(+0 -2)

azkaban-sql/src/sql/update.execution_flows.3.0.sql 2(+0 -2)

Details

azkaban-sql/src/sql/create.active_executing_flows.sql 4(+1 -3)

diff --git a/azkaban-sql/src/sql/create.active_executing_flows.sql b/azkaban-sql/src/sql/create.active_executing_flows.sql
index 960ebc5..6c2f8e4 100644
--- a/azkaban-sql/src/sql/create.active_executing_flows.sql
+++ b/azkaban-sql/src/sql/create.active_executing_flows.sql
@@ -1,7 +1,5 @@
 CREATE TABLE active_executing_flows (
 	exec_id INT,
-	host VARCHAR(255),
-	port INT,
 	update_time BIGINT,
 	PRIMARY KEY (exec_id)
-);
\ No newline at end of file
+);

azkaban-sql/src/sql/create.execution_flows.sql 2(+2 -0)

diff --git a/azkaban-sql/src/sql/create.execution_flows.sql b/azkaban-sql/src/sql/create.execution_flows.sql
index b2f7625..8df344d 100644
--- a/azkaban-sql/src/sql/create.execution_flows.sql
+++ b/azkaban-sql/src/sql/create.execution_flows.sql
@@ -11,6 +11,7 @@ CREATE TABLE execution_flows (
 	end_time BIGINT,
 	enc_type TINYINT,
 	flow_data LONGBLOB,
+	executor_id INT DEFAULT NULL,
 	PRIMARY KEY (exec_id)
 );
 
@@ -18,3 +19,4 @@ CREATE INDEX ex_flows_start_time ON execution_flows(start_time);
 CREATE INDEX ex_flows_end_time ON execution_flows(end_time);
 CREATE INDEX ex_flows_time_range ON execution_flows(start_time, end_time);
 CREATE INDEX ex_flows_flows ON execution_flows(project_id, flow_id);
+CREATE INDEX executor_id ON execution_flows(executor_id);
\ No newline at end of file

azkaban-sql/src/sql/create.execution_logs.sql 3(+2 -1)

diff --git a/azkaban-sql/src/sql/create.execution_logs.sql b/azkaban-sql/src/sql/create.execution_logs.sql
index 0aa6a36..b1ed376 100644
--- a/azkaban-sql/src/sql/create.execution_logs.sql
+++ b/azkaban-sql/src/sql/create.execution_logs.sql
@@ -11,4 +11,5 @@ CREATE TABLE execution_logs (
 );
 
 CREATE INDEX ex_log_attempt ON execution_logs(exec_id, name, attempt);
-CREATE INDEX ex_log_index ON execution_logs(exec_id, name);
\ No newline at end of file
+CREATE INDEX ex_log_index ON execution_logs(exec_id, name);
+CREATE INDEX ex_log_upload_time ON execution_logs(upload_time);

azkaban-sql/src/sql/database.properties 2(+1 -1)

diff --git a/azkaban-sql/src/sql/database.properties b/azkaban-sql/src/sql/database.properties
index b6802bc..2453cd1 100644
--- a/azkaban-sql/src/sql/database.properties
+++ b/azkaban-sql/src/sql/database.properties
@@ -1 +1 @@
-version=3.0
+version=3.10.1