[jira] [Commented] (FLINK-35564) The topic cannot be distributed on subtask when calculatePartitionOwner returns -1

[ https://issues.apache.org/jira/browse/FLINK-35564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17854929#comment-17854929 ] Yufan Sheng commented on FLINK-35564: - Hi, thanks for mention this. I think this bug

[jira] [Commented] (FLINK-35064) Flink sql connector pulsar/hive com.fasterxml.jackson.annotation.JsonFormat$Value conflict

[ https://issues.apache.org/jira/browse/FLINK-35064?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837068#comment-17837068 ] Yufan Sheng commented on FLINK-35064: - I have made a comment in the related PR. I ju

[jira] [Commented] (FLINK-34436) Avro schema evolution and compatibility issues in Pulsar connector

[ https://issues.apache.org/jira/browse/FLINK-34436?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837073#comment-17837073 ] Yufan Sheng commented on FLINK-34436: - I think this is not a issue. It's just a desi

[jira] [Commented] (FLINK-34414) EXACTLY_ONCE guarantee doesn't work properly for Flink/Pulsar connector

[ https://issues.apache.org/jira/browse/FLINK-34414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837079#comment-17837079 ] Yufan Sheng commented on FLINK-34414: - I don't think this is a issue from my side. F

[jira] [Commented] (FLINK-34962) flink-connector-pulsa starts failed due to incorrect use of Pulsar API: LookupService. getPartitionedTopicMetadata

[ https://issues.apache.org/jira/browse/FLINK-34962?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837080#comment-17837080 ] Yufan Sheng commented on FLINK-34962: - [~Tison] This issue should be marked resolved

[jira] [Commented] (FLINK-35064) Flink sql connector pulsar/hive com.fasterxml.jackson.annotation.JsonFormat$Value conflict

[ https://issues.apache.org/jira/browse/FLINK-35064?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837107#comment-17837107 ] Yufan Sheng commented on FLINK-35064: - AFAICS, the {{pulsar-client-all}} should be r

[jira] [Commented] (FLINK-34436) Avro schema evolution and compatibility issues in Pulsar connector

[ https://issues.apache.org/jira/browse/FLINK-34436?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837148#comment-17837148 ] Yufan Sheng commented on FLINK-34436: - If you want to consume all the messages with

[jira] [Commented] (FLINK-34091) Flink pulsar connect add automatic failover capability

[ https://issues.apache.org/jira/browse/FLINK-34091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837152#comment-17837152 ] Yufan Sheng commented on FLINK-34091: - Since this is a requirement from Pulsar side.

[jira] [Commented] (FLINK-33729) Events are getting lost when an exception occurs within a processing function

[ https://issues.apache.org/jira/browse/FLINK-33729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837157#comment-17837157 ] Yufan Sheng commented on FLINK-33729: - [~Weijie Guo] Yep, this is a valid ticket. Bu

[jira] [Commented] (FLINK-33486) Pulsar Client Send Timeout Terminates TaskManager

[ https://issues.apache.org/jira/browse/FLINK-33486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837160#comment-17837160 ] Yufan Sheng commented on FLINK-33486: - The retry logic is internally provided by the

[jira] [Commented] (FLINK-33136) Flink Pulsar Connector RoundRobinTopicRouter Generates Invalid Error Message

[ https://issues.apache.org/jira/browse/FLINK-33136?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837161#comment-17837161 ] Yufan Sheng commented on FLINK-33136: - Yep, I think you are right. We should use mor

[jira] [Commented] (FLINK-32645) Flink pulsar sink is having poor performance

[ https://issues.apache.org/jira/browse/FLINK-32645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17837162#comment-17837162 ] Yufan Sheng commented on FLINK-32645: - [~tison] I think we can close this issue now.

[jira] [Commented] (FLINK-23969) Test Pulsar source end 2 end

[ https://issues.apache.org/jira/browse/FLINK-23969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17405544#comment-17405544 ] Yufan Sheng commented on FLINK-23969: - [~Jiangang] Hi Liu, I'm very happy to see you

[jira] [Commented] (FLINK-24030) PulsarSourceITCase>SourceTestSuiteBase.testMultipleSplits failed

[ https://issues.apache.org/jira/browse/FLINK-24030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17405864#comment-17405864 ] Yufan Sheng commented on FLINK-24030: - [~pnowojski] This is a duplicated issue compa

[jira] [Commented] (FLINK-24030) PulsarSourceITCase>SourceTestSuiteBase.testMultipleSplits failed

[ https://issues.apache.org/jira/browse/FLINK-24030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17406039#comment-17406039 ] Yufan Sheng commented on FLINK-24030: - [~pnowojski] All the build failure are listed

[jira] [Commented] (FLINK-23848) PulsarSourceITCase is failed on Azure

[ https://issues.apache.org/jira/browse/FLINK-23848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17409351#comment-17409351 ] Yufan Sheng commented on FLINK-23848: - [~xtsong] The test failure should be fixed in

[jira] [Comment Edited] (FLINK-23848) PulsarSourceITCase is failed on Azure

[ https://issues.apache.org/jira/browse/FLINK-23848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17409351#comment-17409351 ] Yufan Sheng edited comment on FLINK-23848 at 9/3/21, 8:02 AM:

[jira] [Commented] (FLINK-23864) The document for Pulsar Source

[ https://issues.apache.org/jira/browse/FLINK-23864?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17411434#comment-17411434 ] Yufan Sheng commented on FLINK-23864: - [~xtsong] [~joemoe] Tks for your help, the do

[jira] [Commented] (FLINK-23969) Test Pulsar source end 2 end

[ https://issues.apache.org/jira/browse/FLINK-23969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17411435#comment-17411435 ] Yufan Sheng commented on FLINK-23969: - [~Jiangang] Here is a [sample project|https:

[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&focusedCommentId=17411632#comment-17411632 ] Yufan Sheng commented on FLINK-23944: - [~renqs] Tks for your investigation, I suck w

[jira] [Commented] (FLINK-24012) PulsarSourceITCase.testTaskManagerFailure fails due to NoResourceAvailableException

[ https://issues.apache.org/jira/browse/FLINK-24012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17412013#comment-17412013 ] Yufan Sheng commented on FLINK-24012: - [~xtsong] This issue is caused by https://is

[jira] [Commented] (FLINK-20731) Pulsar Source

[ https://issues.apache.org/jira/browse/FLINK-20731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17400967#comment-17400967 ] Yufan Sheng commented on FLINK-20731: - [~joemoe] OK, document and test. I'll do it.

[jira] [Commented] (FLINK-20731) Pulsar Source

[ https://issues.apache.org/jira/browse/FLINK-20731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17401170#comment-17401170 ] Yufan Sheng commented on FLINK-20731: - [~arvid] Tks for your detailed clarification.

[jira] [Created] (FLINK-23864) The document for Pulsar Source

Yufan Sheng created FLINK-23864: --- Summary: The document for Pulsar Source Key: FLINK-23864 URL: https://issues.apache.org/jira/browse/FLINK-23864 Project: Flink Issue Type: Sub-task Affects

[jira] [Created] (FLINK-23877) Embedded Pulsar broker backend for testing

Yufan Sheng created FLINK-23877: --- Summary: Embedded Pulsar broker backend for testing Key: FLINK-23877 URL: https://issues.apache.org/jira/browse/FLINK-23877 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-23848) PulsarSourceITCase is failed on Azure

[ https://issues.apache.org/jira/browse/FLINK-23848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17402114#comment-17402114 ] Yufan Sheng commented on FLINK-23848: - [~trohrmann] I have read all the test report,

[jira] [Comment Edited] (FLINK-20726) Introduce Pulsar connector

[ https://issues.apache.org/jira/browse/FLINK-20726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17402252#comment-17402252 ] Yufan Sheng edited comment on FLINK-20726 at 8/20/21, 2:42 PM: ---

[jira] [Commented] (FLINK-20726) Introduce Pulsar connector

[ https://issues.apache.org/jira/browse/FLINK-20726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17402252#comment-17402252 ] Yufan Sheng commented on FLINK-20726: - [~ nicholasjiang] Pulsar Sink is still under

[jira] [Commented] (FLINK-23969) Test Pulsar source end 2 end

[ https://issues.apache.org/jira/browse/FLINK-23969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17412938#comment-17412938 ] Yufan Sheng commented on FLINK-23969: - [~Jiangang] Any progress on this e2e test? >

[jira] [Commented] (FLINK-24206) PulsarSourceITCase fails with "Consumer not found"

[ https://issues.apache.org/jira/browse/FLINK-24206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17412973#comment-17412973 ] Yufan Sheng commented on FLINK-24206: - This could be some bugs on the Pulsar side. I

[jira] [Created] (FLINK-24246) Bump Pulsar to 2.8.1

Yufan Sheng created FLINK-24246: --- Summary: Bump Pulsar to 2.8.1 Key: FLINK-24246 URL: https://issues.apache.org/jira/browse/FLINK-24246 Project: Flink Issue Type: Improvement Componen

[jira] [Commented] (FLINK-24246) Bump Pulsar to 2.8.1

[ https://issues.apache.org/jira/browse/FLINK-24246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17413060#comment-17413060 ] Yufan Sheng commented on FLINK-24246: - [~arvid] Can you assign this issue to me? >

[jira] [Commented] (FLINK-23969) Test Pulsar source end 2 end

[ https://issues.apache.org/jira/browse/FLINK-23969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17413468#comment-17413468 ] Yufan Sheng commented on FLINK-23969: - [~Jiangang] Just add my wechat: syhily. We ca

[jira] [Commented] (FLINK-23969) Test Pulsar source end 2 end

[ https://issues.apache.org/jira/browse/FLINK-23969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17413551#comment-17413551 ] Yufan Sheng commented on FLINK-23969: - [~Jiangang] I have written a e2e test code sa

[jira] [Comment Edited] (FLINK-23969) Test Pulsar source end 2 end

[ https://issues.apache.org/jira/browse/FLINK-23969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17413551#comment-17413551 ] Yufan Sheng edited comment on FLINK-23969 at 9/11/21, 4:33 PM: ---

[jira] [Commented] (FLINK-24263) PulsarSourceITCase.testMultipleSplits fails due to "Consumer not found"

[ https://issues.apache.org/jira/browse/FLINK-24263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17414010#comment-17414010 ] Yufan Sheng commented on FLINK-24263: - [~xtsong] Duplicated by https://issues.apache

[jira] [Commented] (FLINK-24206) PulsarSourceITCase fails with "Consumer not found"

[ https://issues.apache.org/jira/browse/FLINK-24206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17414011#comment-17414011 ] Yufan Sheng commented on FLINK-24206: - It's a race condition on pulsar source close.

[jira] [Comment Edited] (FLINK-24206) PulsarSourceITCase fails with "Consumer not found"

[ https://issues.apache.org/jira/browse/FLINK-24206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17414011#comment-17414011 ] Yufan Sheng edited comment on FLINK-24206 at 9/13/21, 8:22 AM: ---

[jira] [Commented] (FLINK-24206) PulsarSourceITCase fails with "Consumer not found"

[ https://issues.apache.org/jira/browse/FLINK-24206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17414030#comment-17414030 ] Yufan Sheng commented on FLINK-24206: - [~xtsong] Can you review this PR? https://git

[jira] [Commented] (FLINK-24206) PulsarSourceITCase fails with "Consumer not found"

[ https://issues.apache.org/jira/browse/FLINK-24206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17414049#comment-17414049 ] Yufan Sheng commented on FLINK-24206: - [~xtsong] OK, I'll open a new PR that targets

[jira] [Commented] (FLINK-23969) Test Pulsar source end 2 end

[ https://issues.apache.org/jira/browse/FLINK-23969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17414587#comment-17414587 ] Yufan Sheng commented on FLINK-23969: - [~xtsong] The e2e test PR is ready. Can you r

[jira] [Comment Edited] (FLINK-23969) Test Pulsar source end 2 end

[ https://issues.apache.org/jira/browse/FLINK-23969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17414587#comment-17414587 ] Yufan Sheng edited comment on FLINK-23969 at 9/13/21, 9:43 PM: ---

[jira] [Commented] (FLINK-23969) Test Pulsar source end 2 end

[ https://issues.apache.org/jira/browse/FLINK-23969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17414706#comment-17414706 ] Yufan Sheng commented on FLINK-23969: - [~xtsong] Arvid is on holiday. Can you review

[jira] [Commented] (FLINK-23969) Test Pulsar source end 2 end

[ https://issues.apache.org/jira/browse/FLINK-23969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17414950#comment-17414950 ] Yufan Sheng commented on FLINK-23969: - [~dwysakowicz] OK, but some bugfix needs to p

[jira] [Created] (FLINK-24283) Pulsar connector won't use given hash ranges in Key_Shared mode

Yufan Sheng created FLINK-24283: --- Summary: Pulsar connector won't use given hash ranges in Key_Shared mode Key: FLINK-24283 URL: https://issues.apache.org/jira/browse/FLINK-24283 Project: Flink

[jira] [Updated] (FLINK-24283) Pulsar connector won't use given hash ranges in Key_Shared mode

[ https://issues.apache.org/jira/browse/FLINK-24283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yufan Sheng updated FLINK-24283: Priority: Critical (was: Major) > Pulsar connector won't use given hash ranges in Key_Shared mode

[jira] [Commented] (FLINK-23969) Test Pulsar source end 2 end

[ https://issues.apache.org/jira/browse/FLINK-23969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17414966#comment-17414966 ] Yufan Sheng commented on FLINK-23969: - [~dwysakowicz] OK, I mean. The [bug|https://

[jira] [Commented] (FLINK-24283) Pulsar connector won't use given hash ranges in Key_Shared mode

[ https://issues.apache.org/jira/browse/FLINK-24283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17414970#comment-17414970 ] Yufan Sheng commented on FLINK-24283: - [~dwysakowicz] Can you assign this issue to m

[jira] [Commented] (FLINK-24283) Pulsar connector won't use given hash ranges in Key_Shared mode

[ https://issues.apache.org/jira/browse/FLINK-24283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17414991#comment-17414991 ] Yufan Sheng commented on FLINK-24283: - [~dwysakowicz] Can you review the PR for this

[jira] [Created] (FLINK-24302) Direct buffer memory leak on Pulsar connector with Java 11

Yufan Sheng created FLINK-24302: --- Summary: Direct buffer memory leak on Pulsar connector with Java 11 Key: FLINK-24302 URL: https://issues.apache.org/jira/browse/FLINK-24302 Project: Flink Issu

[jira] [Commented] (FLINK-24329) PulsarSourceITCase fails due to port conflict

[ https://issues.apache.org/jira/browse/FLINK-24329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17417691#comment-17417691 ] Yufan Sheng commented on FLINK-24329: - [~xmarker] Yep, you are right. > PulsarSourc

[jira] [Commented] (FLINK-24329) PulsarSourceITCase fails due to port conflict

[ https://issues.apache.org/jira/browse/FLINK-24329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17417692#comment-17417692 ] Yufan Sheng commented on FLINK-24329: - [~xtsong] Can we also backport this to the 1.

[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&focusedCommentId=17418244#comment-17418244 ] Yufan Sheng commented on FLINK-23944: - [~dwysakowicz] OK, just assign it to me. I'l

[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&focusedCommentId=17441350#comment-17441350 ] Yufan Sheng commented on FLINK-23944: - [~trohrmann] I think this test failure should

[jira] [Commented] (FLINK-23848) PulsarSourceITCase is failed on Azure

[ https://issues.apache.org/jira/browse/FLINK-23848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17441511#comment-17441511 ] Yufan Sheng commented on FLINK-23848: - [~gaoyunhaii] I think this is a new issue cau

[jira] [Commented] (FLINK-24449) PulsarSourceITCase>SourceTestSuiteBase.testTaskManagerFailure fails with record mismatch

[ https://issues.apache.org/jira/browse/FLINK-24449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17441513#comment-17441513 ] Yufan Sheng commented on FLINK-24449: - Hi [~dwysakowicz], this issue is the same as

[jira] [Comment Edited] (FLINK-23848) PulsarSourceITCase is failed on Azure

[ https://issues.apache.org/jira/browse/FLINK-23848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17441511#comment-17441511 ] Yufan Sheng edited comment on FLINK-23848 at 11/10/21, 6:01 AM: --

[jira] [Comment Edited] (FLINK-24668) Pulsar consumption data repeated output

[ https://issues.apache.org/jira/browse/FLINK-24668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17441566#comment-17441566 ] Yufan Sheng edited comment on FLINK-24668 at 11/10/21, 8:22 AM: --

[jira] [Commented] (FLINK-24668) Pulsar consumption data repeated output

[ https://issues.apache.org/jira/browse/FLINK-24668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17441566#comment-17441566 ] Yufan Sheng commented on FLINK-24668: - Hi [~余嘉悦], I can understand what you have sai

[jira] [Comment Edited] (FLINK-24668) Pulsar consumption data repeated output

[ https://issues.apache.org/jira/browse/FLINK-24668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17441566#comment-17441566 ] Yufan Sheng edited comment on FLINK-24668 at 11/10/21, 8:22 AM: --

[jira] [Commented] (FLINK-24872) PulsarSourceITCase.testMultipleSplits failed on AZP

[ https://issues.apache.org/jira/browse/FLINK-24872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17442801#comment-17442801 ] Yufan Sheng commented on FLINK-24872: - Tks, I'm trying to figure out the cause. > P

[jira] [Updated] (FLINK-24246) Bump Pulsar to 2.9.0

[ https://issues.apache.org/jira/browse/FLINK-24246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yufan Sheng updated FLINK-24246: Summary: Bump Pulsar to 2.9.0 (was: Bump Pulsar to 2.8.1) > Bump Pulsar to 2.9.0 > --

[jira] [Commented] (FLINK-24246) Bump Pulsar to 2.9.0

[ https://issues.apache.org/jira/browse/FLINK-24246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17442803#comment-17442803 ] Yufan Sheng commented on FLINK-24246: - I'm waiting for the Pulsar 2.9.0 release. >

[jira] [Comment Edited] (FLINK-24872) PulsarSourceITCase.testMultipleSplits failed on AZP

[ https://issues.apache.org/jira/browse/FLINK-24872?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17442801#comment-17442801 ] Yufan Sheng edited comment on FLINK-24872 at 11/12/21, 3:21 PM: --

[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&focusedCommentId=17443228#comment-17443228 ] Yufan Sheng commented on FLINK-23944: - Since FLINK-24733 has been fixed. Let's keep

[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&focusedCommentId=17444344#comment-17444344 ] Yufan Sheng commented on FLINK-23944: - [~gaoyunhaii] OK, I'm working on this. > Pul

[jira] [Commented] (FLINK-25013) flink pulsar connector cannot consume deferred messages

[ https://issues.apache.org/jira/browse/FLINK-25013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17448401#comment-17448401 ] Yufan Sheng commented on FLINK-25013: - I see. But I don't this is a bug. Delayed mes

[jira] [Updated] (FLINK-25013) flink pulsar connector cannot consume deferred messages

[ https://issues.apache.org/jira/browse/FLINK-25013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yufan Sheng updated FLINK-25013: Attachment: screenshot-1.png > flink pulsar connector cannot consume deferred messages > -

[jira] [Commented] (FLINK-25013) flink pulsar connector cannot consume deferred messages

[ https://issues.apache.org/jira/browse/FLINK-25013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17448430#comment-17448430 ] Yufan Sheng commented on FLINK-25013: - !screenshot-1.png! The test passed on my lo

[jira] [Comment Edited] (FLINK-25013) flink pulsar connector cannot consume deferred messages

[ https://issues.apache.org/jira/browse/FLINK-25013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17448430#comment-17448430 ] Yufan Sheng edited comment on FLINK-25013 at 11/24/21, 8:19 AM: --

[jira] [Updated] (FLINK-24246) Bump Pulsar to 2.9.1

[ https://issues.apache.org/jira/browse/FLINK-24246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yufan Sheng updated FLINK-24246: Fix Version/s: 1.16.0 (was: 1.15.0) > Bump Pulsar to 2.9.1 > --

[jira] [Updated] (FLINK-24246) Bump PulsarClient to 2.9.1 with better transaction management

[ https://issues.apache.org/jira/browse/FLINK-24246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yufan Sheng updated FLINK-24246: Summary: Bump PulsarClient to 2.9.1 with better transaction management (was: Bump Pulsar to 2.9.1

[jira] [Updated] (FLINK-24246) Bump PulsarClient to 2.9.1 with better transaction management

[ https://issues.apache.org/jira/browse/FLINK-24246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yufan Sheng updated FLINK-24246: Description: Pulsar 2.9.1 has been released, the hack for getting TxnID from Pulsar Transaction in

[jira] [Created] (FLINK-26020) Unified Pulsar Connector config model

Yufan Sheng created FLINK-26020: --- Summary: Unified Pulsar Connector config model Key: FLINK-26020 URL: https://issues.apache.org/jira/browse/FLINK-26020 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-24246) Bump PulsarClient to 2.9.1 with better transaction management

[ https://issues.apache.org/jira/browse/FLINK-24246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yufan Sheng updated FLINK-24246: Fix Version/s: 1.16.0 > Bump PulsarClient to 2.9.1 with better transaction management > --

[jira] [Created] (FLINK-26021) Pulsar topic deduplicated in both sink and source connector

Yufan Sheng created FLINK-26021: --- Summary: Pulsar topic deduplicated in both sink and source connector Key: FLINK-26021 URL: https://issues.apache.org/jira/browse/FLINK-26021 Project: Flink Is

[jira] [Updated] (FLINK-26020) Unified Pulsar Connector config model

[ https://issues.apache.org/jira/browse/FLINK-26020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yufan Sheng updated FLINK-26020: Fix Version/s: (was: 1.16.0) > Unified Pulsar Connector config model > ---

[jira] [Updated] (FLINK-24246) Bump PulsarClient to 2.9.1 with better transaction management

[ https://issues.apache.org/jira/browse/FLINK-24246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yufan Sheng updated FLINK-24246: Fix Version/s: (was: 1.16.0) > Bump PulsarClient to 2.9.1 with better transaction management >

[jira] [Updated] (FLINK-26021) Pulsar topic deduplicated in both sink and source connector

[ https://issues.apache.org/jira/browse/FLINK-26021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yufan Sheng updated FLINK-26021: Fix Version/s: (was: 1.16.0) > Pulsar topic deduplicated in both sink and source connector > -

[jira] [Created] (FLINK-26022) Implement at-least-once and exactly-once Pulsar Sink

Yufan Sheng created FLINK-26022: --- Summary: Implement at-least-once and exactly-once Pulsar Sink Key: FLINK-26022 URL: https://issues.apache.org/jira/browse/FLINK-26022 Project: Flink Issue Type

[jira] [Created] (FLINK-26023) Create a Pulsar sink config model for matching ProducerConfigurationData

Yufan Sheng created FLINK-26023: --- Summary: Create a Pulsar sink config model for matching ProducerConfigurationData Key: FLINK-26023 URL: https://issues.apache.org/jira/browse/FLINK-26023 Project: Flink

[jira] [Updated] (FLINK-26023) Create a Pulsar sink config model for matching ProducerConfigurationData

[ https://issues.apache.org/jira/browse/FLINK-26023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yufan Sheng updated FLINK-26023: Component/s: Connectors / Pulsar > Create a Pulsar sink config model for matching ProducerConfigur

[jira] [Created] (FLINK-26024) Create a PulsarSerializationSchema for better records serialization

Yufan Sheng created FLINK-26024: --- Summary: Create a PulsarSerializationSchema for better records serialization Key: FLINK-26024 URL: https://issues.apache.org/jira/browse/FLINK-26024 Project: Flink

[jira] [Created] (FLINK-26025) Replace MockPulsar with new Pulsar test tools based on PulsarStandalone

Yufan Sheng created FLINK-26025: --- Summary: Replace MockPulsar with new Pulsar test tools based on PulsarStandalone Key: FLINK-26025 URL: https://issues.apache.org/jira/browse/FLINK-26025 Project: Flink

[jira] [Created] (FLINK-26027) Add FLIP-33 metrics to new PulsarSink

Yufan Sheng created FLINK-26027: --- Summary: Add FLIP-33 metrics to new PulsarSink Key: FLINK-26027 URL: https://issues.apache.org/jira/browse/FLINK-26027 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-26026) Test FLIP-191 PulsarSink

Yufan Sheng created FLINK-26026: --- Summary: Test FLIP-191 PulsarSink Key: FLINK-26026 URL: https://issues.apache.org/jira/browse/FLINK-26026 Project: Flink Issue Type: Sub-task Repor

[jira] [Updated] (FLINK-26026) Test FLIP-191 PulsarSink

[ https://issues.apache.org/jira/browse/FLINK-26026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yufan Sheng updated FLINK-26026: Component/s: Connectors / Pulsar > Test FLIP-191 PulsarSink > > >

[jira] [Created] (FLINK-26028) Write documentation for new PulsarSink

Yufan Sheng created FLINK-26028: --- Summary: Write documentation for new PulsarSink Key: FLINK-26028 URL: https://issues.apache.org/jira/browse/FLINK-26028 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-26038) Support delay message on Pulsar sink

Yufan Sheng created FLINK-26038: --- Summary: Support delay message on Pulsar sink Key: FLINK-26038 URL: https://issues.apache.org/jira/browse/FLINK-26038 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-26038) Support delay message on PulsarSink

[ https://issues.apache.org/jira/browse/FLINK-26038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yufan Sheng updated FLINK-26038: Summary: Support delay message on PulsarSink (was: Support delay message on Pulsar sink) > Suppo

[jira] [Updated] (FLINK-26038) Support delay message on PulsarSink

[ https://issues.apache.org/jira/browse/FLINK-26038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yufan Sheng updated FLINK-26038: Description: A delayed message is a type of message that would be sent to the consumer after waiti

[jira] [Commented] (FLINK-25289) Add DataStream sink test suite in connector testing framework

[ https://issues.apache.org/jira/browse/FLINK-25289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17490569#comment-17490569 ] Yufan Sheng commented on FLINK-25289: - Hi [~renqs], I have seen the DataStreamSinkEx

[jira] [Comment Edited] (FLINK-25289) Add DataStream sink test suite in connector testing framework

[ https://issues.apache.org/jira/browse/FLINK-25289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17490569#comment-17490569 ] Yufan Sheng edited comment on FLINK-25289 at 2/10/22, 11:03 PM: --

[jira] [Updated] (FLINK-26038) Support delay message on PulsarSink

[ https://issues.apache.org/jira/browse/FLINK-26038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yufan Sheng updated FLINK-26038: Description: A delayed message is a type of message that would be sent to the consumer after waiti

[jira] [Comment Edited] (FLINK-30489) flink-sql-connector-pulsar doesn't shade all dependencies

[ https://issues.apache.org/jira/browse/FLINK-30489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17652982#comment-17652982 ] Yufan Sheng edited comment on FLINK-30489 at 12/30/22 1:03 AM: ---

[jira] [Commented] (FLINK-30489) flink-sql-connector-pulsar doesn't shade all dependencies

[ https://issues.apache.org/jira/browse/FLINK-30489?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17652982#comment-17652982 ] Yufan Sheng commented on FLINK-30489: - We didn't shade these dependencies because th

[jira] [Commented] (FLINK-30413) Drop Shared and Key_Shared subscription support in Pulsar connector

[ https://issues.apache.org/jira/browse/FLINK-30413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17653972#comment-17653972 ] Yufan Sheng commented on FLINK-30413: - [~Tison] Can you close this issue? > Drop Sh

[jira] [Created] (FLINK-30552) Pulsar connector shouldn't assert the BatchMessageId size.

Yufan Sheng created FLINK-30552: --- Summary: Pulsar connector shouldn't assert the BatchMessageId size. Key: FLINK-30552 URL: https://issues.apache.org/jira/browse/FLINK-30552 Project: Flink Issu

[jira] [Updated] (FLINK-30552) Pulsar connector shouldn't assert the BatchMessageId size.

[ https://issues.apache.org/jira/browse/FLINK-30552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yufan Sheng updated FLINK-30552: Description: Pulsar will try to assert the batch message id size in {{MessageIdUtils}}, but the b

[jira] [Commented] (FLINK-29755) PulsarSourceUnorderedE2ECase.testSavepoint failed because of missing TaskManagers

[ https://issues.apache.org/jira/browse/FLINK-29755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17654068#comment-17654068 ] Yufan Sheng commented on FLINK-29755: - [~mapohl] We have removed these tests in {{pu

  1   2   3   4   >