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

2022-10-19 Thread Yufei Zhang (Jira)
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

2022-09-22 Thread Yufei Zhang (Jira)
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-29358) Pulsar Table Connector testing

2022-09-20 Thread Yufei Zhang (Jira)
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

2022-09-20 Thread Yufei Zhang (Jira)
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-29360) Pulsar Table Connector Documentation

2022-09-20 Thread Yufei Zhang (Jira)
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-29356) Pulsar Table Source code :implementation

2022-09-20 Thread Yufei Zhang (Jira)
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] [Created] (FLINK-29357) Pulsar Table Sink code: implementation

2022-09-20 Thread Yufei Zhang (Jira)
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-26645) Pulsar Source subscribe to a single topic partition will consume all partitions from that topic

2022-03-15 Thread Yufei Zhang (Jira)
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] [Created] (FLINK-26203) Support Table API in Pulsar Sink Connector

2022-02-16 Thread Yufei Zhang (Jira)
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

2022-02-16 Thread Yufei Zhang (Jira)
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] [Created] (FLINK-26161) Pulsar Connector: edge case: splits should be added to finishedSplits if was empty from beginning

2022-02-15 Thread Yufei Zhang (Jira)
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.

2022-02-15 Thread Yufei Zhang (Jira)
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

2022-02-15 Thread Yufei Zhang (Jira)
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] [Created] (FLINK-25686) Support Pulsar Schema evolution in Pulsar Connector

2022-01-17 Thread Yufei Zhang (Jira)
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] [Created] (FLINK-25044) Add More Unit Test For Pulsar Source

2021-11-24 Thread Yufei Zhang (Jira)
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] [Created] (FLINK-24857) Upgrade SourceReaderTestBase to Use Junit 5

2021-11-10 Thread Yufei Zhang (Jira)
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] [Created] (FLINK-24856) Upgrade SourceReaderTestBase to Use Junit 5

2021-11-10 Thread Yufei Zhang (Jira)
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: