Insert Final summary issue entry in issues table (#4125)

Author: NamsB7

gobblin-metastore/src/main/java/org/apache/gobblin/metastore/MysqlErrorPatternStore.java

@@ -50,7 +50,7 @@
  *
  * 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 MysqlErrorPatternStore(Config config)
       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());

gobblin-runtime/src/main/java/org/apache/gobblin/runtime/troubleshooter/JobIssueEventHandler.java

@@ -129,7 +129,8 @@ public List<Issue> getErrorListForClassification(String contextId)
       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 void logFinalError(Issue issue, String flowName, String flowGroup, String
     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);
   }
 }