[jira] [Commented] (FLINK-16125) Make zookeeper.connect optional for Kafka connectors

[ https://issues.apache.org/jira/browse/FLINK-16125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17053267#comment-17053267 ] Qingsheng Ren commented on FLINK-16125: --- Hi [~jark], I'm still working on this issue and will

[jira] [Commented] (FLINK-16130) Translate "Common Configurations" page of "File Systems" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-16130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17038848#comment-17038848 ] Qingsheng Ren commented on FLINK-16130: --- Thanks [~jark]. I'd like to work on this. > Translate

[jira] [Commented] (FLINK-16132) Translate "Aliyun OSS" page of "File Systems" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-16132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17038851#comment-17038851 ] Qingsheng Ren commented on FLINK-16132: --- Thanks [~jark]. I'd like to work on this issue. >

[jira] [Commented] (FLINK-16133) Translate "Azure Blob Storage" page of "File Systems" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-16133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17038852#comment-17038852 ] Qingsheng Ren commented on FLINK-16133: --- Thanks [~jark]. I'd like to work on this issue. >

[jira] [Commented] (FLINK-16131) Translate "Amazon S3" page of "File Systems" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-16131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17038850#comment-17038850 ] Qingsheng Ren commented on FLINK-16131: --- Thanks [~jark]. I'd like to work on this issue. >

[jira] [Commented] (FLINK-16129) Translate "Overview" page of "File Systems" into Chinese

[ https://issues.apache.org/jira/browse/FLINK-16129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17038846#comment-17038846 ] Qingsheng Ren commented on FLINK-16129: --- Thanks [~jark]. I'd like to work on this. > Translate

[jira] [Created] (FLINK-19652) Support pure string format for Kafka table connector

Qingsheng Ren created FLINK-19652: - Summary: Support pure string format for Kafka table connector Key: FLINK-19652 URL: https://issues.apache.org/jira/browse/FLINK-19652 Project: Flink Issue

[jira] [Commented] (FLINK-19652) Support pure string format for Kafka table connector

[ https://issues.apache.org/jira/browse/FLINK-19652?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17215144#comment-17215144 ] Qingsheng Ren commented on FLINK-19652: --- Yes FLINK-14356 indeed covers this issue. I'll mark this

[jira] [Closed] (FLINK-19652) Support pure string format for Kafka table connector

[ https://issues.apache.org/jira/browse/FLINK-19652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren closed FLINK-19652. - Resolution: Duplicate > Support pure string format for Kafka table connector >

[jira] [Created] (FLINK-19554) Unified testing framework for connectors

Qingsheng Ren created FLINK-19554: - Summary: Unified testing framework for connectors Key: FLINK-19554 URL: https://issues.apache.org/jira/browse/FLINK-19554 Project: Flink Issue Type: New

[jira] [Commented] (FLINK-18780) FlinkKafkaProducer should add another constructor accepting SerializationSchema

[ https://issues.apache.org/jira/browse/FLINK-18780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17182893#comment-17182893 ] Qingsheng Ren commented on FLINK-18780: --- [~ting.lt] This looks good to me. Any comments from

[jira] [Commented] (FLINK-18780) FlinkKafkaProducer should add another constructor accepting SerializationSchema

[ https://issues.apache.org/jira/browse/FLINK-18780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17183002#comment-17183002 ] Qingsheng Ren commented on FLINK-18780: --- Thanks [~becket_qin] ~  I'll create another ticket about

[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=17199112#comment-17199112 ] Qingsheng Ren commented on FLINK-13733: --- Hello everyone, I ran this test case locally with TRACE

[jira] [Updated] (FLINK-18802) Create an uber jar when packaging flink-avro

[ https://issues.apache.org/jira/browse/FLINK-18802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-18802: -- Summary: Create an uber jar when packaging flink-avro (was: Creating an uber jar when

[jira] [Created] (FLINK-18802) Creating an uber jar when packaging flink-avro

Qingsheng Ren created FLINK-18802: - Summary: Creating an uber jar when packaging flink-avro Key: FLINK-18802 URL: https://issues.apache.org/jira/browse/FLINK-18802 Project: Flink Issue Type:

[jira] [Created] (FLINK-18578) Add rejecting checkpoint logic in source

Qingsheng Ren created FLINK-18578: - Summary: Add rejecting checkpoint logic in source Key: FLINK-18578 URL: https://issues.apache.org/jira/browse/FLINK-18578 Project: Flink Issue Type: New

[jira] [Created] (FLINK-18780) FlinkKafkaProducer should add another constructor accepting SerializationSchema

Qingsheng Ren created FLINK-18780: - Summary: FlinkKafkaProducer should add another constructor accepting SerializationSchema Key: FLINK-18780 URL: https://issues.apache.org/jira/browse/FLINK-18780

[jira] [Commented] (FLINK-20777) Default value of property "partition.discovery.interval.ms" is not as documented in new Kafka Source

[ https://issues.apache.org/jira/browse/FLINK-20777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17255853#comment-17255853 ] Qingsheng Ren commented on FLINK-20777: --- Hi [~873925...@qq.com], Thanks for your reviewing~ I

[jira] [Commented] (FLINK-20777) Default value of property "partition.discovery.interval.ms" is not as documented in new Kafka Source

[ https://issues.apache.org/jira/browse/FLINK-20777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17255869#comment-17255869 ] Qingsheng Ren commented on FLINK-20777: --- >From my perspective, I prefer enabling discovering

[jira] [Comment Edited] (FLINK-20777) Default value of property "partition.discovery.interval.ms" is not as documented in new Kafka Source

[ https://issues.apache.org/jira/browse/FLINK-20777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17255853#comment-17255853 ] Qingsheng Ren edited comment on FLINK-20777 at 12/29/20, 7:41 AM: -- Hi

[jira] [Commented] (FLINK-20655) Add E2E tests to the new KafkaSource based on FLIP-27.

[ https://issues.apache.org/jira/browse/FLINK-20655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17260257#comment-17260257 ] Qingsheng Ren commented on FLINK-20655: --- I used Flink integrated state machine example with 4

[jira] [Updated] (FLINK-20524) Package KafkaTestEnvironment into Kafka connector test JAR

[ https://issues.apache.org/jira/browse/FLINK-20524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-20524: -- Description: Currently the test JAR of `{{flink-connector-kafka}}` module only includes one

[jira] [Created] (FLINK-20524) Package KafkaTestEnvironment into Kafka connector test JAR

Qingsheng Ren created FLINK-20524: - Summary: Package KafkaTestEnvironment into Kafka connector test JAR Key: FLINK-20524 URL: https://issues.apache.org/jira/browse/FLINK-20524 Project: Flink

[jira] [Created] (FLINK-20553) Add end-to-end test case for new Kafka source

Qingsheng Ren created FLINK-20553: - Summary: Add end-to-end test case for new Kafka source Key: FLINK-20553 URL: https://issues.apache.org/jira/browse/FLINK-20553 Project: Flink Issue Type:

[jira] [Created] (FLINK-20459) Handle null message correctly in JSON RowData deserializer

Qingsheng Ren created FLINK-20459: - Summary: Handle null message correctly in JSON RowData deserializer Key: FLINK-20459 URL: https://issues.apache.org/jira/browse/FLINK-20459 Project: Flink

[jira] [Commented] (FLINK-18578) Add rejecting checkpoint logic in source

[ https://issues.apache.org/jira/browse/FLINK-18578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17251432#comment-17251432 ] Qingsheng Ren commented on FLINK-18578: --- [~becket_qin] I'd like to take over this issue. Thanks >

[jira] [Created] (FLINK-20777) Default value of property "partition.discovery.interval.ms" is not as documented in new Kafka Source

Qingsheng Ren created FLINK-20777: - Summary: Default value of property "partition.discovery.interval.ms" is not as documented in new Kafka Source Key: FLINK-20777 URL:

[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=17229025#comment-17229025 ] Qingsheng Ren commented on FLINK-13733: --- [~rmetzger] Sorry for my late response! I'll create a PR

[jira] [Commented] (FLINK-18382) Translate "Kafka SQL Connector" page into Chinese

[ https://issues.apache.org/jira/browse/FLINK-18382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17223489#comment-17223489 ] Qingsheng Ren commented on FLINK-18382: --- Hello [~zouzhiye] , is there any update about this issue?

[jira] [Commented] (FLINK-19554) Unified testing framework for connectors

[ https://issues.apache.org/jira/browse/FLINK-19554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17223536#comment-17223536 ] Qingsheng Ren commented on FLINK-19554: --- Hi [~rmetzger] , thanks for pointing this out! This

[jira] [Closed] (FLINK-18780) FlinkKafkaProducer should add another constructor accepting SerializationSchema

[ https://issues.apache.org/jira/browse/FLINK-18780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren closed FLINK-18780. - Resolution: Won't Fix > FlinkKafkaProducer should add another constructor accepting >

[jira] [Comment Edited] (FLINK-19893) stop consuming in specific offset or timestamp

[ https://issues.apache.org/jira/browse/FLINK-19893?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17223497#comment-17223497 ] Qingsheng Ren edited comment on FLINK-19893 at 10/30/20, 8:49 AM: -- I

[jira] [Commented] (FLINK-19893) stop consuming in specific offset or timestamp

[ https://issues.apache.org/jira/browse/FLINK-19893?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17223497#comment-17223497 ] Qingsheng Ren commented on FLINK-19893: --- I think this feature will be added in the new Kafka

[jira] [Created] (FLINK-19750) Deserializer is not opened in Kafka consumer when restoring from state

Qingsheng Ren created FLINK-19750: - Summary: Deserializer is not opened in Kafka consumer when restoring from state Key: FLINK-19750 URL: https://issues.apache.org/jira/browse/FLINK-19750 Project:

[jira] [Commented] (FLINK-19750) Deserializer is not opened in Kafka consumer when restoring from state

[ https://issues.apache.org/jira/browse/FLINK-19750?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17218266#comment-17218266 ] Qingsheng Ren commented on FLINK-19750: --- Sure [~jark] , I'll create a PR about this. Thank you~ >

[jira] [Updated] (FLINK-19750) Deserializer is not opened in Kafka consumer when restoring from state

[ https://issues.apache.org/jira/browse/FLINK-19750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-19750: -- Description: When a job using Kafka consumer is recovered from a checkpoint or savepoint, the 

[jira] [Commented] (FLINK-20777) Default value of property "partition.discovery.interval.ms" is not as documented in new Kafka Source

[ https://issues.apache.org/jira/browse/FLINK-20777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17256853#comment-17256853 ] Qingsheng Ren commented on FLINK-20777: --- [~jark] Partition discovery is disabled by default in the

[jira] [Issue Comment Deleted] (FLINK-20777) Default value of property "partition.discovery.interval.ms" is not as documented in new Kafka Source

[ https://issues.apache.org/jira/browse/FLINK-20777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-20777: -- Comment: was deleted (was: I took more investigation on the logic here. Actually the

[jira] [Comment Edited] (FLINK-20655) Add E2E tests to the new KafkaSource based on FLIP-27.

[ https://issues.apache.org/jira/browse/FLINK-20655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17258699#comment-17258699 ] Qingsheng Ren edited comment on FLINK-20655 at 1/5/21, 7:16 AM: Also

[jira] [Commented] (FLINK-20655) Add E2E tests to the new KafkaSource based on FLIP-27.

[ https://issues.apache.org/jira/browse/FLINK-20655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17258699#comment-17258699 ] Qingsheng Ren commented on FLINK-20655: --- Also some JavaDoc can be better such as \{{setUnbounded}}

[jira] [Comment Edited] (FLINK-20655) Add E2E tests to the new KafkaSource based on FLIP-27.

[ https://issues.apache.org/jira/browse/FLINK-20655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17258053#comment-17258053 ] Qingsheng Ren edited comment on FLINK-20655 at 1/5/21, 7:05 AM: I'm

[jira] [Created] (FLINK-20848) Kafka consumer ID is not specified correctly in new KafkaSource

Qingsheng Ren created FLINK-20848: - Summary: Kafka consumer ID is not specified correctly in new KafkaSource Key: FLINK-20848 URL: https://issues.apache.org/jira/browse/FLINK-20848 Project: Flink

[jira] [Created] (FLINK-20849) Improve JavaDoc and logging of new KafkaSource

Qingsheng Ren created FLINK-20849: - Summary: Improve JavaDoc and logging of new KafkaSource Key: FLINK-20849 URL: https://issues.apache.org/jira/browse/FLINK-20849 Project: Flink Issue Type:

[jira] [Commented] (FLINK-20777) Default value of property "partition.discovery.interval.ms" is not as documented in new Kafka Source

[ https://issues.apache.org/jira/browse/FLINK-20777?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17258689#comment-17258689 ] Qingsheng Ren commented on FLINK-20777: --- I took more investigation on the logic here. Actually the

[jira] [Commented] (FLINK-20655) Add E2E tests to the new KafkaSource based on FLIP-27.

[ https://issues.apache.org/jira/browse/FLINK-20655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17258053#comment-17258053 ] Qingsheng Ren commented on FLINK-20655: --- I'm currently making some manually end-to-end tests, and

[jira] [Comment Edited] (FLINK-20655) Add E2E tests to the new KafkaSource based on FLIP-27.

[ https://issues.apache.org/jira/browse/FLINK-20655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17258053#comment-17258053 ] Qingsheng Ren edited comment on FLINK-20655 at 1/4/21, 8:14 AM: I'm

[jira] [Created] (FLINK-22914) Use Kafka New Source in Table/SQL connector

Qingsheng Ren created FLINK-22914: - Summary: Use Kafka New Source in Table/SQL connector Key: FLINK-22914 URL: https://issues.apache.org/jira/browse/FLINK-22914 Project: Flink Issue Type:

[jira] [Updated] (FLINK-22914) Use Kafka new source in Table/SQL connector

[ https://issues.apache.org/jira/browse/FLINK-22914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-22914: -- Summary: Use Kafka new source in Table/SQL connector (was: Use Kafka New Source in Table/SQL

[jira] [Commented] (FLINK-22457) KafkaSourceLegacyITCase.testMultipleSourcesOnePartition fails because of timeout

[ https://issues.apache.org/jira/browse/FLINK-22457?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17360575#comment-17360575 ] Qingsheng Ren commented on FLINK-22457: --- [~xintongsong] Sure, trying to reproduce locally >

[jira] [Resolved] (FLINK-21160) ValueDeserializerWrapper throws NullPointerException when getProducedType is invoked

[ https://issues.apache.org/jira/browse/FLINK-21160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren resolved FLINK-21160. --- Resolution: Fixed > ValueDeserializerWrapper throws NullPointerException when

[jira] [Created] (FLINK-22722) Add Documentation for Kafka New Source

Qingsheng Ren created FLINK-22722: - Summary: Add Documentation for Kafka New Source Key: FLINK-22722 URL: https://issues.apache.org/jira/browse/FLINK-22722 Project: Flink Issue Type:

[jira] [Updated] (FLINK-21160) ValueDeserializerWrapper throws NullPointerException when getProducedType is invoked

[ https://issues.apache.org/jira/browse/FLINK-21160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-21160: -- Affects Version/s: (was: 1.13.0) > ValueDeserializerWrapper throws NullPointerException

[jira] [Commented] (FLINK-20553) Add end-to-end test case for new Kafka source

[ https://issues.apache.org/jira/browse/FLINK-20553?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17341254#comment-17341254 ] Qingsheng Ren commented on FLINK-20553: --- Duplicated to FLINK-20655 > Add end-to-end test case for

[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=17341247#comment-17341247 ] Qingsheng Ren commented on FLINK-11793: --- According to [the documentation of Kafka

[jira] [Closed] (FLINK-20553) Add end-to-end test case for new Kafka source

[ https://issues.apache.org/jira/browse/FLINK-20553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren closed FLINK-20553. - Resolution: Duplicate > Add end-to-end test case for new Kafka source >

[jira] [Updated] (FLINK-21160) ValueDeserializerWrapper throws NullPointerException when getProducedType is invoked

[ https://issues.apache.org/jira/browse/FLINK-21160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-21160: -- Affects Version/s: 1.13.0 1.12.3 > ValueDeserializerWrapper throws

[jira] [Updated] (FLINK-21160) ValueDeserializerWrapper throws NullPointerException when getProducedType is invoked

[ https://issues.apache.org/jira/browse/FLINK-21160?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-21160: -- Fix Version/s: 1.13.0 > ValueDeserializerWrapper throws NullPointerException when

[jira] [Created] (FLINK-22766) Report metrics of KafkaConsumer in Kafka new source

Qingsheng Ren created FLINK-22766: - Summary: Report metrics of KafkaConsumer in Kafka new source Key: FLINK-22766 URL: https://issues.apache.org/jira/browse/FLINK-22766 Project: Flink Issue

[jira] [Commented] (FLINK-22416) UpsertKafkaTableITCase hangs when collecting results

[ https://issues.apache.org/jira/browse/FLINK-22416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17372581#comment-17372581 ] Qingsheng Ren commented on FLINK-22416: --- I checked logs of recent 3 failure instances, and seems

[jira] [Commented] (FLINK-22457) KafkaSourceLegacyITCase.testMultipleSourcesOnePartition fails because of timeout

[ https://issues.apache.org/jira/browse/FLINK-22457?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17372589#comment-17372589 ] Qingsheng Ren commented on FLINK-22457: --- Hi [~xintongsong] Sorry for my late response! I couldn't

[jira] [Created] (FLINK-23254) Upgrade Test Framework to JUnit 5

Qingsheng Ren created FLINK-23254: - Summary: Upgrade Test Framework to JUnit 5 Key: FLINK-23254 URL: https://issues.apache.org/jira/browse/FLINK-23254 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-23255) Add JUnit 5 jupiter and vintage engine

Qingsheng Ren created FLINK-23255: - Summary: Add JUnit 5 jupiter and vintage engine Key: FLINK-23255 URL: https://issues.apache.org/jira/browse/FLINK-23255 Project: Flink Issue Type:

[jira] [Commented] (FLINK-21160) ValueDeserializerWrapper throws NullPointerException when getProducedType is invoked

[ https://issues.apache.org/jira/browse/FLINK-21160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17331697#comment-17331697 ] Qingsheng Ren commented on FLINK-21160: --- Fixed by

[jira] [Created] (FLINK-21159) KafkaSourceEnumerator not sending NoMoreSplitsEvent to unassigned reader

Qingsheng Ren created FLINK-21159: - Summary: KafkaSourceEnumerator not sending NoMoreSplitsEvent to unassigned reader Key: FLINK-21159 URL: https://issues.apache.org/jira/browse/FLINK-21159 Project:

[jira] [Created] (FLINK-21160) ValueDeserializerWrapper throws NullPointerException when getProducedType is invoked

Qingsheng Ren created FLINK-21160: - Summary: ValueDeserializerWrapper throws NullPointerException when getProducedType is invoked Key: FLINK-21160 URL: https://issues.apache.org/jira/browse/FLINK-21160

[jira] [Comment Edited] (FLINK-21817) New Kafka Source might break subtask and split assignment upon rescale

[ https://issues.apache.org/jira/browse/FLINK-21817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17305961#comment-17305961 ] Qingsheng Ren edited comment on FLINK-21817 at 3/23/21, 2:07 AM: - Thanks

[jira] [Commented] (FLINK-21817) New Kafka Source might break subtask and split assignment upon rescale

[ https://issues.apache.org/jira/browse/FLINK-21817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17306912#comment-17306912 ] Qingsheng Ren commented on FLINK-21817: --- Thanks for the inspiring discussion! About

[jira] [Commented] (FLINK-21817) New Kafka Source might break subtask and split assignment upon rescale

[ https://issues.apache.org/jira/browse/FLINK-21817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17309485#comment-17309485 ] Qingsheng Ren commented on FLINK-21817: --- I can work on those two blockers mentioned by [~sewen]

[jira] [Commented] (FLINK-21817) FLIP-27 Source might break subtask and split assignment upon rescale

[ https://issues.apache.org/jira/browse/FLINK-21817?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17305961#comment-17305961 ] Qingsheng Ren commented on FLINK-21817: --- Thanks for the ticket [~kezhuw]! I took a look of new

[jira] [Commented] (FLINK-21193) Migrate Flink Docs to Hugo

[ https://issues.apache.org/jira/browse/FLINK-21193?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17300134#comment-17300134 ] Qingsheng Ren commented on FLINK-21193: --- Hi [~sjwiesman], it seems that some documentation files

[jira] [Created] (FLINK-22147) Refactor Partition Discovery Logic in KafkaSourceEnumerator

Qingsheng Ren created FLINK-22147: - Summary: Refactor Partition Discovery Logic in KafkaSourceEnumerator Key: FLINK-22147 URL: https://issues.apache.org/jira/browse/FLINK-22147 Project: Flink

[jira] [Commented] (FLINK-23828) KafkaSourceITCase.testIdleReader fails on azure

[ https://issues.apache.org/jira/browse/FLINK-23828?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17402073#comment-17402073 ] Qingsheng Ren commented on FLINK-23828: --- Thanks [~xtsong] for raising this. I'll take over the

[jira] [Commented] (FLINK-22198) KafkaTableITCase hang.

[ https://issues.apache.org/jira/browse/FLINK-22198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17402069#comment-17402069 ] Qingsheng Ren commented on FLINK-22198: --- [~jark] The default value is 7 days. The problem is that

[jira] [Commented] (FLINK-22198) KafkaTableITCase hang.

[ https://issues.apache.org/jira/browse/FLINK-22198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17401454#comment-17401454 ] Qingsheng Ren commented on FLINK-22198: --- Thanks [~xtsong] for the reminder. I had a discussion

[jira] [Created] (FLINK-23914) Make connector testing framework more verbose on test failure

Qingsheng Ren created FLINK-23914: - Summary: Make connector testing framework more verbose on test failure Key: FLINK-23914 URL: https://issues.apache.org/jira/browse/FLINK-23914 Project: Flink

[jira] [Comment Edited] (FLINK-22198) KafkaTableITCase hang.

[ https://issues.apache.org/jira/browse/FLINK-22198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17400280#comment-17400280 ] Qingsheng Ren edited comment on FLINK-22198 at 8/17/21, 9:23 AM: - This

[jira] [Commented] (FLINK-22198) KafkaTableITCase hang.

[ https://issues.apache.org/jira/browse/FLINK-22198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17400280#comment-17400280 ] Qingsheng Ren commented on FLINK-22198: --- This is another instance from my own Azure pipeline,

[jira] [Created] (FLINK-23850) Test Kafka table connector with new runtime provider

Qingsheng Ren created FLINK-23850: - Summary: Test Kafka table connector with new runtime provider Key: FLINK-23850 URL: https://issues.apache.org/jira/browse/FLINK-23850 Project: Flink Issue

[jira] [Commented] (FLINK-22198) KafkaTableITCase hang.

[ https://issues.apache.org/jira/browse/FLINK-22198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17403694#comment-17403694 ] Qingsheng Ren commented on FLINK-22198: --- [~jark] Thanks for pointing this out! To be honest I have

[jira] [Closed] (FLINK-22702) KafkaSourceITCase.testRedundantParallelism failed

[ https://issues.apache.org/jira/browse/FLINK-22702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren closed FLINK-22702. - > KafkaSourceITCase.testRedundantParallelism failed >

[jira] [Comment Edited] (FLINK-22416) UpsertKafkaTableITCase hangs when collecting results

[ https://issues.apache.org/jira/browse/FLINK-22416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17404128#comment-17404128 ] Qingsheng Ren edited comment on FLINK-22416 at 8/25/21, 2:36 AM: - This

[jira] [Closed] (FLINK-22416) UpsertKafkaTableITCase hangs when collecting results

[ https://issues.apache.org/jira/browse/FLINK-22416?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren closed FLINK-22416. - Resolution: Fixed > UpsertKafkaTableITCase hangs when collecting results >

[jira] [Commented] (FLINK-22416) UpsertKafkaTableITCase hangs when collecting results

[ https://issues.apache.org/jira/browse/FLINK-22416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17404128#comment-17404128 ] Qingsheng Ren commented on FLINK-22416: --- This issue shares the same root cause with FLINK-22198

[jira] [Commented] (FLINK-23971) PulsarSourceITCase.testIdleReader failed on azure

[ https://issues.apache.org/jira/browse/FLINK-23971?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17406618#comment-17406618 ] Qingsheng Ren commented on FLINK-23971: --- Thanks [~ruanhang1993] for the investigation! I double

[jira] [Created] (FLINK-23801) Add FLIP-33 metrics to KafkaSource

Qingsheng Ren created FLINK-23801: - Summary: Add FLIP-33 metrics to KafkaSource Key: FLINK-23801 URL: https://issues.apache.org/jira/browse/FLINK-23801 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-23773) KafkaPartitionSplitReader should remove empty splits from fetcher

Qingsheng Ren created FLINK-23773: - Summary: KafkaPartitionSplitReader should remove empty splits from fetcher Key: FLINK-23773 URL: https://issues.apache.org/jira/browse/FLINK-23773 Project: Flink

[jira] [Updated] (FLINK-23773) KafkaPartitionSplitReader should remove empty splits from fetcher

[ https://issues.apache.org/jira/browse/FLINK-23773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-23773: -- Description: Currently if a {{KafkaPartitionSplit}} is empty (startingOffset >=

[jira] [Commented] (FLINK-23850) Test Kafka table connector with new runtime provider

[ https://issues.apache.org/jira/browse/FLINK-23850?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17400954#comment-17400954 ] Qingsheng Ren commented on FLINK-23850: --- [~joemoe] Sure that's reasonable. Converted to subtask.

[jira] [Updated] (FLINK-23850) Test Kafka table connector with new runtime provider

[ https://issues.apache.org/jira/browse/FLINK-23850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-23850: -- Parent: FLINK-22914 Issue Type: Sub-task (was: Improvement) > Test Kafka table

[jira] [Commented] (FLINK-22198) KafkaTableITCase hang.

[ https://issues.apache.org/jira/browse/FLINK-22198?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17401679#comment-17401679 ] Qingsheng Ren commented on FLINK-22198: --- Thanks [~lindong] for the investigation! Yes there are

[jira] [Created] (FLINK-24126) Use increment of bytes-consumed-total for updating numBytesIn in KafkaSource

Qingsheng Ren created FLINK-24126: - Summary: Use increment of bytes-consumed-total for updating numBytesIn in KafkaSource Key: FLINK-24126 URL: https://issues.apache.org/jira/browse/FLINK-24126

[jira] [Created] (FLINK-24277) Offset commit should be disabled if consumer group ID is not specified in KafkaSource

Qingsheng Ren created FLINK-24277: - Summary: Offset commit should be disabled if consumer group ID is not specified in KafkaSource Key: FLINK-24277 URL: https://issues.apache.org/jira/browse/FLINK-24277

[jira] [Commented] (FLINK-24308) Translate KafkaSink docs to chinese

[ https://issues.apache.org/jira/browse/FLINK-24308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17415986#comment-17415986 ] Qingsheng Ren commented on FLINK-24308: --- Sure I'll work on the translation > Translate KafkaSink

[jira] [Commented] (FLINK-24174) MiniClusterTestEnvironment‘s triggerTaskManagerFailover may stuck in CommonTestUtils.waitForJobStatus()

[ https://issues.apache.org/jira/browse/FLINK-24174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17410895#comment-17410895 ] Qingsheng Ren commented on FLINK-24174: --- Thanks [~Jiangang] for reporting this. I think the issue

[jira] [Updated] (FLINK-23807) Use RestClient to detect restarts in MiniClusterTestEnvironment#triggerTaskManagerFailover

[ https://issues.apache.org/jira/browse/FLINK-23807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-23807: -- Description: {{MiniClusterTestEnvironment#triggerTaskManagerFailover}} checks the job status

[jira] [Commented] (FLINK-23944) PulsarSourceITCase.testTaskManagerFailure is instable

[ https://issues.apache.org/jira/browse/FLINK-23944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17410951#comment-17410951 ] Qingsheng Ren commented on FLINK-23944: --- I checked the log and I think this issue is caused by

[jira] [Updated] (FLINK-23807) Use RestClient to detect restarts in MiniClusterTestEnvironment#triggerTaskManagerFailover

[ https://issues.apache.org/jira/browse/FLINK-23807?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren updated FLINK-23807: -- Summary: Use RestClient to detect restarts in

[jira] [Commented] (FLINK-23914) Make connector testing framework more verbose on test failure

[ https://issues.apache.org/jira/browse/FLINK-23914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17415289#comment-17415289 ] Qingsheng Ren commented on FLINK-23914: --- Hi [~esexton], I think the pull request of this issue is

[jira] [Commented] (FLINK-23391) KafkaSourceReaderTest.testKafkaSourceMetrics fails on azure

[ https://issues.apache.org/jira/browse/FLINK-23391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17412996#comment-17412996 ] Qingsheng Ren commented on FLINK-23391: --- Thanks for reporting this. I think this one is the same

[jira] [Resolved] (FLINK-20655) Add E2E tests to the new KafkaSource based on FLIP-27.

[ https://issues.apache.org/jira/browse/FLINK-20655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Qingsheng Ren resolved FLINK-20655. --- Fix Version/s: (was: 1.12.6) Resolution: Fixed > Add E2E tests to the new

  1   2   3   4   5   6   7   8   9   10   >