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

[ https://issues.apache.org/jira/browse/GOBBLIN-1766?focusedWorklogId=840505&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-840505 ] 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…

phet commented on code in PR #3625: URL: https://github.com/apache/gobblin/pull/3625#discussion_r1082123322 ## gobblin-service/src/main/java/org/apache/gobblin/service/monitoring/DagActionStoreChangeMonitor.java: ## @@ -98,18 +102,20 @@ protected void processMessage(DecodeableKa

[GitHub] [gobblin] codecov-commenter commented on pull request #3627: Specifically name each Hikari connection pool created, for traceability

codecov-commenter commented on PR #3627: URL: https://github.com/apache/gobblin/pull/3627#issuecomment-1397906097 # [Codecov](https://codecov.io/gh/apache/gobblin/pull/3627?src=pr&el=h1&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+Sof

[GitHub] [gobblin] phet opened a new pull request, #3627: Specifically name each Hikari connection pool created, for traceability

phet opened a new pull request, #3627: URL: https://github.com/apache/gobblin/pull/3627 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] [Work logged] (GOBBLIN-1765) Add support to sync metadata for dir in manifest based copy

[ https://issues.apache.org/jira/browse/GOBBLIN-1765?focusedWorklogId=840478&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-840478 ] ASF GitHub Bot logged work on GOBBLIN-1765: --- Author: ASF GitHub B

[GitHub] [gobblin] ZihanLi58 commented on a diff in pull request #3624: [GOBBLIN-1765] Add support to sync metadata for dir in manifest based copy

ZihanLi58 commented on code in PR #3624: URL: https://github.com/apache/gobblin/pull/3624#discussion_r1081946270 ## gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/CopyableFile.java: ## @@ -316,23 +316,33 @@ private List replicateAncestorsOwnerAndP

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

[ https://issues.apache.org/jira/browse/GOBBLIN-1759?focusedWorklogId=840455&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-840455 ] ASF GitHub Bot logged work on GOBBLIN-1759: --- Author: ASF GitHub B

[GitHub] [gobblin] Will-Lo merged pull request #3614: [GOBBLIN-1759] Add error reporting when attempting to resolve flow configs

Will-Lo merged PR #3614: URL: https://github.com/apache/gobblin/pull/3614 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: dev-unsubscr...@gobblin.apache

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

[ https://issues.apache.org/jira/browse/GOBBLIN-1766?focusedWorklogId=840451&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-840451 ] ASF GitHub Bot logged work on GOBBLIN-1766: --- Author: ASF GitHub B

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

umustafi commented on code in PR #3625: URL: https://github.com/apache/gobblin/pull/3625#discussion_r1081842299 ## gobblin-service/src/main/java/org/apache/gobblin/service/monitoring/DagActionStoreChangeMonitor.java: ## @@ -176,6 +185,7 @@ protected void createMetrics() { t

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

[ https://issues.apache.org/jira/browse/GOBBLIN-1766?focusedWorklogId=840449&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-840449 ] ASF GitHub Bot logged work on GOBBLIN-1766: --- Author: ASF GitHub B

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

umustafi commented on code in PR #3625: URL: https://github.com/apache/gobblin/pull/3625#discussion_r1081826513 ## gobblin-service/src/main/java/org/apache/gobblin/service/monitoring/DagActionStoreChangeMonitor.java: ## @@ -98,18 +102,20 @@ protected void processMessage(Decodeab

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

[ https://issues.apache.org/jira/browse/GOBBLIN-1766?focusedWorklogId=840448&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-840448 ] ASF GitHub Bot logged work on GOBBLIN-1766: --- Author: ASF GitHub B

[jira] [Work logged] (GOBBLIN-1612) Add description about downloading gradle wrapper

[ https://issues.apache.org/jira/browse/GOBBLIN-1612?focusedWorklogId=840447&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-840447 ] ASF GitHub Bot logged work on GOBBLIN-1612: --- Author: ASF GitHub B

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

umustafi commented on code in PR #3625: URL: https://github.com/apache/gobblin/pull/3625#discussion_r1081821627 ## gobblin-runtime/src/main/java/org/apache/gobblin/runtime/metrics/RuntimeMetrics.java: ## @@ -36,15 +36,17 @@ public class RuntimeMetrics { public static final St

[GitHub] [gobblin] Will-Lo merged pull request #3471: [GOBBLIN-1612] Add description about downloading gradle wrapper

Will-Lo merged PR #3471: URL: https://github.com/apache/gobblin/pull/3471 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: dev-unsubscr...@gobblin.apache

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

[ https://issues.apache.org/jira/browse/GOBBLIN-1766?focusedWorklogId=840446&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-840446 ] 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…

phet commented on code in PR #3625: URL: https://github.com/apache/gobblin/pull/3625#discussion_r1081820136 ## gobblin-runtime/src/main/java/org/apache/gobblin/runtime/kafka/HighLevelConsumer.java: ## @@ -333,4 +333,8 @@ public void run() { } } } + + public Long

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

[ https://issues.apache.org/jira/browse/GOBBLIN-1764?focusedWorklogId=840438&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-840438 ] ASF GitHub Bot logged work on GOBBLIN-1764: --- Author: ASF GitHub B

[GitHub] [gobblin] Will-Lo merged pull request #3623: [GOBBLIN-1764] Emit observability event

Will-Lo merged PR #3623: URL: https://github.com/apache/gobblin/pull/3623 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: dev-unsubscr...@gobblin.apache

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

[ https://issues.apache.org/jira/browse/GOBBLIN-1766?focusedWorklogId=840415&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-840415 ] ASF GitHub Bot logged work on GOBBLIN-1766: --- Author: ASF GitHub B

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

umustafi commented on code in PR #3625: URL: https://github.com/apache/gobblin/pull/3625#discussion_r1081680380 ## gobblin-runtime/src/main/java/org/apache/gobblin/runtime/kafka/HighLevelConsumer.java: ## @@ -333,4 +333,8 @@ public void run() { } } } + + public L

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

[ https://issues.apache.org/jira/browse/GOBBLIN-1766?focusedWorklogId=840394&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-840394 ] ASF GitHub Bot logged work on GOBBLIN-1766: --- Author: ASF GitHub B

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

umustafi commented on code in PR #3625: URL: https://github.com/apache/gobblin/pull/3625#discussion_r1081645025 ## 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-1766) Define metric to measure lag from producing to consume change stream events

[ https://issues.apache.org/jira/browse/GOBBLIN-1766?focusedWorklogId=840228&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-840228 ] 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…

phet commented on code in PR #3625: URL: https://github.com/apache/gobblin/pull/3625#discussion_r1081058477 ## gobblin-runtime/src/main/java/org/apache/gobblin/runtime/kafka/HighLevelConsumer.java: ## @@ -333,4 +333,8 @@ public void run() { } } } + + public Long

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

[ https://issues.apache.org/jira/browse/GOBBLIN-1764?focusedWorklogId=840208&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-840208 ] ASF GitHub Bot logged work on GOBBLIN-1764: --- Author: ASF GitHub B

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

phet commented on code in PR #3623: URL: https://github.com/apache/gobblin/pull/3623#discussion_r1081035824 ## gobblin-modules/gobblin-kafka-09/src/test/java/org/apache/gobblin/runtime/KafkaAvroJobStatusMonitorTest.java: ## @@ -618,6 +728,7 @@ public org.apache.gobblin.configura

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

[ https://issues.apache.org/jira/browse/GOBBLIN-1764?focusedWorklogId=840201&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-840201 ] ASF GitHub Bot logged work on GOBBLIN-1764: --- Author: ASF GitHub B

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

[ https://issues.apache.org/jira/browse/GOBBLIN-1764?focusedWorklogId=840199&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-840199 ] ASF GitHub Bot logged work on GOBBLIN-1764: --- Author: ASF GitHub B

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

phet commented on code in PR #3623: URL: https://github.com/apache/gobblin/pull/3623#discussion_r1081033861 ## gobblin-modules/gobblin-kafka-09/src/test/java/org/apache/gobblin/runtime/KafkaAvroJobStatusMonitorTest.java: ## @@ -358,6 +370,66 @@ public void testProcessingRetried

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

phet commented on code in PR #3623: URL: https://github.com/apache/gobblin/pull/3623#discussion_r1081029179 ## gobblin-service/src/main/java/org/apache/gobblin/service/monitoring/GaaSObservabilityEventProducer.java: ## @@ -0,0 +1,161 @@ +/* + * Licensed to the Apache Software Fo

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

[ https://issues.apache.org/jira/browse/GOBBLIN-1764?focusedWorklogId=840196&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-840196 ] ASF GitHub Bot logged work on GOBBLIN-1764: --- Author: ASF GitHub B

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

phet commented on code in PR #3623: URL: https://github.com/apache/gobblin/pull/3623#discussion_r1081029179 ## gobblin-service/src/main/java/org/apache/gobblin/service/monitoring/GaaSObservabilityEventProducer.java: ## @@ -0,0 +1,161 @@ +/* + * Licensed to the Apache Software Fo