(gobblin) branch master updated: Insert Final summary issue entry in issues table (#4125)

[abhijain]

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

abhijain 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 9151f93668 Insert Final summary issue entry in issues table (#4125)
9151f93668 is described below

commit 9151f93668cbb403d319d4474a4d313beb81ef70
Author: NamsB7 <126075176+nam...@users.noreply.github.com>
AuthorDate: Mon Jul 28 18:55:10 2025 +0530

    Insert Final summary issue entry in issues table (#4125)
---
 .../java/org/apache/gobblin/metastore/MysqlErrorPatternStore.java    | 4 ++--
 .../apache/gobblin/runtime/troubleshooter/JobIssueEventHandler.java  | 5 ++++-
 2 files changed, 6 insertions(+), 3 deletions(-)

diff --git 
a/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/MysqlErrorPatternStore.java
 
b/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/MysqlErrorPatternStore.java
index e63d419d2c..e2aaeb3efc 100644
--- 
a/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/MysqlErrorPatternStore.java
+++ 
b/gobblin-metastore/src/main/java/org/apache/gobblin/metastore/MysqlErrorPatternStore.java
@@ -50,7 +50,7 @@ import java.util.List;
  *
  * Expected table schemas:
  *
- * 1. error_summary_regex_store
+ * 1. error_regex_summary_store
  *    - description_regex: VARCHAR(255) NOT NULL UNIQUE
  *    - error_category_name: VARCHAR(255) NOT NULL
  *
@@ -127,7 +127,7 @@ public class MysqlErrorPatternStore implements 
ErrorPatternStore {
       throw new IOException("Please specify the config for 
MysqlErrorPatternStore");
     }
     this.errorRegexSummaryStoreTable =
-        ConfigUtils.getString(config, 
ConfigurationKeys.ERROR_REGEX_DB_TABLE_KEY, "error_summary_regex_store");
+        ConfigUtils.getString(config, 
ConfigurationKeys.ERROR_REGEX_DB_TABLE_KEY, "error_regex_summary_store");
     this.errorCategoriesTable =
         ConfigUtils.getString(config, 
ConfigurationKeys.ERROR_CATEGORIES_DB_TABLE_KEY, "error_categories");
     this.dataSource = MysqlDataSourceFactory.get(config, 
SharedResourcesBrokerFactory.getImplicitBroker());
diff --git 
a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/troubleshooter/JobIssueEventHandler.java
 
b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/troubleshooter/JobIssueEventHandler.java
index ea26ede30f..df2b22629f 100644
--- 
a/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/troubleshooter/JobIssueEventHandler.java
+++ 
b/gobblin-runtime/src/main/java/org/apache/gobblin/runtime/troubleshooter/JobIssueEventHandler.java
@@ -129,7 +129,8 @@ public class JobIssueEventHandler {
       return issueRepository.getMostRecentErrors(contextId, limit);
   }
 
-  public void logFinalError(Issue issue, String flowName, String flowGroup, 
String flowExecutionId, String jobName) {
+  public void logFinalError(Issue issue, String flowName, String flowGroup, 
String flowExecutionId, String jobName)
+      throws TroubleshooterException {
     JobIssueLogEntry logEntry = new JobIssueLogEntry();
     logEntry.issue = issue;
     logEntry.flowName = flowName;
@@ -138,6 +139,8 @@ public class JobIssueEventHandler {
     logEntry.jobName = jobName;
 
     String serializedIssueEvent = 
GsonUtils.GSON_WITH_DATE_HANDLING.toJson(logEntry);
+    String contextId = TroubleshooterUtils.getContextIdForJob(flowGroup, 
flowName, flowExecutionId, jobName);
+    issueRepository.put(contextId, issue);
     issueLogger.info(serializedIssueEvent);
   }
 }
\ No newline at end of file