[jira] [Work logged] (GOBBLIN-1767) Update Mysql driver class name to `com.mysql.cj.jdbc.Driver`

2023-01-17 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/GOBBLIN-1767?focusedWorklogId=839846&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-839846 ] ASF GitHub Bot logged work on GOBBLIN-1767: --- Author: ASF GitHub B

[GitHub] [gobblin] phet opened a new pull request, #3626: [GOBBLIN-1767] Update references to deprecated Mysql connector/j driver to new name

2023-01-17 Thread GitBox
phet opened a new pull request, #3626: URL: https://github.com/apache/gobblin/pull/3626 Dear Gobblin maintainers, Please accept this PR. I understand that it will not be reviewed until I have checked off all the steps below! ### JIRA - [ ] My PR addresses the following [

[jira] [Created] (GOBBLIN-1767) Update Mysql driver class name to `com.mysql.cj.jdbc.Driver`

2023-01-17 Thread Kip Kohn (Jira)
Kip Kohn created GOBBLIN-1767: - Summary: Update Mysql driver class name to `com.mysql.cj.jdbc.Driver` Key: GOBBLIN-1767 URL: https://issues.apache.org/jira/browse/GOBBLIN-1767 Project: Apache Gobblin

[jira] [Work logged] (GOBBLIN-1764) Emit GaaSObservabilityEvent

2023-01-17 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/GOBBLIN-1764?focusedWorklogId=839805&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-839805 ] ASF GitHub Bot logged work on GOBBLIN-1764: --- Author: ASF GitHub B

[GitHub] [gobblin] Will-Lo commented on a diff in pull request #3623: [GOBBLIN-1764] Emit observability event

2023-01-17 Thread GitBox
Will-Lo commented on code in PR #3623: URL: https://github.com/apache/gobblin/pull/3623#discussion_r1073005648 ## gobblin-service/src/main/java/org/apache/gobblin/service/monitoring/KafkaAvroJobStatusMonitor.java: ## @@ -65,9 +65,9 @@ public class KafkaAvroJobStatusMonitor exten

[jira] [Work logged] (GOBBLIN-1764) Emit GaaSObservabilityEvent

2023-01-17 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/GOBBLIN-1764?focusedWorklogId=839804&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-839804 ] ASF GitHub Bot logged work on GOBBLIN-1764: --- Author: ASF GitHub B

[GitHub] [gobblin] Will-Lo commented on a diff in pull request #3623: [GOBBLIN-1764] Emit observability event

2023-01-17 Thread GitBox
Will-Lo commented on code in PR #3623: URL: https://github.com/apache/gobblin/pull/3623#discussion_r1073002292 ## gobblin-service/src/main/java/org/apache/gobblin/service/monitoring/GaaSObservabilityEventProducer.java: ## @@ -0,0 +1,149 @@ +/* + * Licensed to the Apache Software

[GitHub] [gobblin] Will-Lo commented on a diff in pull request #3623: [GOBBLIN-1764] Emit observability event

2023-01-17 Thread GitBox
Will-Lo commented on code in PR #3623: URL: https://github.com/apache/gobblin/pull/3623#discussion_r1073002292 ## gobblin-service/src/main/java/org/apache/gobblin/service/monitoring/GaaSObservabilityEventProducer.java: ## @@ -0,0 +1,149 @@ +/* + * Licensed to the Apache Software

[jira] [Work logged] (GOBBLIN-1764) Emit GaaSObservabilityEvent

2023-01-17 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/GOBBLIN-1764?focusedWorklogId=839802&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-839802 ] ASF GitHub Bot logged work on GOBBLIN-1764: --- Author: ASF GitHub B

[jira] [Work logged] (GOBBLIN-1764) Emit GaaSObservabilityEvent

2023-01-17 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/GOBBLIN-1764?focusedWorklogId=839803&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-839803 ] ASF GitHub Bot logged work on GOBBLIN-1764: --- Author: ASF GitHub B

[GitHub] [gobblin] Will-Lo commented on a diff in pull request #3623: [GOBBLIN-1764] Emit observability event

2023-01-17 Thread GitBox
Will-Lo commented on code in PR #3623: URL: https://github.com/apache/gobblin/pull/3623#discussion_r1073001902 ## gobblin-service/src/main/java/org/apache/gobblin/service/monitoring/GaaSObservabilityEventProducer.java: ## @@ -0,0 +1,149 @@ +/* + * Licensed to the Apache Software

[jira] [Work logged] (GOBBLIN-1766) Define metric to measure lag from producing to consume change stream events

2023-01-17 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/GOBBLIN-1766?focusedWorklogId=839795&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-839795 ] ASF GitHub Bot logged work on GOBBLIN-1766: --- Author: ASF GitHub B

[GitHub] [gobblin] phet commented on a diff in pull request #3625: [GOBBLIN-1766] Define metric to measure lag from producing to consume…

2023-01-17 Thread GitBox
phet commented on code in PR #3625: URL: https://github.com/apache/gobblin/pull/3625#discussion_r1072969190 ## gobblin-service/src/main/java/org/apache/gobblin/service/monitoring/SpecStoreChangeMonitor.java: ## @@ -171,5 +178,6 @@ protected void createMetrics() { this.delet

[jira] [Work logged] (GOBBLIN-1766) Define metric to measure lag from producing to consume change stream events

2023-01-17 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/GOBBLIN-1766?focusedWorklogId=839794&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-839794 ] ASF GitHub Bot logged work on GOBBLIN-1766: --- Author: ASF GitHub B

[GitHub] [gobblin] phet commented on a diff in pull request #3625: [GOBBLIN-1766] Define metric to measure lag from producing to consume…

2023-01-17 Thread GitBox
phet commented on code in PR #3625: URL: https://github.com/apache/gobblin/pull/3625#discussion_r1072949890 ## gobblin-metrics-libs/gobblin-metrics-base/src/main/avro/GenericStoreChangeEvent.avsc: ## @@ -9,9 +9,14 @@ "doc" : "Primary key for the store", "compliance" :

[jira] [Work logged] (GOBBLIN-1764) Emit GaaSObservabilityEvent

2023-01-17 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/GOBBLIN-1764?focusedWorklogId=839791&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-839791 ] ASF GitHub Bot logged work on GOBBLIN-1764: --- Author: ASF GitHub B

[jira] [Work logged] (GOBBLIN-1764) Emit GaaSObservabilityEvent

2023-01-17 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/GOBBLIN-1764?focusedWorklogId=839790&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-839790 ] ASF GitHub Bot logged work on GOBBLIN-1764: --- Author: ASF GitHub B

[GitHub] [gobblin] Will-Lo commented on a diff in pull request #3623: [GOBBLIN-1764] Emit observability event

2023-01-17 Thread GitBox
Will-Lo commented on code in PR #3623: URL: https://github.com/apache/gobblin/pull/3623#discussion_r1072967326 ## gobblin-service/src/main/java/org/apache/gobblin/service/monitoring/GaaSObservabilityEventProducer.java: ## @@ -0,0 +1,149 @@ +/* + * Licensed to the Apache Software

[GitHub] [gobblin] Will-Lo commented on a diff in pull request #3623: [GOBBLIN-1764] Emit observability event

2023-01-17 Thread GitBox
Will-Lo commented on code in PR #3623: URL: https://github.com/apache/gobblin/pull/3623#discussion_r1072966969 ## gobblin-service/src/main/java/org/apache/gobblin/service/monitoring/KafkaJobStatusMonitor.java: ## @@ -219,7 +229,8 @@ protected void processMessage(DecodeableKafka

[jira] [Work logged] (GOBBLIN-1764) Emit GaaSObservabilityEvent

2023-01-17 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/GOBBLIN-1764?focusedWorklogId=839789&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-839789 ] ASF GitHub Bot logged work on GOBBLIN-1764: --- Author: ASF GitHub B

[GitHub] [gobblin] Will-Lo commented on a diff in pull request #3623: [GOBBLIN-1764] Emit observability event

2023-01-17 Thread GitBox
Will-Lo commented on code in PR #3623: URL: https://github.com/apache/gobblin/pull/3623#discussion_r1072966717 ## gobblin-service/src/main/java/org/apache/gobblin/service/monitoring/KafkaJobStatusMonitor.java: ## @@ -136,6 +140,12 @@ public void onRetry(Attempt attempt) {

[jira] [Work logged] (GOBBLIN-1764) Emit GaaSObservabilityEvent

2023-01-17 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/GOBBLIN-1764?focusedWorklogId=839788&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-839788 ] ASF GitHub Bot logged work on GOBBLIN-1764: --- Author: ASF GitHub B

[jira] [Work logged] (GOBBLIN-1764) Emit GaaSObservabilityEvent

2023-01-17 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/GOBBLIN-1764?focusedWorklogId=839783&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-839783 ] ASF GitHub Bot logged work on GOBBLIN-1764: --- Author: ASF GitHub B

[GitHub] [gobblin] Will-Lo commented on a diff in pull request #3623: [GOBBLIN-1764] Emit observability event

2023-01-17 Thread GitBox
Will-Lo commented on code in PR #3623: URL: https://github.com/apache/gobblin/pull/3623#discussion_r1072965455 ## gobblin-service/src/test/java/org/apache/gobblin/service/monitoring/GaaSObservabilityProducerTest.java: ## @@ -0,0 +1,100 @@ +/* + * Licensed to the Apache Software

[GitHub] [gobblin] Will-Lo commented on a diff in pull request #3623: [GOBBLIN-1764] Emit observability event

2023-01-17 Thread GitBox
Will-Lo commented on code in PR #3623: URL: https://github.com/apache/gobblin/pull/3623#discussion_r1072965138 ## gobblin-runtime/src/main/java/org/apache/gobblin/runtime/troubleshooter/JobIssueEventHandler.java: ## @@ -50,6 +51,7 @@ public class JobIssueEventHandler { privat

