[jira] [Created] (GOBBLIN-1195) Close the writer when a fork is done

Hung Tran created GOBBLIN-1195: -- Summary: Close the writer when a fork is done Key: GOBBLIN-1195 URL: https://issues.apache.org/jira/browse/GOBBLIN-1195 Project: Apache Gobblin Issue Type: Impro

[jira] [Work logged] (GOBBLIN-1192) Container commit suicide if Helix task creation failed after retry

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

[jira] [Work logged] (GOBBLIN-1193) Ensure that ingestion latency is 0 when no records are consumed by Kafka Extractor

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

[jira] [Work logged] (GOBBLIN-1193) Ensure that ingestion latency is 0 when no records are consumed by Kafka Extractor

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

[jira] [Work logged] (GOBBLIN-1193) Ensure that ingestion latency is 0 when no records are consumed by Kafka Extractor

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

[jira] [Work logged] (GOBBLIN-1196) add support to search flow configs using multiple configs and other params

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

[GitHub] [incubator-gobblin] jack-moseley commented on a change in pull request #3042: [GOBBLIN-1196] search flow configs using flow properties and/or other parameters

jack-moseley commented on a change in pull request #3042: URL: https://github.com/apache/incubator-gobblin/pull/3042#discussion_r440511681 ## File path: gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-client/src/main/java/org/apache/gobblin/service/FlowConfigV2C

[jira] [Work logged] (GOBBLIN-1193) Ensure that ingestion latency is 0 when no records are consumed by Kafka Extractor

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

[jira] [Work logged] (GOBBLIN-1193) Ensure that ingestion latency is 0 when no records are consumed by Kafka Extractor

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

[jira] [Work logged] (GOBBLIN-1143) Add a generic wrapper producer client to communicate with Kafka

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

[jira] [Created] (GOBBLIN-1197) Fix race contention among different tests for port allocation

Lei Sun created GOBBLIN-1197: Summary: Fix race contention among different tests for port allocation Key: GOBBLIN-1197 URL: https://issues.apache.org/jira/browse/GOBBLIN-1197 Project: Apache Gobblin

[jira] [Work logged] (GOBBLIN-1197) Fix race contention among different tests for port allocation

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

[jira] [Work logged] (GOBBLIN-1127) Provide an option to make metric reporting instantiation failures fatal

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

[GitHub] [incubator-gobblin] codecov-commenter edited a comment on pull request #3042: [GOBBLIN-1196] search flow configs using flow properties and/or other parameters

codecov-commenter edited a comment on pull request #3042: URL: https://github.com/apache/incubator-gobblin/pull/3042#issuecomment-644437989 # [Codecov](https://codecov.io/gh/apache/incubator-gobblin/pull/3042?src=pr&el=h1) Report > Merging [#3042](https://codecov.io/gh/apache/incubato

[GitHub] [incubator-gobblin] sv2000 commented on a change in pull request #3042: [GOBBLIN-1196] search flow configs using flow properties and/or other parameters

sv2000 commented on a change in pull request #3042: URL: https://github.com/apache/incubator-gobblin/pull/3042#discussion_r440893024 ## File path: gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/FlowSpec.java ## @@ -411,5 +419,43 @@ public static String getFlowGro

[jira] [Work logged] (GOBBLIN-1196) add support to search flow configs using multiple configs and other params

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

[GitHub] [incubator-gobblin] arjun4084346 commented on a change in pull request #3042: [GOBBLIN-1196] search flow configs using flow properties and/or other parameters

arjun4084346 commented on a change in pull request #3042: URL: https://github.com/apache/incubator-gobblin/pull/3042#discussion_r440908142 ## File path: gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_catalog/FlowCatalog.java ## @@ -269,23 +270,40 @@ public boole

[jira] [Work logged] (GOBBLIN-1196) add support to search flow configs using multiple configs and other params

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

[jira] [Work logged] (GOBBLIN-1196) add support to search flow configs using multiple configs and other params

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

[GitHub] [incubator-gobblin] arjun4084346 commented on a change in pull request #3042: [GOBBLIN-1196] search flow configs using flow properties and/or other parameters

arjun4084346 commented on a change in pull request #3042: URL: https://github.com/apache/incubator-gobblin/pull/3042#discussion_r440910388 ## File path: gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/SpecSearchObject.java ## @@ -0,0 +1,24 @@ +/* + * Licensed to t

