[jira] [Resolved] (FLINK-36180) Flink pulsar connector when restoring from the state, the unconsumed messages of the first batch will be lost

[ https://issues.apache.org/jira/browse/FLINK-36180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen resolved FLINK-36180. --- Assignee: Wenbing Shen Resolution: Fixed master via https://github.com/apache/flink-connector

[jira] [Resolved] (FLINK-35182) Bump org.apache.commons:commons-compress from 1.24.0 to 1.26.1 for Flink Pulsar connector

[ https://issues.apache.org/jira/browse/FLINK-35182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen resolved FLINK-35182. --- Fix Version/s: pulsar-4.2.0 Assignee: Zhongqiang Gong Resolution: Fixed master via

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

[ https://issues.apache.org/jira/browse/FLINK-32645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen resolved FLINK-32645. --- Resolution: Fixed > Flink pulsar sink is having poor performance > -

[jira] [Updated] (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:all-tabpanel ] Zili Chen updated FLINK-34962: -- Affects Version/s: (was: pulsar-4.2.0) > flink-connector-pulsa starts failed due to incorrect use

[jira] [Updated] (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:all-tabpanel ] Zili Chen updated FLINK-34962: -- Affects Version/s: (was: pulsar-4.1.1) > flink-connector-pulsa starts failed due to incorrect use

[jira] [Resolved] (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:all-tabpanel ] Zili Chen resolved FLINK-34962. --- Fix Version/s: pulsar-4.2.0 Resolution: Fixed master via https://github.com/apache/flink-con

[jira] [Resolved] (FLINK-33884) Update Pulsar dependency to 3.0.2 in Pulsar Connector

[ https://issues.apache.org/jira/browse/FLINK-33884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen resolved FLINK-33884. --- Fix Version/s: pulsar-4.2.0 Resolution: Fixed Master via https://github.com/apache/flink-con

[jira] [Resolved] (FLINK-34629) Pulsar source lost topic subscribe

[ https://issues.apache.org/jira/browse/FLINK-34629?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen resolved FLINK-34629. --- Fix Version/s: pulsar-4.2.0 Resolution: Fixed Master via https://github.com/apache/flink-con

[jira] [Closed] (FLINK-33970) Add necessary checks for connector document

[ https://issues.apache.org/jira/browse/FLINK-33970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen closed FLINK-33970. - Resolution: Fixed master via 5b70da8f88e21057a5c590d139eab558f87e5dca Thanks a lot [~gongzhongqiang]!

[jira] [Updated] (FLINK-33970) Add necessary checks for connector document

[ https://issues.apache.org/jira/browse/FLINK-33970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen updated FLINK-33970: -- Fix Version/s: pulsar-4.2.0 pulsar-4.1.1 > Add necessary checks for connector docum

[jira] [Closed] (FLINK-33400) Pulsar connector doesn't compile for Flink 1.18 due to Archunit update

[ https://issues.apache.org/jira/browse/FLINK-33400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen closed FLINK-33400. - Fix Version/s: pulsar-4.1.0 Assignee: Zili Chen (was: Martijn Visser) Resolution: Fixed

[jira] [Created] (FLINK-33602) Pulsar connector should be compatible with Flink 1.18

Zili Chen created FLINK-33602: - Summary: Pulsar connector should be compatible with Flink 1.18 Key: FLINK-33602 URL: https://issues.apache.org/jira/browse/FLINK-33602 Project: Flink Issue Type: B

[jira] [Assigned] (FLINK-33357) add Apache Software License 2

[ https://issues.apache.org/jira/browse/FLINK-33357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen reassigned FLINK-33357: - Assignee: 蔡灿材 > add Apache Software License 2 > - > >

[jira] [Resolved] (FLINK-32938) flink-connector-pulsar should remove all `PulsarAdmin` calls

[ https://issues.apache.org/jira/browse/FLINK-32938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen resolved FLINK-32938. --- Fix Version/s: pulsar-4.1.0 Resolution: Fixed master via 78d00ea9e3e278d4ce2fbb0c8a8d380abef7

[jira] [Assigned] (FLINK-32938) flink-connector-pulsar should remove all `PulsarAdmin` calls

[ https://issues.apache.org/jira/browse/FLINK-32938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen reassigned FLINK-32938: - Assignee: Neng Lu > flink-connector-pulsar should remove all `PulsarAdmin` calls >

[jira] [Commented] (FLINK-33111) Flink Pulsar Connector to Pulsar Client Version Mismatch

[ https://issues.apache.org/jira/browse/FLINK-33111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17767131#comment-17767131 ] Zili Chen commented on FLINK-33111: --- We upgrade the Pulsar client version in https://

[jira] [Commented] (FLINK-33053) Watcher leak in Zookeeper HA mode

[ https://issues.apache.org/jira/browse/FLINK-33053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764950#comment-17764950 ] Zili Chen commented on FLINK-33053: --- But it's possible to add an option to explicitly

[jira] [Commented] (FLINK-33053) Watcher leak in Zookeeper HA mode

[ https://issues.apache.org/jira/browse/FLINK-33053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764948#comment-17764948 ] Zili Chen commented on FLINK-33053: --- No. Both {{CuratorCache}} and {{TreeCache}} doesn

[jira] [Commented] (FLINK-33053) Watcher leak in Zookeeper HA mode

[ https://issues.apache.org/jira/browse/FLINK-33053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764723#comment-17764723 ] Zili Chen commented on FLINK-33053: --- But we don't have other shared watchers so we can

[jira] [Commented] (FLINK-33053) Watcher leak in Zookeeper HA mode

[ https://issues.apache.org/jira/browse/FLINK-33053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764721#comment-17764721 ] Zili Chen commented on FLINK-33053: --- See https://lists.apache.org/thread/3b9hn9j4c05yf

[jira] [Commented] (FLINK-33053) Watcher leak in Zookeeper HA mode

[ https://issues.apache.org/jira/browse/FLINK-33053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17764702#comment-17764702 ] Zili Chen commented on FLINK-33053: --- I noticed that the {{TreeCache}}'s close call {{r

[jira] [Comment Edited] (FLINK-33019) Pulsar tests hangs during nightly builds

[ https://issues.apache.org/jira/browse/FLINK-33019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17763587#comment-17763587 ] Zili Chen edited comment on FLINK-33019 at 9/11/23 7:57 AM:

[jira] [Comment Edited] (FLINK-33019) Pulsar tests hangs during nightly builds

[ https://issues.apache.org/jira/browse/FLINK-33019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17763587#comment-17763587 ] Zili Chen edited comment on FLINK-33019 at 9/11/23 7:57 AM:

[jira] [Commented] (FLINK-33019) Pulsar tests hangs during nightly builds

[ https://issues.apache.org/jira/browse/FLINK-33019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17763587#comment-17763587 ] Zili Chen commented on FLINK-33019: --- It seems we can sometimes pass the test https://

[jira] [Commented] (FLINK-33053) Watcher leak in Zookeeper HA mode

[ https://issues.apache.org/jira/browse/FLINK-33053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17762965#comment-17762965 ] Zili Chen commented on FLINK-33053: --- The log seems trimed. I saw: 2023-09-08 11:09:03

[jira] [Commented] (FLINK-33053) Watcher leak in Zookeeper HA mode

[ https://issues.apache.org/jira/browse/FLINK-33053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17762657#comment-17762657 ] Zili Chen commented on FLINK-33053: --- Perhaps you can enable debug logs and check "Remo

[jira] [Commented] (FLINK-33053) Watcher leak in Zookeeper HA mode

[ https://issues.apache.org/jira/browse/FLINK-33053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17762599#comment-17762599 ] Zili Chen commented on FLINK-33053: --- The recipe in use is {{TreeCache}}, which doesn't

[jira] [Commented] (FLINK-33019) Pulsar tests hangs during nightly builds

[ https://issues.apache.org/jira/browse/FLINK-33019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17762412#comment-17762412 ] Zili Chen commented on FLINK-33019: --- [~martijnvisser] It seems all for the SNAPSHOT ve

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

[ https://issues.apache.org/jira/browse/FLINK-29390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen reassigned FLINK-29390: - Assignee: Zili Chen > Pulsar SQL Connector: SQLClient E2E testing > ---

[jira] [Closed] (FLINK-31427) Pulsar Catalog support with Schema translation

[ https://issues.apache.org/jira/browse/FLINK-31427?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen closed FLINK-31427. - Fix Version/s: (was: pulsar-4.0.1) Resolution: Later It's rare that users would use Pulsar as

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

[ https://issues.apache.org/jira/browse/FLINK-29360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen reassigned FLINK-29360: - Assignee: Zili Chen > Pulsar Table Connector Documentation > --

[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&focusedCommentId=17760687#comment-17760687 ] Zili Chen commented on FLINK-29359: --- [~affe] [~syhily] [~leonard] I'm unsure if this t

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

[ https://issues.apache.org/jira/browse/FLINK-29357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen resolved FLINK-29357. --- Fix Version/s: pulsar-4.1.0 Resolution: Fixed master via c71fc862e0d4a782c19f361d3bf581da836c

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

[ https://issues.apache.org/jira/browse/FLINK-29357?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen reassigned FLINK-29357: - Assignee: Zili Chen > Pulsar Table Sink code: implementation >

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

[ https://issues.apache.org/jira/browse/FLINK-29358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen resolved FLINK-29358. --- Fix Version/s: pulsar-4.1.0 Assignee: Zili Chen Resolution: Fixed master via c71fc86

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

[ https://issues.apache.org/jira/browse/FLINK-29356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen resolved FLINK-29356. --- Fix Version/s: pulsar-4.1.0 Resolution: Fixed master via c71fc862e0d4a782c19f361d3bf581da836c

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

[ https://issues.apache.org/jira/browse/FLINK-29356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen reassigned FLINK-29356: - Assignee: Zili Chen > Pulsar Table Source code :implementation > --

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

[ https://issues.apache.org/jira/browse/FLINK-26203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17760680#comment-17760680 ] Zili Chen commented on FLINK-26203: --- Yeah. I'm updating the tickets here now. > Suppo

[jira] [Resolved] (FLINK-29527) Make unknownFieldsIndices work for single ParquetReader

[ https://issues.apache.org/jira/browse/FLINK-29527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen resolved FLINK-29527. --- Resolution: Fixed master via 50622df1f01cd9cade78bfe2add5a7faff678e3e Shall we pick to other versio

[jira] [Updated] (FLINK-29527) Make unknownFieldsIndices work for single ParquetReader

[ https://issues.apache.org/jira/browse/FLINK-29527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen updated FLINK-29527: -- Fix Version/s: 1.19.0 > Make unknownFieldsIndices work for single ParquetReader >

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

[ https://issues.apache.org/jira/browse/FLINK-32645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen updated FLINK-32645: -- Fix Version/s: pulsar-3.0.2 > Flink pulsar sink is having poor performance > -

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

[ https://issues.apache.org/jira/browse/FLINK-32645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen reassigned FLINK-32645: - Assignee: Zili Chen > Flink pulsar sink is having poor performance > --

[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=17746193#comment-17746193 ] Zili Chen commented on FLINK-32645: --- The new version series use a differnt GAV. You ca

[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=17746177#comment-17746177 ] Zili Chen commented on FLINK-32645: --- What version of Flink Pulsar connector did you us

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

[ https://issues.apache.org/jira/browse/FLINK-24302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17745015#comment-17745015 ] Zili Chen edited comment on FLINK-24302 at 7/20/23 10:24 AM: -

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

[ https://issues.apache.org/jira/browse/FLINK-24302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen closed FLINK-24302. - Resolution: Workaround Temporarily work around with https://github.com/apache/flink-connector-pulsar/co

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

[ https://issues.apache.org/jira/browse/FLINK-24302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen updated FLINK-24302: -- Fix Version/s: pulsar-4.1.0 (was: pulsar-4.0.1) > Direct buffer memory leak on

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

[ https://issues.apache.org/jira/browse/FLINK-24302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen reassigned FLINK-24302: - Assignee: Zili Chen > Direct buffer memory leak on Pulsar connector with Java 11 >

[jira] [Assigned] (FLINK-32630) The log level of job failed info should change from INFO to WARN/ERROR if job failed

[ https://issues.apache.org/jira/browse/FLINK-32630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen reassigned FLINK-32630: - Assignee: Matt Wang > The log level of job failed info should change from INFO to WARN/ERROR if

[jira] [Commented] (FLINK-32630) The log level of job failed info should change from INFO to WARN/ERROR if job failed

[ https://issues.apache.org/jira/browse/FLINK-32630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17744605#comment-17744605 ] Zili Chen commented on FLINK-32630: --- You can ping me on a patch ready. > The log leve

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

[ https://issues.apache.org/jira/browse/FLINK-24302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17744604#comment-17744604 ] Zili Chen commented on FLINK-24302: --- Pending to close. This should be an issue on the

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

[ https://issues.apache.org/jira/browse/FLINK-24302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17744603#comment-17744603 ] Zili Chen commented on FLINK-24302: --- Workaround to turn on tests for JDK11 in https:/

[jira] [Created] (FLINK-32625) MiniClusterTestEnvironment supports customized MiniClusterResourceConfiguration

Zili Chen created FLINK-32625: - Summary: MiniClusterTestEnvironment supports customized MiniClusterResourceConfiguration Key: FLINK-32625 URL: https://issues.apache.org/jira/browse/FLINK-32625 Project: Fl

[jira] [Closed] (FLINK-32612) Upgrade Pulsar version to 3.0.0 for the connector

[ https://issues.apache.org/jira/browse/FLINK-32612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen closed FLINK-32612. - Fix Version/s: pulsar-4.0.1 Resolution: Fixed master via https://github.com/apache/flink-connect

[jira] [Created] (FLINK-32612) Upgrade Pulsar version to 3.0.0 for the connector

Zili Chen created FLINK-32612: - Summary: Upgrade Pulsar version to 3.0.0 for the connector Key: FLINK-32612 URL: https://issues.apache.org/jira/browse/FLINK-32612 Project: Flink Issue Type: Impro

[jira] [Closed] (FLINK-32585) Filter javax.xml.bind:jaxb-api false positive for Pulsar connector

[ https://issues.apache.org/jira/browse/FLINK-32585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen closed FLINK-32585. - Resolution: Fixed master via d7a3b3847dc5c680b32d1997d448b7dac44e529c > Filter javax.xml.bind:jaxb-api

[jira] [Created] (FLINK-32585) Filter javax.xml.bind:jaxb-api false positive for Pulsar connector

Zili Chen created FLINK-32585: - Summary: Filter javax.xml.bind:jaxb-api false positive for Pulsar connector Key: FLINK-32585 URL: https://issues.apache.org/jira/browse/FLINK-32585 Project: Flink

[jira] [Commented] (FLINK-32003) Release 3.0.0-1.16 and 1.16.1 doesn't work with OAuth2

[ https://issues.apache.org/jira/browse/FLINK-32003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17725683#comment-17725683 ] Zili Chen commented on FLINK-32003: --- The main branch already has more later version. I

[jira] [Commented] (FLINK-32003) Release 3.0.0-1.16 and 1.16.1 doesn't work with OAuth2

[ https://issues.apache.org/jira/browse/FLINK-32003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17720101#comment-17720101 ] Zili Chen commented on FLINK-32003: --- Thanks for reporting this issue [~nlu90]! It's re

[jira] [Assigned] (FLINK-32003) Release 3.0.0-1.16 and 1.16.1 doesn't work with OAuth2

[ https://issues.apache.org/jira/browse/FLINK-32003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen reassigned FLINK-32003: - Assignee: Zili Chen > Release 3.0.0-1.16 and 1.16.1 doesn't work with OAuth2 >

[jira] [Created] (FLINK-31748) Adapt SplitFetcherManager#removeSplit for flink-connector-pulsar

Zili Chen created FLINK-31748: - Summary: Adapt SplitFetcherManager#removeSplit for flink-connector-pulsar Key: FLINK-31748 URL: https://issues.apache.org/jira/browse/FLINK-31748 Project: Flink I

[jira] [Commented] (FLINK-25509) FLIP-208: Add RecordEvaluator to dynamically stop source based on de-serialized records

[ https://issues.apache.org/jira/browse/FLINK-25509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17708825#comment-17708825 ] Zili Chen commented on FLINK-25509: --- For the Pulsar side, I have a conversation with [

[jira] [Commented] (FLINK-31334) E2e ci fail with unsupported file exception

[ https://issues.apache.org/jira/browse/FLINK-31334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17696803#comment-17696803 ] Zili Chen commented on FLINK-31334: --- cc [~chesnay] I guess you're familiar with this p

[jira] [Commented] (FLINK-31206) Broken links on flink.apache.org

[ https://issues.apache.org/jira/browse/FLINK-31206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17693137#comment-17693137 ] Zili Chen commented on FLINK-31206: --- [~martijnvisser] Thanks for your follow-ups! See

[jira] [Created] (FLINK-31206) Broken links on flink.apache.org

Zili Chen created FLINK-31206: - Summary: Broken links on flink.apache.org Key: FLINK-31206 URL: https://issues.apache.org/jira/browse/FLINK-31206 Project: Flink Issue Type: Bug Report

[jira] [Commented] (FLINK-22922) Migrate flink project website to Hugo

[ https://issues.apache.org/jira/browse/FLINK-22922?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17692982#comment-17692982 ] Zili Chen commented on FLINK-22922: --- Hi [~martijnvisser]! I see now we use `asf-site`

[jira] [Closed] (FLINK-31086) [DOC]update connector lable for blackhole and kafka

[ https://issues.apache.org/jira/browse/FLINK-31086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen closed FLINK-31086. - Resolution: Fixed master via e292a105eb9f7ddccfba2b0d53430dcdb06c0280 > [DOC]update connector lable for

[jira] [Updated] (FLINK-31086) [DOC]update connector lable for blackhole and kafka

[ https://issues.apache.org/jira/browse/FLINK-31086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen updated FLINK-31086: -- Issue Type: Improvement (was: Bug) > [DOC]update connector lable for blackhole and kafka > --

[jira] [Assigned] (FLINK-31086) [DOC]update connector lable for blackhole and kafka

[ https://issues.apache.org/jira/browse/FLINK-31086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen reassigned FLINK-31086: - Assignee: hehuiyuan > [DOC]update connector lable for blackhole and kafka > ---

[jira] [Closed] (FLINK-30606) Bump Pulsar to 2.11.0

[ https://issues.apache.org/jira/browse/FLINK-30606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen closed FLINK-30606. - Resolution: Fixed master via 8b58e7f81058ee50f7d194319ca122cc134033dc > Bump Pulsar to 2.11.0 > ---

[jira] [Closed] (FLINK-28505) Pulsar sink doesn't support topic auto creation

[ https://issues.apache.org/jira/browse/FLINK-28505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen closed FLINK-28505. - Resolution: Duplicate > Pulsar sink doesn't support topic auto creation > --

[jira] [Commented] (FLINK-30109) Checked exceptions are sneakingly transformed into unchecked exceptions in the Pulsar

[ https://issues.apache.org/jira/browse/FLINK-30109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17687944#comment-17687944 ] Zili Chen commented on FLINK-30109: --- master via 2278653d67a8ddf171c88d538a288e50322162

[jira] [Closed] (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:all-tabpanel ] Zili Chen closed FLINK-30489. - Fix Version/s: pulsar-4.0.0 Resolution: Fixed master via 5f0bb2db9f1f357a11cce965eb5832bb908523a1

[jira] [Assigned] (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:all-tabpanel ] Zili Chen reassigned FLINK-30489: - Assignee: Yufan Sheng > flink-sql-connector-pulsar doesn't shade all dependencies > ---

[jira] [Closed] (FLINK-30654) Add option to force consumption from StartCursor every time the application starts

[ https://issues.apache.org/jira/browse/FLINK-30654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen closed FLINK-30654. - Fix Version/s: pulsar-4.0.0 Resolution: Fixed master via https://github.com/apache/flink-connecto

[jira] [Closed] (FLINK-30622) Support auto consume schema in Pulsar source

[ https://issues.apache.org/jira/browse/FLINK-30622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen closed FLINK-30622. - Resolution: Fixed master via https://github.com/apache/flink-connector-pulsar/pull/19 > Support auto co

[jira] [Commented] (FLINK-28351) Pulsar Sink should support dynamic generated topic from record

[ https://issues.apache.org/jira/browse/FLINK-28351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17685937#comment-17685937 ] Zili Chen commented on FLINK-28351: --- [~syhily] I've written a release note here. Pleas

[jira] [Closed] (FLINK-28351) Pulsar Sink should support dynamic generated topic from record

[ https://issues.apache.org/jira/browse/FLINK-28351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen closed FLINK-28351. - Fix Version/s: pulsar-4.0.0 Release Note: The default value of `pulsar.source.partitionDiscoveryInt

[jira] [Closed] (FLINK-30689) Use auto produce bytes schema in Pulsar sink

[ https://issues.apache.org/jira/browse/FLINK-30689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen closed FLINK-30689. - Resolution: Fixed master via https://github.com/apache/flink-connector-pulsar/pull/20 > Use auto produc

[jira] [Commented] (FLINK-30657) Remove Shared and Key_Shared related tests in Pulsar connector

[ https://issues.apache.org/jira/browse/FLINK-30657?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17682356#comment-17682356 ] Zili Chen commented on FLINK-30657: --- flink-connector-pulsar 3.0 via https://github.co

[jira] [Assigned] (FLINK-30622) Support auto consume schema in Pulsar source

[ https://issues.apache.org/jira/browse/FLINK-30622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen reassigned FLINK-30622: - Assignee: Yufan Sheng > Support auto consume schema in Pulsar source >

[jira] [Closed] (FLINK-30681) Pulsar-Flink connector corrupts its output topic

[ https://issues.apache.org/jira/browse/FLINK-30681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen closed FLINK-30681. - Assignee: Yufan Sheng Resolution: Not A Bug Explained in https://github.com/apache/flink-connector

[jira] [Reopened] (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:all-tabpanel ] Zili Chen reopened FLINK-30413: --- > Drop Shared and Key_Shared subscription support in Pulsar connector >

[jira] [Closed] (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:all-tabpanel ] Zili Chen closed FLINK-30413. - Fix Version/s: pulsar-4.0.0 Resolution: Fixed > Drop Shared and Key_Shared subscription support i

[jira] [Assigned] (FLINK-30657) Disable Shared and Key_Shared related tests in Pulsar connector

[ https://issues.apache.org/jira/browse/FLINK-30657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen reassigned FLINK-30657: - Assignee: Yufan Sheng > Disable Shared and Key_Shared related tests in Pulsar connector > -

[jira] [Closed] (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:all-tabpanel ] Zili Chen closed FLINK-30413. - Fix Version/s: (was: pulsar-4.0.0) Resolution: Won't Do > Drop Shared and Key_Shared subscrip

[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=17676411#comment-17676411 ] Zili Chen commented on FLINK-30413: --- I second [~syhily]'s comment that it can be a bre

[jira] [Assigned] (FLINK-30654) start cursor issue

[ https://issues.apache.org/jira/browse/FLINK-30654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen reassigned FLINK-30654: - Assignee: Yufan Sheng > start cursor issue > -- > > Key: FLINK-

[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 ] Zili Chen updated FLINK-30552: -- Fix Version/s: pulsar-3.0.1 > Pulsar connector shouldn't assert the BatchMessageId size. > ---

[jira] [Assigned] (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 ] Zili Chen reassigned FLINK-30552: - Assignee: Yufan Sheng > Pulsar connector shouldn't assert the BatchMessageId size. > --

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=17665060#comment-17665060 ] Zili Chen commented on FLINK-30552: --- 3.0.1 via https://github.com/apache/flink-connect

[jira] [Closed] (FLINK-28870) Pulsar Source hangs on the small incoming message rates

[ https://issues.apache.org/jira/browse/FLINK-28870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen closed FLINK-28870. - Fix Version/s: pulsar-4.0.0 Resolution: Fixed master via https://github.com/apache/flink-connecto

[jira] [Commented] (FLINK-30616) Don't support batchMessageId when restore from checkpoint

[ https://issues.apache.org/jira/browse/FLINK-30616?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17656508#comment-17656508 ] Zili Chen commented on FLINK-30616: --- [~songv] According to [~syhily]'s comment above,

[jira] [Closed] (FLINK-28082) Support end to end encryption on Pulsar connector.

[ https://issues.apache.org/jira/browse/FLINK-28082?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen closed FLINK-28082. - Fix Version/s: pulsar-4.0.0 (was: 1.17.0) Resolution: Fixed master via htt

[jira] [Closed] (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 ] Zili Chen closed FLINK-25686. - Fix Version/s: pulsar-4.0.0 Resolution: Fixed master via https://github.com/apache/flink-connecto

[jira] [Closed] (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 ] Zili Chen closed FLINK-30552. - Resolution: Fixed master via https://github.com/apache/flink-connector-pulsar/pull/11 > Pulsar connecto

[jira] [Closed] (FLINK-27917) PulsarUnorderedPartitionSplitReaderTest.consumeMessageCreatedBeforeHandleSplitsChangesAndResetToEarliestPosition failed with AssertionError

[ https://issues.apache.org/jira/browse/FLINK-27917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen closed FLINK-27917. - Fix Version/s: (was: 1.14.7) (was: 1.16.1) (was: 1.15.4

[jira] [Closed] (FLINK-29835) NoClassDefFoundError in PulsarSourceUnorderedE2ECase

[ https://issues.apache.org/jira/browse/FLINK-29835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen closed FLINK-29835. - Resolution: Invalid After FLINK-30413 dropped the related support, this test was dropped also. Invalid

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

[ https://issues.apache.org/jira/browse/FLINK-29755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen closed FLINK-29755. - Resolution: Invalid After FLINK-30413 dropped the related support, this test was dropped also. Invalid

[jira] [Closed] (FLINK-30393) PulsarSourceUnorderedE2ECase.testScaleDown failed with TimeoutException

[ https://issues.apache.org/jira/browse/FLINK-30393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen closed FLINK-30393. - Resolution: Invalid After FLINK-30413 dropped the related support, this test was dropped also. Invalid

  1   2   3   4   5   6   7   8   >