[jira] [Work logged] (GOBBLIN-1766) Define metric to measure lag from producing to consume change stream events

2023-01-17 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/GOBBLIN-1766?focusedWorklogId=839768&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-839768 ] ASF GitHub Bot logged work on GOBBLIN-1766: --- Author: ASF GitHub B

[GitHub] [gobblin] ZihanLi58 commented on a diff in pull request #3625: [GOBBLIN-1766] Define metric to measure lag from producing to consume…

2023-01-17 Thread GitBox
ZihanLi58 commented on code in PR #3625: URL: https://github.com/apache/gobblin/pull/3625#discussion_r1072860103 ## gobblin-service/src/main/java/org/apache/gobblin/service/monitoring/DagActionStoreChangeMonitor.java: ## @@ -98,18 +102,20 @@ protected void processMessage(Decodea

[jira] [Work logged] (GOBBLIN-1759) More robust logging when attempting to resolve a flow config

2023-01-17 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/GOBBLIN-1759?focusedWorklogId=839757&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-839757 ] ASF GitHub Bot logged work on GOBBLIN-1759: --- Author: ASF GitHub B

[GitHub] [gobblin] Will-Lo commented on a diff in pull request #3614: [GOBBLIN-1759] Add error reporting when attempting to resolve flow configs

2023-01-17 Thread GitBox
Will-Lo commented on code in PR #3614: URL: https://github.com/apache/gobblin/pull/3614#discussion_r1072710897 ## gobblin-service/src/main/java/org/apache/gobblin/service/modules/flowgraph/DatasetDescriptorErrorUtils.java: ## @@ -0,0 +1,104 @@ +/* + * Licensed to the Apache Soft

[jira] [Work logged] (GOBBLIN-1759) More robust logging when attempting to resolve a flow config

2023-01-17 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/GOBBLIN-1759?focusedWorklogId=839756&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-839756 ] ASF GitHub Bot logged work on GOBBLIN-1759: --- Author: ASF GitHub B

[GitHub] [gobblin] Will-Lo commented on a diff in pull request #3614: [GOBBLIN-1759] Add error reporting when attempting to resolve flow configs

2023-01-17 Thread GitBox
Will-Lo commented on code in PR #3614: URL: https://github.com/apache/gobblin/pull/3614#discussion_r1072709823 ## gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-server/src/main/java/org/apache/gobblin/service/FlowConfigV2ResourceLocalHandler.java: ## @@ -

[jira] [Work logged] (GOBBLIN-1759) More robust logging when attempting to resolve a flow config

2023-01-17 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/GOBBLIN-1759?focusedWorklogId=839755&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-839755 ] ASF GitHub Bot logged work on GOBBLIN-1759: --- Author: ASF GitHub B

[GitHub] [gobblin] Will-Lo commented on a diff in pull request #3614: [GOBBLIN-1759] Add error reporting when attempting to resolve flow configs

2023-01-17 Thread GitBox
Will-Lo commented on code in PR #3614: URL: https://github.com/apache/gobblin/pull/3614#discussion_r1068845916 ## gobblin-service/src/main/java/org/apache/gobblin/service/modules/template/StaticFlowTemplate.java: ## @@ -56,6 +57,8 @@ @Slf4j public class StaticFlowTemplate impl

[jira] [Work logged] (GOBBLIN-1764) Emit GaaSObservabilityEvent

2023-01-17 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/GOBBLIN-1764?focusedWorklogId=839752&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-839752 ] ASF GitHub Bot logged work on GOBBLIN-1764: --- Author: ASF GitHub B

[GitHub] [gobblin] arjun4084346 commented on pull request #3623: [GOBBLIN-1764] Emit observability event

2023-01-17 Thread GitBox
arjun4084346 commented on PR #3623: URL: https://github.com/apache/gobblin/pull/3623#issuecomment-1385907611 I read the description of the PR, can you please elaborate more what benefit GaaSObservabilityEvents has over a GobblinTrackingEvent with name="GaaSObservabilityEvent". How is it mor

[jira] [Work logged] (GOBBLIN-1764) Emit GaaSObservabilityEvent

2023-01-17 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/GOBBLIN-1764?focusedWorklogId=839723&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-839723 ] ASF GitHub Bot logged work on GOBBLIN-1764: --- Author: ASF GitHub B

[GitHub] [gobblin] Will-Lo commented on a diff in pull request #3623: [GOBBLIN-1764] Emit observability event

2023-01-17 Thread GitBox
Will-Lo commented on code in PR #3623: URL: https://github.com/apache/gobblin/pull/3623#discussion_r1072534871 ## gobblin-service/src/main/java/org/apache/gobblin/service/monitoring/KafkaJobStatusMonitor.java: ## @@ -288,6 +303,15 @@ private static void modifyStateIfRetryRequir