[jira] [Created] (FLINK-36083) Fix kafka table api doc's Connector Options table broken
Zhongqiang Gong created FLINK-36083: --- Summary: Fix kafka table api doc's Connector Options table broken Key: FLINK-36083 URL: https://issues.apache.org/jira/browse/FLINK-36083 Project: Flink Issue Type: Bug Components: Connectors / Kafka Affects Versions: kafka-3.2.0 Reporter: Zhongqiang Gong Assignee: Zhongqiang Gong Attachments: image-2024-08-18-15-26-13-109.png !image-2024-08-18-15-26-13-109.png! -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (FLINK-35865) When Sync SqlServer table with smallint type as pk
Zhongqiang Gong created FLINK-35865: --- Summary: When Sync SqlServer table with smallint type as pk Key: FLINK-35865 URL: https://issues.apache.org/jira/browse/FLINK-35865 Project: Flink Issue Type: Bug Affects Versions: cdc-3.3.0 Reporter: Zhongqiang Gong Attachments: image-2024-07-18-18-01-55-577.png, image-2024-07-18-19-27-53-165.png Reproduce: Use flink cdc task to extract data from sqlserver which table with smallint type as pk. Occur the error like below: !image-2024-07-18-19-27-53-165.png! -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (FLINK-35824) Polish JDBC documentation : fix link and add back to top button
Zhongqiang Gong created FLINK-35824: --- Summary: Polish JDBC documentation : fix link and add back to top button Key: FLINK-35824 URL: https://issues.apache.org/jira/browse/FLINK-35824 Project: Flink Issue Type: Improvement Components: Connectors / JDBC Reporter: Zhongqiang Gong Assignee: Zhongqiang Gong -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (FLINK-35545) Miss 3.0.1 version in snapshot flink-cdc doc version list
Zhongqiang Gong created FLINK-35545: --- Summary: Miss 3.0.1 version in snapshot flink-cdc doc version list Key: FLINK-35545 URL: https://issues.apache.org/jira/browse/FLINK-35545 Project: Flink Issue Type: Bug Components: Flink CDC Reporter: Zhongqiang Gong -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (FLINK-35514) Add Flink CDC Channel to Apache Flink Slack Workspace
Zhongqiang Gong created FLINK-35514: --- Summary: Add Flink CDC Channel to Apache Flink Slack Workspace Key: FLINK-35514 URL: https://issues.apache.org/jira/browse/FLINK-35514 Project: Flink Issue Type: Bug Reporter: Zhongqiang Gong DISCUSS thread : https://lists.apache.org/thread/gqzrs3c0j9k7c5m9m5k2slomgorrqrwf -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (FLINK-35484) Flink Document document file had removed but website can access
Zhongqiang Gong created FLINK-35484: --- Summary: Flink Document document file had removed but website can access Key: FLINK-35484 URL: https://issues.apache.org/jira/browse/FLINK-35484 Project: Flink Issue Type: Bug Components: Documentation Reporter: Zhongqiang Gong Flink 1.18 document had remove document about DataSet : issue link https://issues.apache.org/jira/browse/FLINK-32741. But I can still access the link : https://nightlies.apache.org/flink/flink-docs-master/docs/connectors/dataset/formats/avro/ -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (FLINK-35447) Flink CDC Document document file had removed but website can access
Zhongqiang Gong created FLINK-35447: --- Summary: Flink CDC Document document file had removed but website can access Key: FLINK-35447 URL: https://issues.apache.org/jira/browse/FLINK-35447 Project: Flink Issue Type: Improvement Components: Flink CDC Reporter: Zhongqiang Gong https://nightlies.apache.org/flink/flink-cdc-docs-master/docs/connectors/overview/ the link should not appeared. -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (FLINK-35431) Migrate references in Flink CDC documentation from Debezium 1.9 to 2.0
Zhongqiang Gong created FLINK-35431: --- Summary: Migrate references in Flink CDC documentation from Debezium 1.9 to 2.0 Key: FLINK-35431 URL: https://issues.apache.org/jira/browse/FLINK-35431 Project: Flink Issue Type: Improvement Components: Flink CDC Affects Versions: cdc-3.2.0 Reporter: Zhongqiang Gong Backgroud: The website has taken down the documentation for versions before 2.0. And flink cdc document ci failed. Discuss link: https://lists.apache.org/thread/twdpd4bvoxtmjd0tykk7hs73hx4rm6yv -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (FLINK-35309) Enable Notice file ci check and fix Notice
Zhongqiang Gong created FLINK-35309: --- Summary: Enable Notice file ci check and fix Notice Key: FLINK-35309 URL: https://issues.apache.org/jira/browse/FLINK-35309 Project: Flink Issue Type: Improvement Components: Flink CDC Affects Versions: 3.1.0 Reporter: Zhongqiang Gong Changes: * * Add ci to check Notice file * Fix Notice file issue -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (FLINK-35240) Disable FLUSH_AFTER_WRITE_VALUE to avoid flush per record
Zhongqiang Gong created FLINK-35240: --- Summary: Disable FLUSH_AFTER_WRITE_VALUE to avoid flush per record Key: FLINK-35240 URL: https://issues.apache.org/jira/browse/FLINK-35240 Project: Flink Issue Type: Improvement Components: Connectors / FileSystem Reporter: Zhongqiang Gong Attachments: image-2024-04-26-00-23-29-975.png According to user email: https://lists.apache.org/thread/9j5z8hv4vjkd54dkzqy1ryyvm0l5rxhc !image-2024-04-26-00-23-29-975.png! I found `org.apache.flink.formats.csv.CsvBulkWriter#addElement` will flush per record. I think maybe we can disable `FLUSH_AFTER_WRITE_VALUE` to avoid flush when a record added. -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (FLINK-35182) Bump org.apache.commons:commons-compress from 1.24.0 to 1.26.1 for Flink Pulsar connector
Zhongqiang Gong created FLINK-35182: --- Summary: Bump org.apache.commons:commons-compress from 1.24.0 to 1.26.1 for Flink Pulsar connector Key: FLINK-35182 URL: https://issues.apache.org/jira/browse/FLINK-35182 Project: Flink Issue Type: Technical Debt Components: Connectors / Pulsar Reporter: Zhongqiang Gong -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (FLINK-35181) CLONE - Bump org.apache.commons:commons-compress from 1.24.0 to 1.26.1 for Flink Elasticsearch connector
Zhongqiang Gong created FLINK-35181: --- Summary: CLONE - Bump org.apache.commons:commons-compress from 1.24.0 to 1.26.1 for Flink Elasticsearch connector Key: FLINK-35181 URL: https://issues.apache.org/jira/browse/FLINK-35181 Project: Flink Issue Type: Technical Debt Components: Connectors/ RabbitMQ Reporter: Zhongqiang Gong Assignee: Danny Cranmer Fix For: rabbitmq-3.1.0 Bump org.apache.commons:commons-compress from 1.24.0 to 1.26.1 for Flink RabbitMQ connector -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (FLINK-35010) Bump org.apache.commons:commons-compress from 1.25.0 to 1.26.0 for Flink Mongodb connector
Zhongqiang Gong created FLINK-35010: --- Summary: Bump org.apache.commons:commons-compress from 1.25.0 to 1.26.0 for Flink Mongodb connector Key: FLINK-35010 URL: https://issues.apache.org/jira/browse/FLINK-35010 Project: Flink Issue Type: Technical Debt Components: Connectors / MongoDB Reporter: Zhongqiang Gong -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (FLINK-34958) Add support Flink 1.20-SNAPSHOT and bump flink-connector-parent to 1.1.0 for mongodb connector
Zhongqiang Gong created FLINK-34958: --- Summary: Add support Flink 1.20-SNAPSHOT and bump flink-connector-parent to 1.1.0 for mongodb connector Key: FLINK-34958 URL: https://issues.apache.org/jira/browse/FLINK-34958 Project: Flink Issue Type: Improvement Components: Connectors / MongoDB Reporter: Zhongqiang Gong Changes: * Add support Flink 1.20-SNAPSHOT * Bump flink-connector-parent to 1.1.0 -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (FLINK-34953) Add github ci for flink-web to auto commit build files
Zhongqiang Gong created FLINK-34953: --- Summary: Add github ci for flink-web to auto commit build files Key: FLINK-34953 URL: https://issues.apache.org/jira/browse/FLINK-34953 Project: Flink Issue Type: Improvement Components: Project Website Reporter: Zhongqiang Gong Currently, https://github.com/apache/flink-web commit build files by local build. So I want use github ci to build docs and commit. Changes: * Add website build check for pr * Auto build and commit build files after pr was merged to `asf-site` * Optinal: this ci can triggered by manual -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (FLINK-34946) Flink Website Menu Adjustment
Zhongqiang Gong created FLINK-34946: --- Summary: Flink Website Menu Adjustment Key: FLINK-34946 URL: https://issues.apache.org/jira/browse/FLINK-34946 Project: Flink Issue Type: Improvement Components: Project Website Reporter: Zhongqiang Gong {color:#00}Discuss Thread: https://lists.apache.org/thread/fvxrhc9nxzkjkt9t4ctmmopy9wlbp7wp[link title|[DISCUSS] Flink Website Menu Adjustment]{color} {color:#00}Expected Outcome :{color} {color:#00}- Menu "Getting Started" {color} {quote}{color:#00}Before:{color} {quote}{color:#00}With Flink{color}{quote} {quote}{color:#00}With Flink Stateful Functions{color}{quote} {quote}{color:#00}With Flink ML{color}{quote} {quote}{color:#00}With Flink Kubernetes Operator{color}{quote} {quote}{color:#00}With Paimon(incubating) (formerly Flink Table Store){color}{quote} {quote}{color:#00}With Flink CDC{color}{quote} {quote}{color:#00}Training Course{color}{quote} {color:#00} {color}{color:#00}After:{color} {quote}{color:#00}With Flink{color} {color:#00}With Flink Kubernetes Operator{color}{quote} {quote}{color:#00}With Flink CDC{color}{quote} {quote}{color:#00}With Flink ML {color}{quote} {quote}{color:#00}With Flink Stateful Functions{color}{quote} {quote}{color:#00}Training Course{color}{quote}{quote} {quote}{color:#00} {color}{quote} {color:#00}- Menu "Documentation" will same with "Getting Started"{color} -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (FLINK-34943) Support Flink 1.19, 1.20-SNAPSHOT for OpenSearch connector
Zhongqiang Gong created FLINK-34943: --- Summary: Support Flink 1.19, 1.20-SNAPSHOT for OpenSearch connector Key: FLINK-34943 URL: https://issues.apache.org/jira/browse/FLINK-34943 Project: Flink Issue Type: Improvement Components: Connectors / JDBC Reporter: Zhongqiang Gong -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (FLINK-34732) Add document dead link check for Flink CDC Documentation
Zhongqiang Gong created FLINK-34732: --- Summary: Add document dead link check for Flink CDC Documentation Key: FLINK-34732 URL: https://issues.apache.org/jira/browse/FLINK-34732 Project: Flink Issue Type: Sub-task Components: Flink CDC Reporter: Zhongqiang Gong Add ci for check dead link in flink cdc document. -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (FLINK-34578) Remove issue template
Zhongqiang Gong created FLINK-34578: --- Summary: Remove issue template Key: FLINK-34578 URL: https://issues.apache.org/jira/browse/FLINK-34578 Project: Flink Issue Type: Sub-task Components: Flink CDC Reporter: Zhongqiang Gong Flink cdc had done repo migration. So we should remove issue template. -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (FLINK-34577) Add IssueNavigationLink for IDEA git log
Zhongqiang Gong created FLINK-34577: --- Summary: Add IssueNavigationLink for IDEA git log Key: FLINK-34577 URL: https://issues.apache.org/jira/browse/FLINK-34577 Project: Flink Issue Type: Sub-task Components: Flink CDC Reporter: Zhongqiang Gong Add IssueNavigationLink for IDEA git log -- This message was sent by Atlassian Jira (v8.20.10#820010)
Re: [VOTE] FLIP-377: Support fine-grained configuration to control filter push down for Table/SQL Sources
+1 (non-binding) Best, Zhongqiang Gong On 2024/01/09 11:38:40 Jiabao Sun wrote: > Hi Devs, > > I'd like to start a vote on FLIP-377: Support fine-grained configuration to > control filter push down for Table/SQL Sources[1] > which has been discussed in this thread[2]. > > The vote will be open for at least 72 hours unless there is an objection or > not enough votes. > > [1] https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=276105768 > [2] https://lists.apache.org/thread/nvxx8sp9jm009yywm075hoffr632tm7j > > Best, > Jiabao
Re: [VOTE] Release flink-connector-rabbitmq, v3.0.2 release candidate #1
+1 (non-binding) - Build with JDK 11 on ubuntu 22.04 - Gpg sign is correct - No binary files in the source release - Reviewed web pr (need to rebase) Best, Zhongqiang Gong On 2024/01/12 12:50:53 Martijn Visser wrote: > Hi everyone, > Please review and vote on the release candidate #1 for the version > 3.0.2, as follows: > [ ] +1, Approve the release > [ ] -1, Do not approve the release (please provide specific comments) > > This version is compatible with Flink 1.16.x, 1.17.x and 1.18.x. > > The complete staging area is available for your review, which includes: > * JIRA release notes [1], > * the official Apache source release to be deployed to dist.apache.org > [2], which are signed with the key with fingerprint > A5F3BCE4CBE993573EC5966A65321B8382B219AF [3], > * all artifacts to be deployed to the Maven Central Repository [4], > * source code tag v3.0.2-rc1 [5], > * website pull request listing the new release [6]. > > The vote will be open for at least 72 hours. It is adopted by majority > approval, with at least 3 PMC affirmative votes. > > Thanks, > Release Manager > > [1] > https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12315522&version=12353145 > [2] > https://dist.apache.org/repos/dist/dev/flink/flink-connector-rabbitmq-3.0.2-rc1 > [3] https://dist.apache.org/repos/dist/release/flink/KEYS > [4] https://repository.apache.org/content/repositories/orgapacheflink-1697 > [5] https://github.com/apache/flink-connector-rabbitmq/releases/tag/v3.0.2-rc1 > [6] https://github.com/apache/flink-web/pull/712 >
[jira] [Created] (FLINK-34018) Add flink 1.19 verison in ci for flink-connector-aws
Zhongqiang Gong created FLINK-34018: --- Summary: Add flink 1.19 verison in ci for flink-connector-aws Key: FLINK-34018 URL: https://issues.apache.org/jira/browse/FLINK-34018 Project: Flink Issue Type: Improvement Reporter: Zhongqiang Gong Add flink 1.19 verison in ci for flink-connector-aws -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (FLINK-34017) Connectors docs with 404 link in dynamodb.md
Zhongqiang Gong created FLINK-34017: --- Summary: Connectors docs with 404 link in dynamodb.md Key: FLINK-34017 URL: https://issues.apache.org/jira/browse/FLINK-34017 Project: Flink Issue Type: Improvement Components: Documentation Reporter: Zhongqiang Gong Attachments: image-2024-01-08-17-21-16-434.png docs Link: [https://nightlies.apache.org/flink/flink-docs-release-1.18/docs/connectors/datastream/dynamodb/|http://example.com/] screenshort: !image-2024-01-08-17-21-16-434.png! -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Created] (FLINK-32767) Fix en-doc SHOW CREATE TABLE usage
Zhongqiang Gong created FLINK-32767: --- Summary: Fix en-doc SHOW CREATE TABLE usage Key: FLINK-32767 URL: https://issues.apache.org/jira/browse/FLINK-32767 Project: Flink Issue Type: Bug Reporter: Zhongqiang Gong -- This message was sent by Atlassian Jira (v8.20.10#820010)