[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:

[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=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-446239 ] ASF GitHub Bot logged work on GOBBLIN-1143: --- Author: ASF GitHub Bot

[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=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-446298 ] ASF GitHub Bot logged work on GOBBLIN-1197: --- Author: ASF GitHub Bot

[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=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-446282 ] ASF GitHub Bot logged work on GOBBLIN-1192: --- Author: ASF GitHub Bot

[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=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-446199 ] ASF GitHub Bot logged work on GOBBLIN-1193: --- Author: ASF GitHub Bot

[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=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-446156 ] ASF GitHub Bot logged work on GOBBLIN-1193: --- Author: ASF GitHub Bot

[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=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-446157 ] ASF GitHub Bot logged work on GOBBLIN-1193: --- Author: ASF GitHub Bot

[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=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-446348 ] ASF GitHub Bot logged work on GOBBLIN-1196: --- Author: ASF GitHub Bot

[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:

[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=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-446200 ] ASF GitHub Bot logged work on GOBBLIN-1193: --- Author: ASF GitHub Bot

[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=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-446160 ] ASF GitHub Bot logged work on GOBBLIN-1193: --- Author: ASF GitHub Bot

[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=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-446213 ] ASF GitHub Bot logged work on GOBBLIN-1127: --- Author: ASF GitHub Bot

[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=h1) Report > Merging

[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=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-446393 ] ASF GitHub Bot logged work on GOBBLIN-1196: --- Author: ASF GitHub Bot

[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=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-446551 ] ASF GitHub Bot logged work on GOBBLIN-1196: --- Author: ASF GitHub Bot

[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=446174=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-446174 ] ASF GitHub Bot logged work on GOBBLIN-1193: --- Author: ASF GitHub Bot

[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=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-446175 ] ASF GitHub Bot logged work on GOBBLIN-1193: --- Author: ASF GitHub Bot

[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

[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=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-446555 ] ASF GitHub Bot logged work on GOBBLIN-1196: --- Author: ASF GitHub Bot

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

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

[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

[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=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-446117 ] ASF GitHub Bot logged work on GOBBLIN-1193: --- Author: ASF GitHub Bot

[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=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-446118 ] ASF GitHub Bot logged work on GOBBLIN-1193: --- Author: ASF GitHub Bot

[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

[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-1196) add support to search flow configs using multiple configs and other params

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

[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

[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=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-446164 ] ASF GitHub Bot logged work on GOBBLIN-1193: --- Author: ASF GitHub Bot

[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=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-446078 ] ASF GitHub Bot logged work on GOBBLIN-1193: --- Author: ASF GitHub Bot

[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=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-446077 ] ASF GitHub Bot logged work on GOBBLIN-1193: --- Author: ASF GitHub Bot

[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=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-446165 ] ASF GitHub Bot logged work on GOBBLIN-1192: --- Author: ASF GitHub Bot

[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

[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=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-446758 ] ASF GitHub Bot logged work on GOBBLIN-1127: --- Author: ASF GitHub Bot

[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=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-446240 ] ASF GitHub Bot logged work on GOBBLIN-1143: --- Author: ASF GitHub Bot

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

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

[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=h1) Report > Merging

[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=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-446863 ] ASF GitHub Bot logged work on GOBBLIN-1187: --- Author: ASF GitHub Bot

[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

[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

[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=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-446864 ] ASF GitHub Bot logged work on GOBBLIN-1187: --- Author: ASF GitHub Bot

[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=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-446920 ] ASF GitHub Bot logged work on GOBBLIN-1199: --- Author: ASF GitHub Bot

[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=h1) Report > Merging

[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 @@

[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

[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=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-446867 ] ASF GitHub Bot logged work on GOBBLIN-1187: --- Author: ASF GitHub Bot

[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=446870=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-446870 ] ASF GitHub Bot logged work on GOBBLIN-1187: --- Author: ASF GitHub Bot

[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=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-446872 ] ASF GitHub Bot logged work on GOBBLIN-1187: --- Author: ASF GitHub Bot

[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 @@

[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=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-446890 ] ASF GitHub Bot logged work on GOBBLIN-1187: --- Author: ASF GitHub Bot

[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=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-446898 ] ASF GitHub Bot logged work on GOBBLIN-1199: --- Author: ASF GitHub Bot

[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=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-446897 ] ASF GitHub Bot logged work on GOBBLIN-1199: --- Author: ASF GitHub Bot

[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