[jira] [Commented] (FLINK-29359) Pulsar Table Connector pom config and packaging

[ https://issues.apache.org/jira/browse/FLINK-29359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17760716#comment-17760716 ] Yufei Zhang commented on FLINK-29359: - [~tison] Yeah I think when the ticket is created it was still

[jira] [Comment Edited] (FLINK-29359) Pulsar Table Connector pom config and packaging

[ https://issues.apache.org/jira/browse/FLINK-29359?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17760716#comment-17760716 ] Yufei Zhang edited comment on FLINK-29359 at 8/31/23 4:56 AM: -- [~tison]

[jira] [Commented] (FLINK-25582) flink sql kafka source cannot special custom parallelism

[ https://issues.apache.org/jira/browse/FLINK-25582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17644704#comment-17644704 ] Yufei Zhang commented on FLINK-25582: - I currently use `table.exec.resource.default-parallelism` to

[jira] [Created] (FLINK-29696) [Doc] Operator helm install command points to wrong repo

Yufei Zhang created FLINK-29696: --- Summary: [Doc] Operator helm install command points to wrong repo Key: FLINK-29696 URL: https://issues.apache.org/jira/browse/FLINK-29696 Project: Flink Issue

[jira] [Created] (FLINK-29390) Pulsar SQL Connector: SQLClient E2E testing

Yufei Zhang created FLINK-29390: --- Summary: Pulsar SQL Connector: SQLClient E2E testing Key: FLINK-29390 URL: https://issues.apache.org/jira/browse/FLINK-29390 Project: Flink Issue Type:

[jira] [Created] (FLINK-29360) Pulsar Table Connector Documentation

Yufei Zhang created FLINK-29360: --- Summary: Pulsar Table Connector Documentation Key: FLINK-29360 URL: https://issues.apache.org/jira/browse/FLINK-29360 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-29358) Pulsar Table Connector testing

Yufei Zhang created FLINK-29358: --- Summary: Pulsar Table Connector testing Key: FLINK-29358 URL: https://issues.apache.org/jira/browse/FLINK-29358 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-29359) Pulsar Table Connector pom config and packaging

Yufei Zhang created FLINK-29359: --- Summary: Pulsar Table Connector pom config and packaging Key: FLINK-29359 URL: https://issues.apache.org/jira/browse/FLINK-29359 Project: Flink Issue Type:

[jira] [Created] (FLINK-29357) Pulsar Table Sink code: implementation

Yufei Zhang created FLINK-29357: --- Summary: Pulsar Table Sink code: implementation Key: FLINK-29357 URL: https://issues.apache.org/jira/browse/FLINK-29357 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-29356) Pulsar Table Source code :implementation

Yufei Zhang created FLINK-29356: --- Summary: Pulsar Table Source code :implementation Key: FLINK-29356 URL: https://issues.apache.org/jira/browse/FLINK-29356 Project: Flink Issue Type: Sub-task

[jira] [Closed] (FLINK-26202) Support Table API in Pulsar Source Connector

[ https://issues.apache.org/jira/browse/FLINK-26202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yufei Zhang closed FLINK-26202. --- Resolution: Invalid Closed because moved to FLINK-26203 and will be tracked as a subticket under

[jira] [Updated] (FLINK-26203) Support Table API in Pulsar Connector

[ https://issues.apache.org/jira/browse/FLINK-26203?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yufei Zhang updated FLINK-26203: Summary: Support Table API in Pulsar Connector (was: Support Table API in Pulsar Sink Connector)

[jira] [Commented] (FLINK-26203) Support Table API in Pulsar Sink Connector

[ https://issues.apache.org/jira/browse/FLINK-26203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17607175#comment-17607175 ] Yufei Zhang commented on FLINK-26203: - I'm currently working on this Jira ( and FLINK-26202).

[jira] [Commented] (FLINK-26541) SQL Client should support submitting SQL jobs in application mode

[ https://issues.apache.org/jira/browse/FLINK-26541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17539178#comment-17539178 ] Yufei Zhang commented on FLINK-26541: - [~martijnvisser] I think he says "This feature is absolutely

[jira] [Comment Edited] (FLINK-26541) SQL Client should support submitting SQL jobs in application mode

[ https://issues.apache.org/jira/browse/FLINK-26541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17539178#comment-17539178 ] Yufei Zhang edited comment on FLINK-26541 at 5/19/22 3:02 AM: --

[jira] [Commented] (FLINK-27009) Support SQL job submission in flink kubernetes opeartor

[ https://issues.apache.org/jira/browse/FLINK-27009?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17520062#comment-17520062 ] Yufei Zhang commented on FLINK-27009: - I agree, submitting SQL jobs in application mode seems a big

[jira] [Created] (FLINK-26645) Pulsar Source subscribe to a single topic partition will consume all partitions from that topic

Yufei Zhang created FLINK-26645: --- Summary: Pulsar Source subscribe to a single topic partition will consume all partitions from that topic Key: FLINK-26645 URL: https://issues.apache.org/jira/browse/FLINK-26645

[jira] [Commented] (FLINK-26642) Pulsar sink fails with non-partitioned topic

[ https://issues.apache.org/jira/browse/FLINK-26642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17506717#comment-17506717 ] Yufei Zhang commented on FLINK-26642: - Roger. I'll try to reproduce it.  > Pulsar sink fails with

[jira] [Commented] (FLINK-26192) PulsarOrderedSourceReaderTest fails with exit code 255

[ https://issues.apache.org/jira/browse/FLINK-26192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17493800#comment-17493800 ] Yufei Zhang commented on FLINK-26192: - Got it, I'll bring this issue up with my team tomorrow~

[jira] [Commented] (FLINK-26211) PulsarSourceUnorderedE2ECase failed on azure due to multiple causes

[ https://issues.apache.org/jira/browse/FLINK-26211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17493786#comment-17493786 ] Yufei Zhang commented on FLINK-26211: - This seems to be a duplicate of FLINK-26210.  >

[jira] [Commented] (FLINK-26192) PulsarOrderedSourceReaderTest fails with exit code 255

[ https://issues.apache.org/jira/browse/FLINK-26192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17493777#comment-17493777 ] Yufei Zhang commented on FLINK-26192: - This looked to me the test VM crashed, let's keep observing

[jira] [Created] (FLINK-26203) Support Table API in Pulsar Sink Connector

Yufei Zhang created FLINK-26203: --- Summary: Support Table API in Pulsar Sink Connector Key: FLINK-26203 URL: https://issues.apache.org/jira/browse/FLINK-26203 Project: Flink Issue Type: New

[jira] [Created] (FLINK-26202) Support Table API in Pulsar Source Connector

Yufei Zhang created FLINK-26202: --- Summary: Support Table API in Pulsar Source Connector Key: FLINK-26202 URL: https://issues.apache.org/jira/browse/FLINK-26202 Project: Flink Issue Type: New

[jira] [Closed] (FLINK-26161) Pulsar Connector: edge case: splits should be added to finishedSplits if was empty from beginning

[ https://issues.apache.org/jira/browse/FLINK-26161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yufei Zhang closed FLINK-26161. --- Resolution: Invalid When I look back at this issue, I think I had some misunderstanding at the

[jira] [Commented] (FLINK-26161) Pulsar Connector: edge case: splits should be added to finishedSplits if was empty from beginning

[ https://issues.apache.org/jira/browse/FLINK-26161?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17492635#comment-17492635 ] Yufei Zhang commented on FLINK-26161: - When I look back at this issue, I think I had some

[jira] [Created] (FLINK-26161) Pulsar Connector: edge case: splits should be added to finishedSplits if was empty from beginning

Yufei Zhang created FLINK-26161: --- Summary: Pulsar Connector: edge case: splits should be added to finishedSplits if was empty from beginning Key: FLINK-26161 URL: https://issues.apache.org/jira/browse/FLINK-26161

[jira] [Created] (FLINK-26160) Pulsar Connector: stopCursor description should be changed. Connector only stop when auto discovery is disabled.

Yufei Zhang created FLINK-26160: --- Summary: Pulsar Connector: stopCursor description should be changed. Connector only stop when auto discovery is disabled. Key: FLINK-26160 URL:

[jira] [Created] (FLINK-26159) Pulsar Connector: should add description MAX_FETCH_RECORD in doc to explain slow consumption

Yufei Zhang created FLINK-26159: --- Summary: Pulsar Connector: should add description MAX_FETCH_RECORD in doc to explain slow consumption Key: FLINK-26159 URL: https://issues.apache.org/jira/browse/FLINK-26159

[jira] [Updated] (FLINK-25686) Support Pulsar Schema evolution in Pulsar Source Connector

[ https://issues.apache.org/jira/browse/FLINK-25686?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yufei Zhang updated FLINK-25686: Summary: Support Pulsar Schema evolution in Pulsar Source Connector (was: Support Pulsar Schema

[jira] [Commented] (FLINK-25686) Support Pulsar Schema evolution in Pulsar Connector

[ https://issues.apache.org/jira/browse/FLINK-25686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17477605#comment-17477605 ] Yufei Zhang commented on FLINK-25686: - Please assign this ticket to me [~fpaul] ~ Thank you ! >

[jira] [Created] (FLINK-25686) Support Pulsar Schema evolution in Pulsar Connector

Yufei Zhang created FLINK-25686: --- Summary: Support Pulsar Schema evolution in Pulsar Connector Key: FLINK-25686 URL: https://issues.apache.org/jira/browse/FLINK-25686 Project: Flink Issue

[jira] [Commented] (FLINK-25440) Apache Pulsar Connector Document description error about 'Starting Position'.

[ https://issues.apache.org/jira/browse/FLINK-25440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17474583#comment-17474583 ] Yufei Zhang commented on FLINK-25440: - I can take up this ticket, would someone assign this to me ?

[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=17474404#comment-17474404 ] Yufei Zhang commented on FLINK-23944: - I failed to find a way to trigger this failure case 100%. I

[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=17474282#comment-17474282 ] Yufei Zhang commented on FLINK-23944: - I'll try to investigate >

[jira] [Comment Edited] (FLINK-25159) Streamline E2E surefire configuration setup

[ https://issues.apache.org/jira/browse/FLINK-25159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17459641#comment-17459641 ] Yufei Zhang edited comment on FLINK-25159 at 12/15/21, 4:40 AM:

[jira] [Comment Edited] (FLINK-25159) Streamline E2E surefire configuration setup

[ https://issues.apache.org/jira/browse/FLINK-25159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17459641#comment-17459641 ] Yufei Zhang edited comment on FLINK-25159 at 12/15/21, 4:37 AM:

[jira] [Commented] (FLINK-25159) Streamline E2E surefire configuration setup

[ https://issues.apache.org/jira/browse/FLINK-25159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17459641#comment-17459641 ] Yufei Zhang commented on FLINK-25159: - [~chesnay]  Hi Chesnay, do you know how to configure the

[jira] [Commented] (FLINK-25210) PulsarSource(Un)OrderedE2ECase is broken

[ https://issues.apache.org/jira/browse/FLINK-25210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17459591#comment-17459591 ] Yufei Zhang commented on FLINK-25210: - [~trohrmann] Yeah, please assign this ticket to me >

[jira] [Commented] (FLINK-25182) NoClassDefFoundError of PulsarAdminImpl by using flink-connector-pulsar:1.14 on k8s flink cluster

[ https://issues.apache.org/jira/browse/FLINK-25182?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17457059#comment-17457059 ] Yufei Zhang commented on FLINK-25182: - [~forsake0120]  Hi, Looks like the issue has been resolved,

[jira] [Comment Edited] (FLINK-25210) PulsarSource(Un)OrderedE2ECase is broken

[ https://issues.apache.org/jira/browse/FLINK-25210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17454923#comment-17454923 ] Yufei Zhang edited comment on FLINK-25210 at 12/9/21, 4:37 AM: --- CC

[jira] [Commented] (FLINK-25159) Streamline E2E surefire configuration setup

[ https://issues.apache.org/jira/browse/FLINK-25159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17454926#comment-17454926 ] Yufei Zhang commented on FLINK-25159: - Would you mind share the link to the currently in-progress

[jira] [Commented] (FLINK-25210) PulsarSource(Un)OrderedE2ECase is brokern

[ https://issues.apache.org/jira/browse/FLINK-25210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17454923#comment-17454923 ] Yufei Zhang commented on FLINK-25210: - To reproduce/fix this, I guess I should use FLINK-25159's

[jira] [Created] (FLINK-25044) Add More Unit Test For Pulsar Source

Yufei Zhang created FLINK-25044: --- Summary: Add More Unit Test For Pulsar Source Key: FLINK-25044 URL: https://issues.apache.org/jira/browse/FLINK-25044 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-25044) Add More Unit Test For Pulsar Source

[ https://issues.apache.org/jira/browse/FLINK-25044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17448579#comment-17448579 ] Yufei Zhang commented on FLINK-25044: - I am currently working on this issue, feel free to assign it

[jira] [Commented] (FLINK-24857) Upgrade SourceReaderTestBase to Use Junit 5

[ https://issues.apache.org/jira/browse/FLINK-24857?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17441611#comment-17441611 ] Yufei Zhang commented on FLINK-24857: - Would be happy to help with this ticket~ > Upgrade

[jira] [Created] (FLINK-24857) Upgrade SourceReaderTestBase to Use Junit 5

Yufei Zhang created FLINK-24857: --- Summary: Upgrade SourceReaderTestBase to Use Junit 5 Key: FLINK-24857 URL: https://issues.apache.org/jira/browse/FLINK-24857 Project: Flink Issue Type:

[jira] [Closed] (FLINK-24856) Upgrade SourceReaderTestBase to Use Junit 5

[ https://issues.apache.org/jira/browse/FLINK-24856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yufei Zhang closed FLINK-24856. --- Resolution: Invalid Cannot change assignee, will create from scratch. Sorry for any inconvenience  

[jira] [Updated] (FLINK-24856) Upgrade SourceReaderTestBase to Use Junit 5

[ https://issues.apache.org/jira/browse/FLINK-24856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yufei Zhang updated FLINK-24856: Labels: (was: pull-request-available) > Upgrade SourceReaderTestBase to Use Junit 5 >

[jira] [Created] (FLINK-24856) Upgrade SourceReaderTestBase to Use Junit 5

Yufei Zhang created FLINK-24856: --- Summary: Upgrade SourceReaderTestBase to Use Junit 5 Key: FLINK-24856 URL: https://issues.apache.org/jira/browse/FLINK-24856 Project: Flink Issue Type: