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

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

[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] [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&focusedCommentId=16931485#comment-16931485 ] Jiangjie Qin commented on FLINK-14095: -- [~Brian Zhou] Just assigned the ticket to

[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-14302) FlinkKafkaInternalProducer should not send `ADD_PARTITIONS_TO_TXN` request if `newPartitionsInTransaction` is empty when enable EoS

[ https://issues.apache.org/jira/browse/FLINK-14302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16945485#comment-16945485 ] Jiangjie Qin commented on FLINK-14302: -- [~tonywei] Really sorry for the late respon

[jira] [Commented] (FLINK-14302) FlinkKafkaInternalProducer should not send `ADD_PARTITIONS_TO_TXN` request if `newPartitionsInTransaction` is empty when enable EoS

[ https://issues.apache.org/jira/browse/FLINK-14302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16947123#comment-16947123 ] Jiangjie Qin commented on FLINK-14302: -- [~tonywei] Thanks for the explanation. I am

[jira] [Commented] (FLINK-14302) FlinkKafkaInternalProducer should not send `ADD_PARTITIONS_TO_TXN` request if `newPartitionsInTransaction` is empty when enable EoS

[ https://issues.apache.org/jira/browse/FLINK-14302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16947388#comment-16947388 ] Jiangjie Qin commented on FLINK-14302: -- [~tonywei] Ah, you are right. I apparently

[jira] [Commented] (FLINK-14309) Kafka09ProducerITCase>KafkaProducerTestBase.testOneToOneAtLeastOnceRegularSink fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-14309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16948912#comment-16948912 ] Jiangjie Qin commented on FLINK-14309: -- [~wind_ljy] Sorry for the late reply. I agr

[jira] [Assigned] (FLINK-14309) Kafka09ProducerITCase>KafkaProducerTestBase.testOneToOneAtLeastOnceRegularSink fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-14309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin reassigned FLINK-14309: Assignee: Jiayi Liao > Kafka09ProducerITCase>KafkaProducerTestBase.testOneToOneAtLeastOnc

[jira] [Resolved] (FLINK-14309) Kafka09ProducerITCase>KafkaProducerTestBase.testOneToOneAtLeastOnceRegularSink fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-14309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin resolved FLINK-14309. -- Resolution: Fixed > Kafka09ProducerITCase>KafkaProducerTestBase.testOneToOneAtLeastOnceRegular

[jira] [Commented] (FLINK-14309) Kafka09ProducerITCase>KafkaProducerTestBase.testOneToOneAtLeastOnceRegularSink fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-14309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16948921#comment-16948921 ] Jiangjie Qin commented on FLINK-14309: -- Patch merged to master. githash: d963eabdb

[jira] [Commented] (FLINK-14309) Kafka09ProducerITCase>KafkaProducerTestBase.testOneToOneAtLeastOnceRegularSink fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-14309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16950111#comment-16950111 ] Jiangjie Qin commented on FLINK-14309: -- [~trohrmann] This patch just fixes the test

[jira] [Commented] (FLINK-13339) Add an implementation of pipeline's api

[ https://issues.apache.org/jira/browse/FLINK-13339?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16950789#comment-16950789 ] Jiangjie Qin commented on FLINK-13339: -- Merged to master. 2f1200623f465b8e35daa866

[jira] [Assigned] (FLINK-13339) Add an implementation of pipeline's api

[ https://issues.apache.org/jira/browse/FLINK-13339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin reassigned FLINK-13339: Assignee: Xu Yang > Add an implementation of pipeline's api > ---

[jira] [Resolved] (FLINK-13339) Add an implementation of pipeline's api

[ https://issues.apache.org/jira/browse/FLINK-13339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin resolved FLINK-13339. -- Resolution: Implemented > Add an implementation of pipeline's api > --

[jira] [Updated] (FLINK-13339) Add an implementation of pipeline's api

[ https://issues.apache.org/jira/browse/FLINK-13339?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated FLINK-13339: - Fix Version/s: 1.10.0 > Add an implementation of pipeline's api > --

[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&focusedCommentId=16851754#comment-16851754 ] Jiangjie Qin commented on FLINK-10455: -- It looks that some further investigation is

[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&focusedCommentId=16855489#comment-16855489 ] Jiangjie Qin commented on FLINK-10455: -- [~sunjincheng121] Thanks for the help. I am

[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&focusedCommentId=16856486#comment-16856486 ] Jiangjie Qin commented on FLINK-10455: -- Some updates. I think the issue here is sti

[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&focusedCommentId=16856494#comment-16856494 ] Jiangjie Qin commented on FLINK-10455: -- Some updates. I think the issue here is sti

[jira] [Created] (FLINK-33733) [FLIP-321] Update the stability docs to add the migration periods.

Jiangjie Qin created FLINK-33733: Summary: [FLIP-321] Update the stability docs to add the migration periods. Key: FLINK-33733 URL: https://issues.apache.org/jira/browse/FLINK-33733 Project: Flink

[jira] [Assigned] (FLINK-33733) [FLIP-321] Update the stability docs to add the migration periods.

[ https://issues.apache.org/jira/browse/FLINK-33733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin reassigned FLINK-33733: Assignee: Jiangjie Qin > [FLIP-321] Update the stability docs to add the migration period

[jira] [Commented] (FLINK-33733) [FLIP-321] Update the stability docs to add the migration periods.

[ https://issues.apache.org/jira/browse/FLINK-33733?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17797081#comment-17797081 ] Jiangjie Qin commented on FLINK-33733: -- Just realized that I forgot to make the PR

[jira] [Resolved] (FLINK-33733) [FLIP-321] Update the stability docs to add the migration periods.

[ https://issues.apache.org/jira/browse/FLINK-33733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin resolved FLINK-33733. -- Fix Version/s: 1.19.0 Resolution: Fixed > [FLIP-321] Update the stability docs to add t

[jira] [Created] (FLINK-35924) Improve the SourceReaderBase to support the RecordsWithSplitIds share internal buffer from SplitReader.

Jiangjie Qin created FLINK-35924: Summary: Improve the SourceReaderBase to support the RecordsWithSplitIds share internal buffer from SplitReader. Key: FLINK-35924 URL: https://issues.apache.org/jira/browse/FLINK-

[jira] [Assigned] (FLINK-35924) Improve the SourceReaderBase to support the RecordsWithSplitIds share internal buffer from SplitReader.

[ https://issues.apache.org/jira/browse/FLINK-35924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin reassigned FLINK-35924: Assignee: Jiangjie Qin > Improve the SourceReaderBase to support the RecordsWithSplitIds

[jira] [Updated] (FLINK-35924) Improve the SourceReaderBase to support the RecordsWithSplitIds share internal buffer from SplitReader.

[ https://issues.apache.org/jira/browse/FLINK-35924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated FLINK-35924: - Description: Recently, we saw corrupted {{RecordsWithSplitIds}} in one of our Iceberg source im

[jira] [Updated] (FLINK-35924) Improve the SourceReaderBase to support the RecordsWithSplitIds share internal buffer from SplitReader.

[ https://issues.apache.org/jira/browse/FLINK-35924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated FLINK-35924: - Fix Version/s: 2.0.0 > Improve the SourceReaderBase to support the RecordsWithSplitIds share >

[jira] [Closed] (FLINK-35924) Improve the SourceReaderBase to support the RecordsWithSplitIds share internal buffer from SplitReader.

[ https://issues.apache.org/jira/browse/FLINK-35924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin closed FLINK-35924. Resolution: Implemented Merged to master: a15bf58da5442deeb07ac2a1795a961a0ec75561 > Improve the

[jira] [Updated] (FLINK-33681) Display source/sink numRecordsIn/Out & numBytesIn/Out on UI

[ https://issues.apache.org/jira/browse/FLINK-33681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated FLINK-33681: - Affects Version/s: 1.19.1 1.20.0 > Display source/sink numRecordsIn/Out &

[jira] [Resolved] (FLINK-33681) Display source/sink numRecordsIn/Out & numBytesIn/Out on UI

[ https://issues.apache.org/jira/browse/FLINK-33681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin resolved FLINK-33681. -- Fix Version/s: 2.0.0 Release Note: The Source and Sink IO metrics are not reported to the

[jira] [Updated] (FLINK-36265) List and track the deprecated APIs for the 2.0-preview release.

[ https://issues.apache.org/jira/browse/FLINK-36265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated FLINK-36265: - Fix Version/s: 2.0-preview > List and track the deprecated APIs for the 2.0-preview release. > -

[jira] [Assigned] (FLINK-36265) List and track the deprecated APIs for the 2.0-preview release.

[ https://issues.apache.org/jira/browse/FLINK-36265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin reassigned FLINK-36265: Assignee: Jiangjie Qin > List and track the deprecated APIs for the 2.0-preview release.

[jira] [Created] (FLINK-36265) List and track the deprecated APIs for the 2.0-preview release.

Jiangjie Qin created FLINK-36265: Summary: List and track the deprecated APIs for the 2.0-preview release. Key: FLINK-36265 URL: https://issues.apache.org/jira/browse/FLINK-36265 Project: Flink

[jira] [Commented] (FLINK-36146) NoSuchElement exception from SingleThreadFetcherManager

[ https://issues.apache.org/jira/browse/FLINK-36146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17881648#comment-17881648 ] Jiangjie Qin commented on FLINK-36146: -- Yes, this is an apparent race condition.  A

[jira] [Commented] (FLINK-36146) NoSuchElement exception from SingleThreadFetcherManager

[ https://issues.apache.org/jira/browse/FLINK-36146?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17881864#comment-17881864 ] Jiangjie Qin commented on FLINK-36146: -- Hi Kim, yes, the ConcurrentHashMap iterator

[jira] [Commented] (FLINK-33681) Display source/sink numRecordsIn/Out & numBytesIn/Out on UI

[ https://issues.apache.org/jira/browse/FLINK-33681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17850176#comment-17850176 ] Jiangjie Qin commented on FLINK-33681: -- [~Zhanghao Chen] Thanks for firing the tick

[jira] [Resolved] (FLINK-20767) [FLIP-356] Add nested field support for SupportsFilterPushDown

[ https://issues.apache.org/jira/browse/FLINK-20767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin resolved FLINK-20767. -- Fix Version/s: 1.19.0 Resolution: Implemented PR is merged to master: 5be4688e8b8a055b9

[jira] [Assigned] (FLINK-20431) KafkaSourceReaderTest.testCommitOffsetsWithoutAliveFetchers:133->lambda$testCommitOffsetsWithoutAliveFetchers$3:134 expected:<10> but was:<1>

[ https://issues.apache.org/jira/browse/FLINK-20431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin reassigned FLINK-20431: Assignee: Jiangjie Qin > KafkaSourceReaderTest.testCommitOffsetsWithoutAliveFetchers:133-

[jira] [Commented] (FLINK-20431) KafkaSourceReaderTest.testCommitOffsetsWithoutAliveFetchers:133->lambda$testCommitOffsetsWithoutAliveFetchers$3:134 expected:<10> but was:<1>

[ https://issues.apache.org/jira/browse/FLINK-20431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17241587#comment-17241587 ] Jiangjie Qin commented on FLINK-20431: -- The current test is a little ugly and fragi

[jira] [Assigned] (FLINK-20492) The SourceOperatorStreamTask should implement cancelTask() and finishTask()

[ https://issues.apache.org/jira/browse/FLINK-20492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin reassigned FLINK-20492: Assignee: Jiangjie Qin > The SourceOperatorStreamTask should implement cancelTask() and f

[jira] [Created] (FLINK-20492) The SourceOperatorStreamTask should implement cancelTask() and finishTask()

Jiangjie Qin created FLINK-20492: Summary: The SourceOperatorStreamTask should implement cancelTask() and finishTask() Key: FLINK-20492 URL: https://issues.apache.org/jira/browse/FLINK-20492 Project:

[jira] [Updated] (FLINK-20492) The SourceOperatorStreamTask should implement cancelTask() and finishTask()

[ https://issues.apache.org/jira/browse/FLINK-20492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated FLINK-20492: - Affects Version/s: (was: 1.12.0) > The SourceOperatorStreamTask should implement cancelTask(

[jira] [Updated] (FLINK-20492) The SourceOperatorStreamTask should implement cancelTask() and finishTask()

[ https://issues.apache.org/jira/browse/FLINK-20492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated FLINK-20492: - Fix Version/s: 1.12.0 > The SourceOperatorStreamTask should implement cancelTask() and finishTas

[jira] [Updated] (FLINK-20492) The SourceOperatorStreamTask should implement cancelTask() and finishTask()

[ https://issues.apache.org/jira/browse/FLINK-20492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated FLINK-20492: - Description: The {{SourceOperatorStreamTask}} does not implement {{cancelTask}} and {{finishTas

[jira] [Updated] (FLINK-19448) CoordinatedSourceITCase.testEnumeratorReaderCommunication hangs

[ https://issues.apache.org/jira/browse/FLINK-19448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated FLINK-19448: - Fix Version/s: 1.11.3 > CoordinatedSourceITCase.testEnumeratorReaderCommunication hangs > --

[jira] [Updated] (FLINK-20081) ExecutorNotifier should run handler in the main thread when receive an exception from the callable.

[ https://issues.apache.org/jira/browse/FLINK-20081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated FLINK-20081: - Fix Version/s: 1.11.3 > ExecutorNotifier should run handler in the main thread when receive an

[jira] [Resolved] (FLINK-19717) SourceReaderBase.pollNext may return END_OF_INPUT if SplitReader.fetch throws

[ https://issues.apache.org/jira/browse/FLINK-19717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin resolved FLINK-19717. -- Fix Version/s: (was: 1.13.0) 1.12.0 Resolution: Fixed Merged to

[jira] [Updated] (FLINK-19698) Add close() method and onCheckpointComplete() to the Source.

[ https://issues.apache.org/jira/browse/FLINK-19698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated FLINK-19698: - Fix Version/s: (was: 1.13.0) 1.12.0 > Add close() method and onCheckpoint

[jira] [Resolved] (FLINK-19698) Add close() method and onCheckpointComplete() to the Source.

[ https://issues.apache.org/jira/browse/FLINK-19698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin resolved FLINK-19698. -- Resolution: Fixed merged to release-1.11 2d074715a13a1a638ddd2a7dd138ae94d0ca04f8 > Add close

[jira] [Resolved] (FLINK-19253) SourceReaderTestBase.testAddSplitToExistingFetcher hangs

[ https://issues.apache.org/jira/browse/FLINK-19253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin resolved FLINK-19253. -- Fix Version/s: (was: 1.13.0) 1.12.0 Resolution: Fixed Merged to

[jira] [Updated] (FLINK-19717) SourceReaderBase.pollNext may return END_OF_INPUT if SplitReader.fetch throws

[ https://issues.apache.org/jira/browse/FLINK-19717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated FLINK-19717: - Affects Version/s: (was: 1.12.0) 1.11.2 > SourceReaderBase.pollNext m

[jira] [Updated] (FLINK-19253) SourceReaderTestBase.testAddSplitToExistingFetcher hangs

[ https://issues.apache.org/jira/browse/FLINK-19253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated FLINK-19253: - Affects Version/s: (was: 1.12.0) 1.11.2 > SourceReaderTestBase.testAd

[jira] [Commented] (FLINK-20492) The SourceOperatorStreamTask should implement cancelTask() and finishTask()

[ https://issues.apache.org/jira/browse/FLINK-20492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17246933#comment-17246933 ] Jiangjie Qin commented on FLINK-20492: -- Per discussion in the [PR|https://github.co

[jira] [Updated] (FLINK-20492) The SourceOperatorStreamTask should implement cancelTask() and finishTask()

[ https://issues.apache.org/jira/browse/FLINK-20492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated FLINK-20492: - Affects Version/s: 1.11.3 1.12.0 > The SourceOperatorStreamTask should im

[jira] [Resolved] (FLINK-20492) The SourceOperatorStreamTask should implement cancelTask() and finishTask()

[ https://issues.apache.org/jira/browse/FLINK-20492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin resolved FLINK-20492. -- Resolution: Fixed > The SourceOperatorStreamTask should implement cancelTask() and finishTask(

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

Jiangjie Qin created FLINK-20655: Summary: Add E2E tests to the new KafkaSource based on FLIP-27. Key: FLINK-20655 URL: https://issues.apache.org/jira/browse/FLINK-20655 Project: Flink Issue

[jira] [Updated] (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 ] Jiangjie Qin updated FLINK-20655: - Fix Version/s: 1.12.1 > Add E2E tests to the new KafkaSource based on FLIP-27. > ---

[jira] [Assigned] (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 ] Jiangjie Qin reassigned FLINK-20655: Assignee: Qingsheng Ren > Add E2E tests to the new KafkaSource based on FLIP-27. > --

[jira] [Updated] (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 ] Jiangjie Qin updated FLINK-20655: - Fix Version/s: 1.13.0 > Add E2E tests to the new KafkaSource based on FLIP-27. > ---

[jira] [Assigned] (FLINK-20656) Update docs for new KafkaSource connector.

[ https://issues.apache.org/jira/browse/FLINK-20656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin reassigned FLINK-20656: Assignee: Jiangjie Qin > Update docs for new KafkaSource connector. > ---

[jira] [Updated] (FLINK-20656) Update docs for new KafkaSource connector.

[ https://issues.apache.org/jira/browse/FLINK-20656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated FLINK-20656: - Fix Version/s: 1.12.1 1.13.0 > Update docs for new KafkaSource connector. > -

[jira] [Created] (FLINK-20656) Update docs for new KafkaSource connector.

Jiangjie Qin created FLINK-20656: Summary: Update docs for new KafkaSource connector. Key: FLINK-20656 URL: https://issues.apache.org/jira/browse/FLINK-20656 Project: Flink Issue Type: Task

[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&focusedCommentId=17251099#comment-17251099 ] Jiangjie Qin commented on FLINK-18578: -- This feature sounds reasonable to me. I agr

[jira] [Closed] (FLINK-16848) Improve the performance of the RecordsWithSplitIds queue.

[ https://issues.apache.org/jira/browse/FLINK-16848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin closed FLINK-16848. Resolution: Won't Fix > Improve the performance of the RecordsWithSplitIds queue. > --

[jira] [Commented] (FLINK-16848) Improve the performance of the RecordsWithSplitIds queue.

[ https://issues.apache.org/jira/browse/FLINK-16848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17226440#comment-17226440 ] Jiangjie Qin commented on FLINK-16848: -- Sure. Closing the ticket. > Improve the pe

[jira] [Updated] (FLINK-19698) Add close() method and onCheckpointComplete() to the Source.

[ https://issues.apache.org/jira/browse/FLINK-19698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated FLINK-19698: - Fix Version/s: 1.12.0 > Add close() method and onCheckpointComplete() to the Source. > -

[jira] [Commented] (FLINK-19698) Add close() method and onCheckpointComplete() to the Source.

[ https://issues.apache.org/jira/browse/FLINK-19698?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17226772#comment-17226772 ] Jiangjie Qin commented on FLINK-19698: -- Merged to master: 7ea3a6040dafd15733162447c

[jira] [Resolved] (FLINK-18323) Implement a Kafka Source based on new Source API

[ https://issues.apache.org/jira/browse/FLINK-18323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin resolved FLINK-18323. -- Fix Version/s: 1.12.0 Resolution: Implemented Patch merged to master. 80c040fcf3118a520

[jira] [Commented] (FLINK-19717) SourceReaderBase.pollNext may return END_OF_INPUT if SplitReader.fetch throws

[ https://issues.apache.org/jira/browse/FLINK-19717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17228328#comment-17228328 ] Jiangjie Qin commented on FLINK-19717: -- [~sewen] I have merged the patch to master.

[jira] [Commented] (FLINK-20050) SourceCoordinatorProviderTest.testCheckpointAndReset failed with NullPointerException

[ https://issues.apache.org/jira/browse/FLINK-20050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17228739#comment-17228739 ] Jiangjie Qin commented on FLINK-20050: -- [~xuannan] Yes, you are right. The methods

[jira] [Commented] (FLINK-19253) SourceReaderTestBase.testAddSplitToExistingFetcher hangs

[ https://issues.apache.org/jira/browse/FLINK-19253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17229011#comment-17229011 ] Jiangjie Qin commented on FLINK-19253: -- [~xuannan] Good catch. Will you submit a fi

[jira] [Commented] (FLINK-20050) SourceCoordinatorProviderTest.testCheckpointAndReset failed with NullPointerException

[ https://issues.apache.org/jira/browse/FLINK-20050?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17229014#comment-17229014 ] Jiangjie Qin commented on FLINK-20050: -- Merged to master:  ae09f9be438736763db12993

[jira] [Resolved] (FLINK-20050) SourceCoordinatorProviderTest.testCheckpointAndReset failed with NullPointerException

[ https://issues.apache.org/jira/browse/FLINK-20050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin resolved FLINK-20050. -- Resolution: Fixed > SourceCoordinatorProviderTest.testCheckpointAndReset failed with > NullPo

[jira] [Assigned] (FLINK-19253) SourceReaderTestBase.testAddSplitToExistingFetcher hangs

[ https://issues.apache.org/jira/browse/FLINK-19253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin reassigned FLINK-19253: Assignee: Xuannan Su > SourceReaderTestBase.testAddSplitToExistingFetcher hangs > ---

[jira] [Commented] (FLINK-20070) NPE in SourceCoordinatorProviderTest.testCheckpointAndReset

[ https://issues.apache.org/jira/browse/FLINK-20070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17229118#comment-17229118 ] Jiangjie Qin commented on FLINK-20070: -- [~godfreyhe] Thanks for reporting the issue

[jira] [Commented] (FLINK-20068) KafkaSubscriberTest.testTopicPatternSubscriber failed with unexpected results

[ https://issues.apache.org/jira/browse/FLINK-20068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17229245#comment-17229245 ] Jiangjie Qin commented on FLINK-20068: -- [~rmetzger] Checking... > KafkaSubscriberT

[jira] [Updated] (FLINK-20081) ExecutorNotifier should run handler in the main thread when receive an exception from the callable.

[ https://issues.apache.org/jira/browse/FLINK-20081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated FLINK-20081: - Fix Version/s: 1.11.3 > ExecutorNotifier should run handler in the main thread when receive an

[jira] [Created] (FLINK-20081) ExecutorNotifier should run handler in the main thread when receive an exception from the callable.

Jiangjie Qin created FLINK-20081: Summary: ExecutorNotifier should run handler in the main thread when receive an exception from the callable. Key: FLINK-20081 URL: https://issues.apache.org/jira/browse/FLINK-2008

[jira] [Assigned] (FLINK-20081) ExecutorNotifier should run handler in the main thread when receive an exception from the callable.

[ https://issues.apache.org/jira/browse/FLINK-20081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin reassigned FLINK-20081: Assignee: Jiangjie Qin > ExecutorNotifier should run handler in the main thread when rece

[jira] [Updated] (FLINK-20081) ExecutorNotifier should run handler in the main thread when receive an exception from the callable.

[ https://issues.apache.org/jira/browse/FLINK-20081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated FLINK-20081: - Affects Version/s: 1.11.2 > ExecutorNotifier should run handler in the main thread when receive

[jira] [Updated] (FLINK-20081) ExecutorNotifier should run handler in the main thread when receive an exception from the callable.

[ https://issues.apache.org/jira/browse/FLINK-20081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated FLINK-20081: - Fix Version/s: 1.12.0 > ExecutorNotifier should run handler in the main thread when receive an

[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&focusedCommentId=17229761#comment-17229761 ] Jiangjie Qin commented on FLINK-13733: -- The patch has been merged to master. cb2d13

[jira] [Resolved] (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 resolved FLINK-13733. -- Fix Version/s: 1.11.3 Resolution: Fixed > FlinkKafkaInternalProducerITCase.testHappyPat

[jira] [Commented] (FLINK-20068) KafkaSubscriberTest.testTopicPatternSubscriber failed with unexpected results

[ https://issues.apache.org/jira/browse/FLINK-20068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17229763#comment-17229763 ] Jiangjie Qin commented on FLINK-20068: -- This is a legacy issue caused by asynchrono

[jira] [Assigned] (FLINK-20068) KafkaSubscriberTest.testTopicPatternSubscriber failed with unexpected results

[ https://issues.apache.org/jira/browse/FLINK-20068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin reassigned FLINK-20068: Assignee: Jiangjie Qin > KafkaSubscriberTest.testTopicPatternSubscriber failed with unexp

[jira] [Resolved] (FLINK-20068) KafkaSubscriberTest.testTopicPatternSubscriber failed with unexpected results

[ https://issues.apache.org/jira/browse/FLINK-20068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin resolved FLINK-20068. -- Fix Version/s: 1.11.3 Resolution: Fixed Merged to master. cacb4c1fb1d6123d0aeb93d550ffc

[jira] [Commented] (FLINK-19253) SourceReaderTestBase.testAddSplitToExistingFetcher hangs

[ https://issues.apache.org/jira/browse/FLINK-19253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17229865#comment-17229865 ] Jiangjie Qin commented on FLINK-19253: -- Looking at the code, I think there might be

[jira] [Commented] (FLINK-19253) SourceReaderTestBase.testAddSplitToExistingFetcher hangs

[ https://issues.apache.org/jira/browse/FLINK-19253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17229991#comment-17229991 ] Jiangjie Qin commented on FLINK-19253: -- [~xuannan] Thanks for digging into this. Ye

[jira] [Comment Edited] (FLINK-19253) SourceReaderTestBase.testAddSplitToExistingFetcher hangs

[ https://issues.apache.org/jira/browse/FLINK-19253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17229991#comment-17229991 ] Jiangjie Qin edited comment on FLINK-19253 at 11/11/20, 2:34 PM: -

[jira] [Updated] (FLINK-20108) SingleThreadFetcherManager may add splits to a shutting down SplitFetcher

[ https://issues.apache.org/jira/browse/FLINK-20108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated FLINK-20108: - Fix Version/s: 1.11.3 1.12.0 > SingleThreadFetcherManager may add splits to a

[jira] [Created] (FLINK-20108) SingleThreadFetcherManager may add splits to a shutting down SplitFetcher

Jiangjie Qin created FLINK-20108: Summary: SingleThreadFetcherManager may add splits to a shutting down SplitFetcher Key: FLINK-20108 URL: https://issues.apache.org/jira/browse/FLINK-20108 Project: Fl

[jira] [Assigned] (FLINK-20108) SingleThreadFetcherManager may add splits to a shutting down SplitFetcher

[ https://issues.apache.org/jira/browse/FLINK-20108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin reassigned FLINK-20108: Assignee: Jiangjie Qin > SingleThreadFetcherManager may add splits to a shutting down Spl

[jira] [Updated] (FLINK-20108) SingleThreadFetcherManager may add splits to a shutting down SplitFetcher

[ https://issues.apache.org/jira/browse/FLINK-20108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated FLINK-20108: - Fix Version/s: (was: 1.12.0) > SingleThreadFetcherManager may add splits to a shutting down

[jira] [Updated] (FLINK-20108) SingleThreadFetcherManager may add splits to a shutting down SplitFetcher

[ https://issues.apache.org/jira/browse/FLINK-20108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated FLINK-20108: - Description: Currently the split fetchers are only removed from the {{SplitFetcherManager.fetch

[jira] [Updated] (FLINK-19253) SourceReaderTestBase.testAddSplitToExistingFetcher hangs

[ https://issues.apache.org/jira/browse/FLINK-19253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated FLINK-19253: - Fix Version/s: 1.11.3 > SourceReaderTestBase.testAddSplitToExistingFetcher hangs > -

[jira] [Commented] (FLINK-19253) SourceReaderTestBase.testAddSplitToExistingFetcher hangs

[ https://issues.apache.org/jira/browse/FLINK-19253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17230685#comment-17230685 ] Jiangjie Qin commented on FLINK-19253: -- Yes, that has been fixed. Thanks for adding

[jira] [Assigned] (FLINK-20114) Test Kafka Source based on the new Source API 

[ https://issues.apache.org/jira/browse/FLINK-20114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin reassigned FLINK-20114: Assignee: Jiangjie Qin > Test Kafka Source based on the new Source API  > ---

[jira] [Commented] (FLINK-20159) [FLIP-27 source] FutureNotifier does not return a new future when Future::future() is invoked within the returned future's callback

[ https://issues.apache.org/jira/browse/FLINK-20159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17231924#comment-17231924 ] Jiangjie Qin commented on FLINK-20159: -- [~sundaram] Thanks for reporting the issue.

[jira] [Commented] (FLINK-20158) KafkaSource does not implement ResultTypeQueryable

[ https://issues.apache.org/jira/browse/FLINK-20158?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17232779#comment-17232779 ] Jiangjie Qin commented on FLINK-20158: -- [~rmetzger] Thanks for the suggestion. That

  1   2   3   4   5   6   >