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
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
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
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: Sub
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
C
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: Sub-tas
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
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: Technic
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: Technic
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
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 Type:
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
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: https://issues.apache.org/jira/browse
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
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 Fe
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 Feat
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
17 matches
Mail list logo