[jira] [Created] (FLINK-11199) Support interactive programming in Flink

Jiangjie Qin created FLINK-11199: Summary: Support interactive programming in Flink Key: FLINK-11199 URL: https://issues.apache.org/jira/browse/FLINK-11199 Project: Flink Issue Type: New

[jira] [Commented] (FLINK-11912) Expose per partition Kafka lag metric in Flink Kafka connector

[ https://issues.apache.org/jira/browse/FLINK-11912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16808287#comment-16808287 ] Jiangjie Qin commented on FLINK-11912: -- [~suez1224] Thanks for the explanation. Got it. I think

[jira] [Assigned] (FLINK-11682) Add abstract source and sink metric classes.

[ https://issues.apache.org/jira/browse/FLINK-11682?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin reassigned FLINK-11682: Assignee: Jiangjie Qin > Add abstract source and sink metric classes. >

[jira] [Assigned] (FLINK-11683) Implement standard metrics in Kafka connectors.

[ https://issues.apache.org/jira/browse/FLINK-11683?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin reassigned FLINK-11683: Assignee: Jiangjie Qin > Implement standard metrics in Kafka connectors. >

[jira] [Created] (FLINK-11683) Implement standard metrics in Kafka connectors.

Jiangjie Qin created FLINK-11683: Summary: Implement standard metrics in Kafka connectors. Key: FLINK-11683 URL: https://issues.apache.org/jira/browse/FLINK-11683 Project: Flink Issue Type:

[jira] [Created] (FLINK-11682) Add abstract source and sink metric classes.

Jiangjie Qin created FLINK-11682: Summary: Add abstract source and sink metric classes. Key: FLINK-11682 URL: https://issues.apache.org/jira/browse/FLINK-11682 Project: Flink Issue Type:

[jira] [Assigned] (FLINK-11681) Add an AbstractMetric to combine the metric definition and metric management.

[ https://issues.apache.org/jira/browse/FLINK-11681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin reassigned FLINK-11681: Assignee: Jiangjie Qin > Add an AbstractMetric to combine the metric definition and

[jira] [Created] (FLINK-11681) Add an AbstractMetric to combine the metric definition and metric management.

Jiangjie Qin created FLINK-11681: Summary: Add an AbstractMetric to combine the metric definition and metric management. Key: FLINK-11681 URL: https://issues.apache.org/jira/browse/FLINK-11681

[jira] [Updated] (FLINK-11576) FLIP-33: Standardize connector metrics

[ https://issues.apache.org/jira/browse/FLINK-11576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated FLINK-11576: - Description: This is a umbrella ticket for standardize connector metrics. Subtasks will be

[jira] [Commented] (FLINK-11683) Implement standard metrics in Kafka connectors.

[ https://issues.apache.org/jira/browse/FLINK-11683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16774775#comment-16774775 ] Jiangjie Qin commented on FLINK-11683: -- [~HungChang] the metrics are proposed in

[jira] [Created] (FLINK-11893) Update ecosystem page and add it to the navigation bar

Jiangjie Qin created FLINK-11893: Summary: Update ecosystem page and add it to the navigation bar Key: FLINK-11893 URL: https://issues.apache.org/jira/browse/FLINK-11893 Project: Flink Issue

[jira] [Commented] (FLINK-11912) Expose per partition Kafka lag metric in Flink Kafka connector

[ https://issues.apache.org/jira/browse/FLINK-11912?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16796788#comment-16796788 ] Jiangjie Qin commented on FLINK-11912: -- [~suez1224] Thanks for bringing this up. The current

[jira] [Assigned] (FLINK-11893) Update ecosystem page and add it to the navigation bar

[ https://issues.apache.org/jira/browse/FLINK-11893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin reassigned FLINK-11893: Assignee: Jiangjie Qin > Update ecosystem page and add it to the navigation bar >

[jira] [Created] (FLINK-11576) Standardize connector metrics

Jiangjie Qin created FLINK-11576: Summary: Standardize connector metrics Key: FLINK-11576 URL: https://issues.apache.org/jira/browse/FLINK-11576 Project: Flink Issue Type: New Feature

[jira] [Updated] (FLINK-11576) FLIP-33: Standardize connector metrics

[ https://issues.apache.org/jira/browse/FLINK-11576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated FLINK-11576: - Summary: FLIP-33: Standardize connector metrics (was: Standardize connector metrics) >

[jira] [Assigned] (FLINK-11576) Standardize connector metrics

[ https://issues.apache.org/jira/browse/FLINK-11576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin reassigned FLINK-11576: Assignee: Jiangjie Qin > Standardize connector metrics > - >

[jira] [Commented] (FLINK-10455) Potential Kafka producer leak in case of failures

[ https://issues.apache.org/jira/browse/FLINK-10455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16856486#comment-16856486 ] Jiangjie Qin commented on FLINK-10455: -- Some updates. I think the issue here is still producer

[jira] [Commented] (FLINK-10455) Potential Kafka producer leak in case of failures

[ https://issues.apache.org/jira/browse/FLINK-10455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16856494#comment-16856494 ] Jiangjie Qin commented on FLINK-10455: -- Some updates. I think the issue here is still producer

[jira] [Commented] (FLINK-10455) Potential Kafka producer leak in case of failures

[ https://issues.apache.org/jira/browse/FLINK-10455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16851754#comment-16851754 ] Jiangjie Qin commented on FLINK-10455: -- It looks that some further investigation is needed here. I

[jira] [Commented] (FLINK-10455) Potential Kafka producer leak in case of failures

[ https://issues.apache.org/jira/browse/FLINK-10455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16855489#comment-16855489 ] Jiangjie Qin commented on FLINK-10455: -- [~sunjincheng121] Thanks for the help. I am still working

[jira] [Created] (FLINK-12425) Implement RPCs to allow clients release result partitions in a Flink cluster.

Jiangjie Qin created FLINK-12425: Summary: Implement RPCs to allow clients release result partitions in a Flink cluster. Key: FLINK-12425 URL: https://issues.apache.org/jira/browse/FLINK-12425

[jira] [Commented] (FLINK-12425) Implement RPCs to allow clients release result partitions in a Flink cluster.

[ https://issues.apache.org/jira/browse/FLINK-12425?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16835330#comment-16835330 ] Jiangjie Qin commented on FLINK-12425: -- [~yanghua] Thanks for being interested in working on this.

[jira] [Assigned] (FLINK-12425) Implement RPCs to allow clients release result partitions in a Flink cluster.

[ https://issues.apache.org/jira/browse/FLINK-12425?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin reassigned FLINK-12425: Assignee: Ruidong Li > Implement RPCs to allow clients release result partitions in a

[jira] [Created] (FLINK-12352) [FLIP-36] [Phase 1] Support cache() / invalidateCache() in Table with default ShuffleService and NetworkStack

Jiangjie Qin created FLINK-12352: Summary: [FLIP-36] [Phase 1] Support cache() / invalidateCache() in Table with default ShuffleService and NetworkStack Key: FLINK-12352 URL:

[jira] [Updated] (FLINK-12352) [FLIP-36] [Phase 1] Support cache() / invalidateCache() in Table with default ShuffleService and NetworkStack

[ https://issues.apache.org/jira/browse/FLINK-12352?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated FLINK-12352: - Fix Version/s: 1.9.0 > [FLIP-36] [Phase 1] Support cache() / invalidateCache() in Table with

[jira] [Commented] (FLINK-13179) Add document on how to run examples.

[ https://issues.apache.org/jira/browse/FLINK-13179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16882559#comment-16882559 ] Jiangjie Qin commented on FLINK-13179: -- [~rmetzger] the example that I was trying to run was

[jira] [Commented] (FLINK-11793) Make KafkaProducer more resilient to Kafka Broker Failures

[ https://issues.apache.org/jira/browse/FLINK-11793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16882769#comment-16882769 ] Jiangjie Qin commented on FLINK-11793: -- This can probably be done by just make the retry number to

[jira] [Commented] (FLINK-13083) Various improvements PubSub Connector

[ https://issues.apache.org/jira/browse/FLINK-13083?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16882783#comment-16882783 ] Jiangjie Qin commented on FLINK-13083: -- [~Xeli] Just want to check if you have started work on this

[jira] [Updated] (FLINK-13204) The subscribedPartitionStates should be thread safe.

[ https://issues.apache.org/jira/browse/FLINK-13204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated FLINK-13204: - Fix Version/s: (was: 1.9.0) > The subscribedPartitionStates should be thread safe. >

[jira] [Updated] (FLINK-13204) The subscribedPartitionStates should be thread safe.

[ https://issues.apache.org/jira/browse/FLINK-13204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated FLINK-13204: - Affects Version/s: (was: 1.8.0) > The subscribedPartitionStates should be thread safe. >

[jira] [Commented] (FLINK-11792) Make KafkaConsumer more resilient to Kafka Broker Failures

[ https://issues.apache.org/jira/browse/FLINK-11792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16882759#comment-16882759 ] Jiangjie Qin commented on FLINK-11792: -- [~knaufk] This is a little surprising. By design

[jira] [Closed] (FLINK-13204) The subscribedPartitionStates should be thread safe.

[ https://issues.apache.org/jira/browse/FLINK-13204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin closed FLINK-13204. Resolution: Duplicate I was looking at an outdated code base and the issue has been fixed in

[jira] [Closed] (FLINK-11778) Check and update delivery guarantees in Flink docs

[ https://issues.apache.org/jira/browse/FLINK-11778?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin closed FLINK-11778. Resolution: Duplicate > Check and update delivery guarantees in Flink docs >

[jira] [Updated] (FLINK-13204) The subscribedPartitionStates should be thread safe.

[ https://issues.apache.org/jira/browse/FLINK-13204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated FLINK-13204: - Fix Version/s: 1.9.0 > The subscribedPartitionStates should be thread safe. >

[jira] [Updated] (FLINK-11778) Check and update delivery guarantees in Flink docs

[ https://issues.apache.org/jira/browse/FLINK-11778?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated FLINK-11778: - Fix Version/s: 1.9.0 > Check and update delivery guarantees in Flink docs >

[jira] [Created] (FLINK-13204) The subscribedPartitionStates should be thread safe.

Jiangjie Qin created FLINK-13204: Summary: The subscribedPartitionStates should be thread safe. Key: FLINK-13204 URL: https://issues.apache.org/jira/browse/FLINK-13204 Project: Flink Issue

[jira] [Commented] (FLINK-11654) Multiple transactional KafkaProducers writing to same cluster have clashing transaction IDs

[ https://issues.apache.org/jira/browse/FLINK-11654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16882806#comment-16882806 ] Jiangjie Qin commented on FLINK-11654: -- In practice, typically Kafka transaction.ids are assigned

[jira] [Comment Edited] (FLINK-11792) Make KafkaConsumer more resilient to Kafka Broker Failures

[ https://issues.apache.org/jira/browse/FLINK-11792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16883478#comment-16883478 ] Jiangjie Qin edited comment on FLINK-11792 at 7/12/19 2:37 AM: --- [~knaufk]

[jira] [Commented] (FLINK-11792) Make KafkaConsumer more resilient to Kafka Broker Failures

[ https://issues.apache.org/jira/browse/FLINK-11792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16883478#comment-16883478 ] Jiangjie Qin commented on FLINK-11792: -- [~knaufk] Thanks for the explanation. There might be some

[jira] [Comment Edited] (FLINK-11792) Make KafkaConsumer more resilient to Kafka Broker Failures

[ https://issues.apache.org/jira/browse/FLINK-11792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16883478#comment-16883478 ] Jiangjie Qin edited comment on FLINK-11792 at 7/12/19 2:38 AM: --- [~knaufk]

[jira] [Commented] (FLINK-11654) Multiple transactional KafkaProducers writing to same cluster have clashing transaction IDs

[ https://issues.apache.org/jira/browse/FLINK-11654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16883651#comment-16883651 ] Jiangjie Qin commented on FLINK-11654: -- [~pnowojski] Thanks for the explanation. My concern for 

[jira] [Commented] (FLINK-13083) Various improvements PubSub Connector

[ https://issues.apache.org/jira/browse/FLINK-13083?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16883549#comment-16883549 ] Jiangjie Qin commented on FLINK-13083: -- [~Xeli] Thanks for the quick reply. Just a reminder that

[jira] [Commented] (FLINK-11654) Multiple transactional KafkaProducers writing to same cluster have clashing transaction IDs

[ https://issues.apache.org/jira/browse/FLINK-11654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16884267#comment-16884267 ] Jiangjie Qin commented on FLINK-11654: -- [~knaufk] That makes sense. In fact the

[jira] [Comment Edited] (FLINK-11654) Multiple transactional KafkaProducers writing to same cluster have clashing transaction IDs

[ https://issues.apache.org/jira/browse/FLINK-11654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16884267#comment-16884267 ] Jiangjie Qin edited comment on FLINK-11654 at 7/13/19 2:04 AM: --- [~knaufk] 

[jira] [Comment Edited] (FLINK-11736) flink kafka producer failed with NOT_LEADER_FOR_PARTITION

[ https://issues.apache.org/jira/browse/FLINK-11736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16883502#comment-16883502 ] Jiangjie Qin edited comment on FLINK-11736 at 7/12/19 3:50 AM: ---

[jira] [Commented] (FLINK-11736) flink kafka producer failed with NOT_LEADER_FOR_PARTITION

[ https://issues.apache.org/jira/browse/FLINK-11736?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16883502#comment-16883502 ] Jiangjie Qin commented on FLINK-11736: -- [~debugman] NOT_LEADER_FOR_PARTITION indicates that there

[jira] [Commented] (FLINK-11654) Multiple transactional KafkaProducers writing to same cluster have clashing transaction IDs

[ https://issues.apache.org/jira/browse/FLINK-11654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16883503#comment-16883503 ] Jiangjie Qin commented on FLINK-11654: -- [~pnowojski] [~aljoscha] [~dawidwys] [~vicTTim] Do you

[jira] [Commented] (FLINK-10876) Deadlock if closing firstly pending transactions in FlinkKafkaProducer(011).close()

[ https://issues.apache.org/jira/browse/FLINK-10876?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16883518#comment-16883518 ] Jiangjie Qin commented on FLINK-10876: -- Is this still an issue given FLINK-10455 is fixed? Do you

[jira] [Commented] (FLINK-10806) Support multiple consuming offsets when discovering a new topic

[ https://issues.apache.org/jira/browse/FLINK-10806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16883520#comment-16883520 ] Jiangjie Qin commented on FLINK-10806: -- Would setting \{{auto.offset.reset}} for the KafkaConsumer

[jira] [Comment Edited] (FLINK-10806) Support multiple consuming offsets when discovering a new topic

[ https://issues.apache.org/jira/browse/FLINK-10806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16883520#comment-16883520 ] Jiangjie Qin edited comment on FLINK-10806 at 7/12/19 4:31 AM: ---

[jira] [Commented] (FLINK-10636) ERROR org.apache.flink.shaded.curator.org.apache.curator.ConnectionState - Authentication failed

[ https://issues.apache.org/jira/browse/FLINK-10636?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16883533#comment-16883533 ] Jiangjie Qin commented on FLINK-10636: -- [~lsy] Is this issue on Kafka 0.8? Starting from Kafka 0.9,

[jira] [Commented] (FLINK-13124) Stop fails with Universal Kafka Consumer

[ https://issues.apache.org/jira/browse/FLINK-13124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16880896#comment-16880896 ] Jiangjie Qin commented on FLINK-13124: -- [~knaufk] Thanks for reporting the issue. I ran a few times

[jira] [Commented] (FLINK-13052) Supporting multi-topic when using kafkaTableSourceSinkFactoryBase.createStreamTableSource

[ https://issues.apache.org/jira/browse/FLINK-13052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16880061#comment-16880061 ] Jiangjie Qin commented on FLINK-13052: -- Yes, this does look like something that should have been

[jira] [Commented] (FLINK-10806) Support multiple consuming offsets when discovering a new topic

[ https://issues.apache.org/jira/browse/FLINK-10806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16885309#comment-16885309 ] Jiangjie Qin commented on FLINK-10806: -- [~wind_ljy] This is a common case. And this is what

[jira] [Commented] (FLINK-11654) Multiple transactional KafkaProducers writing to same cluster have clashing transaction IDs

[ https://issues.apache.org/jira/browse/FLINK-11654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16885303#comment-16885303 ] Jiangjie Qin commented on FLINK-11654: -- [~knaufk] That's a fair point. There might be pros and cons 

[jira] [Commented] (FLINK-13083) Various improvements PubSub Connector

[ https://issues.apache.org/jira/browse/FLINK-13083?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16905133#comment-16905133 ] Jiangjie Qin commented on FLINK-13083: -- [~Xeli] I've assigned you the two tickets. Can you please

[jira] [Updated] (FLINK-13230) Retry acknowledgement calls

[ https://issues.apache.org/jira/browse/FLINK-13230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated FLINK-13230: - Fix Version/s: 1.9.1 > Retry acknowledgement calls > --- > >

[jira] [Updated] (FLINK-13083) Various improvements PubSub Connector

[ https://issues.apache.org/jira/browse/FLINK-13083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated FLINK-13083: - Fix Version/s: 1.9.1 > Various improvements PubSub Connector >

[jira] [Updated] (FLINK-13231) Add a ratelimiter to pubsub source

[ https://issues.apache.org/jira/browse/FLINK-13231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated FLINK-13231: - Fix Version/s: 1.9.1 > Add a ratelimiter to pubsub source > --

[jira] [Assigned] (FLINK-13230) Retry acknowledgement calls

[ https://issues.apache.org/jira/browse/FLINK-13230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin reassigned FLINK-13230: Assignee: Richard Deurwaarder > Retry acknowledgement calls >

[jira] [Assigned] (FLINK-13231) Add a ratelimiter to pubsub source

[ https://issues.apache.org/jira/browse/FLINK-13231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin reassigned FLINK-13231: Assignee: Richard Deurwaarder > Add a ratelimiter to pubsub source >

[jira] [Commented] (FLINK-13083) Various improvements PubSub Connector

[ https://issues.apache.org/jira/browse/FLINK-13083?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16905130#comment-16905130 ] Jiangjie Qin commented on FLINK-13083: -- [~Xeli] Thanks for submitting the patch. I think we should

[jira] [Commented] (FLINK-13535) Do not abort transactions twice during KafkaProducer startup

[ https://issues.apache.org/jira/browse/FLINK-13535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16899028#comment-16899028 ] Jiangjie Qin commented on FLINK-13535: -- Resolved via 1.10 

[jira] [Resolved] (FLINK-13535) Do not abort transactions twice during KafkaProducer startup

[ https://issues.apache.org/jira/browse/FLINK-13535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin resolved FLINK-13535. -- Resolution: Fixed > Do not abort transactions twice during KafkaProducer startup >

[jira] [Updated] (FLINK-13535) Do not abort transactions twice during KafkaProducer startup

[ https://issues.apache.org/jira/browse/FLINK-13535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated FLINK-13535: - Fix Version/s: 1.10.0 > Do not abort transactions twice during KafkaProducer startup >

[jira] [Commented] (FLINK-13527) Instable KafkaProducerExactlyOnceITCase due to CheckpointFailureManager

[ https://issues.apache.org/jira/browse/FLINK-13527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16898895#comment-16898895 ] Jiangjie Qin commented on FLINK-13527: -- [~yanghua] Any update on this? Since this is set as a

[jira] [Commented] (FLINK-13733) FlinkKafkaInternalProducerITCase.testHappyPath fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-13733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16907899#comment-16907899 ] Jiangjie Qin commented on FLINK-13733: -- This test itself is quite simple. It might fail because a

[jira] [Assigned] (FLINK-13733) FlinkKafkaInternalProducerITCase.testHappyPath fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-13733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin reassigned FLINK-13733: Assignee: Jiangjie Qin > FlinkKafkaInternalProducerITCase.testHappyPath fails on Travis

[jira] [Commented] (FLINK-8521) FlinkKafkaProducer011ITCase.testRunOutOfProducersInThePool timed out on Travis

[ https://issues.apache.org/jira/browse/FLINK-8521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16907170#comment-16907170 ] Jiangjie Qin commented on FLINK-8521: - [~till.rohrmann] No. I am not currently work on this. A glance

[jira] [Updated] (FLINK-12745) Sparse and dense vector class, and dense matrix class with basic operations.

[ https://issues.apache.org/jira/browse/FLINK-12745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated FLINK-12745: - Fix Version/s: 1.10.0 > Sparse and dense vector class, and dense matrix class with basic

[jira] [Commented] (FLINK-12745) Sparse and dense vector class, and dense matrix class with basic operations.

[ https://issues.apache.org/jira/browse/FLINK-12745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16910590#comment-16910590 ] Jiangjie Qin commented on FLINK-12745: -- Merged to master  bc7d4da893e76010b4087e50292f3f1e6a7bc9d4

[jira] [Resolved] (FLINK-12745) Sparse and dense vector class, and dense matrix class with basic operations.

[ https://issues.apache.org/jira/browse/FLINK-12745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin resolved FLINK-12745. -- Resolution: Fixed > Sparse and dense vector class, and dense matrix class with basic

[jira] [Commented] (FLINK-8521) FlinkKafkaProducer011ITCase.testRunOutOfProducersInThePool timed out on Travis

[ https://issues.apache.org/jira/browse/FLINK-8521?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16907320#comment-16907320 ] Jiangjie Qin commented on FLINK-8521: - I probably won't be able to look at this soon. I'll unassign

[jira] [Assigned] (FLINK-8521) FlinkKafkaProducer011ITCase.testRunOutOfProducersInThePool timed out on Travis

[ https://issues.apache.org/jira/browse/FLINK-8521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin reassigned FLINK-8521: --- Assignee: (was: Jiangjie Qin) >

[jira] [Commented] (FLINK-10740) Refactor Source Interface

[ https://issues.apache.org/jira/browse/FLINK-10740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16919547#comment-16919547 ] Jiangjie Qin commented on FLINK-10740: -- [~till.rohrmann] Yes, I am. I'll just assign the ticket to

[jira] [Assigned] (FLINK-10740) Refactor Source Interface

[ https://issues.apache.org/jira/browse/FLINK-10740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin reassigned FLINK-10740: Assignee: Jiangjie Qin > Refactor Source Interface > - > >

[jira] [Assigned] (FLINK-14095) Add Pravega in Flink ecosystem page

[ https://issues.apache.org/jira/browse/FLINK-14095?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin reassigned FLINK-14095: Assignee: Yumin Zhou > Add Pravega in Flink ecosystem page >

[jira] [Commented] (FLINK-14095) Add Pravega in Flink ecosystem page

[ https://issues.apache.org/jira/browse/FLINK-14095?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16931485#comment-16931485 ] Jiangjie Qin commented on FLINK-14095: -- [~Brian Zhou] Just assigned the ticket to you. I don't see

[jira] [Commented] (FLINK-13083) Various improvements PubSub Connector

[ https://issues.apache.org/jira/browse/FLINK-13083?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16897913#comment-16897913 ] Jiangjie Qin commented on FLINK-13083: -- [~Xeli] Ping again. Please let me know if you have time to

[jira] [Commented] (FLINK-13226) KafkaProducerExactlyOnceITCase.testMultipleSinkOperators fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-13226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16897837#comment-16897837 ] Jiangjie Qin commented on FLINK-13226: -- Fixed via 1.9 4f2d5f1d41efefd5704261777245afccebd44ea7

[jira] [Commented] (FLINK-13527) Instable KafkaProducerExactlyOnceITCase due to CheckpointFailureManager

[ https://issues.apache.org/jira/browse/FLINK-13527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16897885#comment-16897885 ] Jiangjie Qin commented on FLINK-13527: -- [~yanghua] I did not notice that [~yunta] was pinging you

[jira] [Resolved] (FLINK-13226) KafkaProducerExactlyOnceITCase.testMultipleSinkOperators fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-13226?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin resolved FLINK-13226. -- Resolution: Fixed > KafkaProducerExactlyOnceITCase.testMultipleSinkOperators fails on Travis

[jira] [Comment Edited] (FLINK-11321) Clarify the NPE on fetching an nonexistent Kafka topic

[ https://issues.apache.org/jira/browse/FLINK-11321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16897839#comment-16897839 ] Jiangjie Qin edited comment on FLINK-11321 at 8/1/19 7:32 AM: -- Fixed via:

[jira] [Updated] (FLINK-11321) Clarify the NPE on fetching an nonexistent Kafka topic

[ https://issues.apache.org/jira/browse/FLINK-11321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated FLINK-11321: - Fix Version/s: 1.10 > Clarify the NPE on fetching an nonexistent Kafka topic >

[jira] [Commented] (FLINK-11321) Clarify the NPE on fetching an nonexistent Kafka topic

[ https://issues.apache.org/jira/browse/FLINK-11321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16897839#comment-16897839 ] Jiangjie Qin commented on FLINK-11321: -- Fixed via: 1.10 ce5de6be563ffe6e36b8f917a7f500ffc2b49c08

[jira] [Resolved] (FLINK-11321) Clarify the NPE on fetching an nonexistent Kafka topic

[ https://issues.apache.org/jira/browse/FLINK-11321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin resolved FLINK-11321. -- Resolution: Fixed > Clarify the NPE on fetching an nonexistent Kafka topic >

[jira] [Updated] (FLINK-11321) Clarify the NPE on fetching an nonexistent Kafka topic

[ https://issues.apache.org/jira/browse/FLINK-11321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated FLINK-11321: - Fix Version/s: (was: 1.10) 1.9.0 > Clarify the NPE on fetching an

[jira] [Assigned] (FLINK-13527) Instable KafkaProducerExactlyOnceITCase due to CheckpointFailureManager

[ https://issues.apache.org/jira/browse/FLINK-13527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin reassigned FLINK-13527: Assignee: vinoyang (was: Jiangjie Qin) > Instable KafkaProducerExactlyOnceITCase due to

[jira] [Commented] (FLINK-13527) Instable KafkaProducerExactlyOnceITCase due to CheckpointFailureManager

[ https://issues.apache.org/jira/browse/FLINK-13527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16897991#comment-16897991 ] Jiangjie Qin commented on FLINK-13527: -- Cool, I'll assign the ticket to you then. > Instable

[jira] [Assigned] (FLINK-13537) Changing Kafka producer pool size and scaling out may create overlapping transaction IDs

[ https://issues.apache.org/jira/browse/FLINK-13537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin reassigned FLINK-13537: Assignee: Jiangjie Qin > Changing Kafka producer pool size and scaling out may create

[jira] [Assigned] (FLINK-13537) Changing Kafka producer pool size and scaling out may create overlapping transaction IDs

[ https://issues.apache.org/jira/browse/FLINK-13537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin reassigned FLINK-13537: Assignee: (was: Jiangjie Qin) > Changing Kafka producer pool size and scaling out

[jira] [Commented] (FLINK-13595) KafkaITCase.testBigRecordJob fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-13595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16900760#comment-16900760 ] Jiangjie Qin commented on FLINK-13595: -- This issue is more of a Kafka issue than a Flink issue. It

[jira] [Updated] (FLINK-13595) KafkaITCase.testBigRecordJob fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-13595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated FLINK-13595: - Priority: Critical (was: Blocker) > KafkaITCase.testBigRecordJob fails on Travis >

[jira] [Updated] (FLINK-13595) KafkaITCase.testBigRecordJob fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-13595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated FLINK-13595: - Fix Version/s: (was: 1.9.0) 1.10.0 > KafkaITCase.testBigRecordJob fails

[jira] [Assigned] (FLINK-11654) Multiple transactional KafkaProducers writing to same cluster have clashing transaction IDs

[ https://issues.apache.org/jira/browse/FLINK-11654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin reassigned FLINK-11654: Assignee: Jiangjie Qin > Multiple transactional KafkaProducers writing to same cluster

[jira] [Commented] (FLINK-11654) Multiple transactional KafkaProducers writing to same cluster have clashing transaction IDs

[ https://issues.apache.org/jira/browse/FLINK-11654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16889729#comment-16889729 ] Jiangjie Qin commented on FLINK-11654: -- Cool. I'm going to assign this ticket to myself then. Since

[jira] [Commented] (FLINK-10806) Support multiple consuming offsets when discovering a new topic

[ https://issues.apache.org/jira/browse/FLINK-10806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16889727#comment-16889727 ] Jiangjie Qin commented on FLINK-10806: -- [~wind_ljy] Thanks for the explanation. So you want to seek

[jira] [Commented] (FLINK-10806) Support multiple consuming offsets when discovering a new topic

[ https://issues.apache.org/jira/browse/FLINK-10806?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16891724#comment-16891724 ] Jiangjie Qin commented on FLINK-10806: -- [~wind_ljy] I think it might still worth having either

[jira] [Commented] (FLINK-13226) KafkaProducerExactlyOnceITCase.testMultipleSinkOperators fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-13226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16885348#comment-16885348 ] Jiangjie Qin commented on FLINK-13226: -- I took a look at the stack trace here. We are hitting

[jira] [Commented] (FLINK-13231) Add a ratelimiter to pubsub source

[ https://issues.apache.org/jira/browse/FLINK-13231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16889868#comment-16889868 ] Jiangjie Qin commented on FLINK-13231: -- [~Xeli] The rate limiter is actually a per consumer / per

  1   2   3   4   5   6   >