(gobblin) branch master updated: update job_name column size (#4011)

[arjun4084346]

This is an automated email from the ASF dual-hosted git repository.

arjun4084346 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/gobblin.git


The following commit(s) were added to refs/heads/master by this push:
     new bdea71eb99 update job_name column size (#4011)
bdea71eb99 is described below

commit bdea71eb9945abdb1a300ba2daf32841ea6c7414
Author: Arjun Singh Bora <ab...@linkedin.com>
AuthorDate: Mon Jul 29 16:31:33 2024 -0700

    update job_name column size (#4011)
---
 .../src/main/resources/db/migration/V1_0_0__Initial_version.sql         | 2 +-
 .../service/modules/orchestration/MysqlMultiActiveLeaseArbiter.java     | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/gobblin-metastore/src/main/resources/db/migration/V1_0_0__Initial_version.sql 
b/gobblin-metastore/src/main/resources/db/migration/V1_0_0__Initial_version.sql
index e51b8c488a..90884d13e2 100644
--- 
a/gobblin-metastore/src/main/resources/db/migration/V1_0_0__Initial_version.sql
+++ 
b/gobblin-metastore/src/main/resources/db/migration/V1_0_0__Initial_version.sql
@@ -18,7 +18,7 @@
 SET SESSION time_zone = '+00:00';
 
 CREATE TABLE IF NOT EXISTS gobblin_job_executions (
-       job_name VARCHAR(128) NOT NULL,
+       job_name VARCHAR(374) NOT NULL,
        job_id VARCHAR(128) NOT NULL,
        start_time TIMESTAMP NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE 
CURRENT_TIMESTAMP,
        end_time TIMESTAMP NOT NULL DEFAULT '1970-01-01 00:00:01',
diff --git 
a/gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/MysqlMultiActiveLeaseArbiter.java
 
b/gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/MysqlMultiActiveLeaseArbiter.java
index 0aeca9a063..9091d9ff52 100644
--- 
a/gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/MysqlMultiActiveLeaseArbiter.java
+++ 
b/gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/MysqlMultiActiveLeaseArbiter.java
@@ -113,7 +113,7 @@ public class MysqlMultiActiveLeaseArbiter implements 
MultiActiveLeaseArbiter {
   private static final String CREATE_LEASE_ARBITER_TABLE_STATEMENT = "CREATE 
TABLE IF NOT EXISTS %s ("
       + "flow_group varchar(" + ServiceConfigKeys.MAX_FLOW_GROUP_LENGTH + ") 
NOT NULL, flow_name varchar("
       + ServiceConfigKeys.MAX_FLOW_GROUP_LENGTH + ") NOT NULL, " + "job_name 
varchar("
-      + ServiceConfigKeys.MAX_FLOW_GROUP_LENGTH + ") NOT NULL, dag_action 
varchar(100) NOT NULL, "
+      + ServiceConfigKeys.MAX_JOB_NAME_LENGTH + ") NOT NULL, dag_action 
varchar(100) NOT NULL, "
       + "event_timestamp TIMESTAMP(3) NOT NULL, "
       + "lease_acquisition_timestamp TIMESTAMP(3) NULL, "
       + "PRIMARY KEY (flow_group,flow_name,job_name,dag_action))";