[jira] [Work logged] (GOBBLIN-1193) Ensure that ingestion latency is 0 when no records are consumed by Kafka Extractor

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

[jira] [Work logged] (GOBBLIN-1193) Ensure that ingestion latency is 0 when no records are consumed by Kafka Extractor

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

[jira] [Work logged] (GOBBLIN-1193) Ensure that ingestion latency is 0 when no records are consumed by Kafka Extractor

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

[jira] [Work logged] (GOBBLIN-1192) Container commit suicide if Helix task creation failed after retry

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

[jira] [Created] (GOBBLIN-1198) use DatasetCleanerTask to clean job status

Arjun Singh Bora created GOBBLIN-1198: - Summary: use DatasetCleanerTask to clean job status Key: GOBBLIN-1198 URL: https://issues.apache.org/jira/browse/GOBBLIN-1198 Project: Apache Gobblin

[jira] [Work logged] (GOBBLIN-1198) use DatasetCleanerTask to clean job status

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

[GitHub] [incubator-gobblin] arjun4084346 opened a new pull request #3044: [GOBBLIN-1198] use DatasetCleanerTask to clean job status

arjun4084346 opened a new pull request #3044: URL: https://github.com/apache/incubator-gobblin/pull/3044 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 - [x] My PR address

[jira] [Work logged] (GOBBLIN-1196) add support to search flow configs using multiple configs and other params

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

[jira] [Created] (GOBBLIN-1196) add support to search flow configs using multiple configs and other params

Arjun Singh Bora created GOBBLIN-1196: - Summary: add support to search flow configs using multiple configs and other params Key: GOBBLIN-1196 URL: https://issues.apache.org/jira/browse/GOBBLIN-1196

[jira] [Work logged] (GOBBLIN-1193) Ensure that ingestion latency is 0 when no records are consumed by Kafka Extractor

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

[jira] [Work logged] (GOBBLIN-1193) Ensure that ingestion latency is 0 when no records are consumed by Kafka Extractor

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

[jira] [Work logged] (GOBBLIN-1193) Ensure that ingestion latency is 0 when no records are consumed by Kafka Extractor

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

[jira] [Work logged] (GOBBLIN-1193) Ensure that ingestion latency is 0 when no records are consumed by Kafka Extractor

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

[jira] [Work logged] (GOBBLIN-1143) Add a generic wrapper producer client to communicate with Kafka

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

[GitHub] [incubator-gobblin] arjun4084346 opened a new pull request #3045: convert seconds to ms because helix api take time in ms

arjun4084346 opened a new pull request #3045: URL: https://github.com/apache/incubator-gobblin/pull/3045 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 address

[GitHub] [incubator-gobblin] asfgit closed pull request #3035: [GOBBLIN-1127] Provide an option to make metric reporting instantiation failure fatal

asfgit closed pull request #3035: URL: https://github.com/apache/incubator-gobblin/pull/3035 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

[jira] [Work logged] (GOBBLIN-1127) Provide an option to make metric reporting instantiation failures fatal

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

[GitHub] [incubator-gobblin] codecov-commenter commented on pull request #3044: [GOBBLIN-1198] use DatasetCleanerTask to clean job status

codecov-commenter commented on pull request #3044: URL: https://github.com/apache/incubator-gobblin/pull/3044#issuecomment-644901118 # [Codecov](https://codecov.io/gh/apache/incubator-gobblin/pull/3044?src=pr&el=h1) Report > Merging [#3044](https://codecov.io/gh/apache/incubator-gobbl

[jira] [Work logged] (GOBBLIN-1198) use DatasetCleanerTask to clean job status

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

[jira] [Work logged] (GOBBLIN-1187) cancel a gaas flow when the dag manager is disabled

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

[GitHub] [incubator-gobblin] autumnust commented on a change in pull request #3027: [GOBBLIN-1187] cancel flow execution when dag manager is disabled

autumnust commented on a change in pull request #3027: URL: https://github.com/apache/incubator-gobblin/pull/3027#discussion_r441108741 ## File path: gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_monitor/KafkaJobMonitor.java ## @@ -100,17 +101,29 @@ protected vo

[jira] [Work logged] (GOBBLIN-1187) cancel a gaas flow when the dag manager is disabled

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

[GitHub] [incubator-gobblin] arjun4084346 commented on a change in pull request #3027: [GOBBLIN-1187] cancel flow execution when dag manager is disabled

arjun4084346 commented on a change in pull request #3027: URL: https://github.com/apache/incubator-gobblin/pull/3027#discussion_r441110026 ## File path: gobblin-modules/gobblin-kafka-09/build.gradle ## @@ -87,6 +87,9 @@ artifacts { } test { + // this module's test cases ha

[GitHub] [incubator-gobblin] arjun4084346 commented on a change in pull request #3027: [GOBBLIN-1187] cancel flow execution when dag manager is disabled

arjun4084346 commented on a change in pull request #3027: URL: https://github.com/apache/incubator-gobblin/pull/3027#discussion_r441115099 ## File path: gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_monitor/KafkaJobMonitor.java ## @@ -100,17 +101,29 @@ protected

[jira] [Work logged] (GOBBLIN-1187) cancel a gaas flow when the dag manager is disabled

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

[GitHub] [incubator-gobblin] arjun4084346 commented on a change in pull request #3027: [GOBBLIN-1187] cancel flow execution when dag manager is disabled

arjun4084346 commented on a change in pull request #3027: URL: https://github.com/apache/incubator-gobblin/pull/3027#discussion_r441117149 ## File path: gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_monitor/AvroJobSpecKafkaJobMonitor.java ## @@ -127,17 +121,10 @

[jira] [Work logged] (GOBBLIN-1187) cancel a gaas flow when the dag manager is disabled

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

[jira] [Work logged] (GOBBLIN-1187) cancel a gaas flow when the dag manager is disabled

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

[GitHub] [incubator-gobblin] arjun4084346 commented on a change in pull request #3027: [GOBBLIN-1187] cancel flow execution when dag manager is disabled

arjun4084346 commented on a change in pull request #3027: URL: https://github.com/apache/incubator-gobblin/pull/3027#discussion_r441117149 ## File path: gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_monitor/AvroJobSpecKafkaJobMonitor.java ## @@ -127,17 +121,10 @

[GitHub] [incubator-gobblin] arjun4084346 commented on a change in pull request #3027: [GOBBLIN-1187] cancel flow execution when dag manager is disabled

arjun4084346 commented on a change in pull request #3027: URL: https://github.com/apache/incubator-gobblin/pull/3027#discussion_r441128943 ## File path: gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_monitor/KafkaJobMonitor.java ## @@ -100,17 +101,29 @@ protected

[jira] [Work logged] (GOBBLIN-1187) cancel a gaas flow when the dag manager is disabled

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

[jira] [Created] (GOBBLIN-1199) convert seconds to ms because helix api take time in ms

Arjun Singh Bora created GOBBLIN-1199: - Summary: convert seconds to ms because helix api take time in ms Key: GOBBLIN-1199 URL: https://issues.apache.org/jira/browse/GOBBLIN-1199 Project: Apache Go

[GitHub] [incubator-gobblin] arjun4084346 closed pull request #3045: [GOBBLIN-1199] convert seconds to ms because helix api take time in ms

arjun4084346 closed pull request #3045: URL: https://github.com/apache/incubator-gobblin/pull/3045 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[jira] [Work logged] (GOBBLIN-1199) convert seconds to ms because helix api take time in ms

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

[jira] [Work logged] (GOBBLIN-1199) convert seconds to ms because helix api take time in ms

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

[jira] [Work logged] (GOBBLIN-1199) convert seconds to ms because helix api take time in ms

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

[GitHub] [incubator-gobblin] codecov-commenter commented on pull request #3045: [GOBBLIN-1199] convert seconds to ms because helix api take time in ms

codecov-commenter commented on pull request #3045: URL: https://github.com/apache/incubator-gobblin/pull/3045#issuecomment-645019159 # [Codecov](https://codecov.io/gh/apache/incubator-gobblin/pull/3045?src=pr&el=h1) Report > Merging [#3045](https://codecov.io/gh/apache/incubator-gobbl

[GitHub] [incubator-gobblin] autumnust opened a new pull request #3046: [WIP] Fix test concurrency

autumnust opened a new pull request #3046: URL: https://github.com/apache/incubator-gobblin/pull/3046 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