Re: [PR] [FLINK-34593][release] Add release note for version 1.19 [flink]

2024-03-17 Thread via GitHub
lincoln-lil merged PR #24505: URL: https://github.com/apache/flink/pull/24505 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.a

Re: [PR] Add GPG key for 1.19.0 release [flink-docker]

2024-03-17 Thread via GitHub
lincoln-lil merged PR #187: URL: https://github.com/apache/flink-docker/pull/187 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flin

Re: [PR] [FLINK-34548][api] Introduce DataStream, Partitioning and ProcessFunction [flink]

2024-03-17 Thread via GitHub
reswqa commented on code in PR #24422: URL: https://github.com/apache/flink/pull/24422#discussion_r1527940518 ## flink-process-function-parent/flink-process-function/src/main/java/org/apache/flink/process/impl/ExecutionEnvironmentImpl.java: ## @@ -0,0 +1,341 @@ +/* + * Licensed

Re: [PR] [FLINK-34548][api] Introduce DataStream, Partitioning and ProcessFunction [flink]

2024-03-17 Thread via GitHub
reswqa commented on code in PR #24422: URL: https://github.com/apache/flink/pull/24422#discussion_r1527936405 ## flink-process-function-parent/flink-process-function/src/test/java/org/apache/flink/process/impl/ExecutionEnvironmentImplTest.java: ## @@ -0,0 +1,84 @@ +/* + * Licens

Re: [PR] [FLINK-34548][api] Introduce DataStream, Partitioning and ProcessFunction [flink]

2024-03-17 Thread via GitHub
reswqa commented on code in PR #24422: URL: https://github.com/apache/flink/pull/24422#discussion_r1527936405 ## flink-process-function-parent/flink-process-function/src/test/java/org/apache/flink/process/impl/ExecutionEnvironmentImplTest.java: ## @@ -0,0 +1,84 @@ +/* + * Licens

[jira] [Updated] (FLINK-34713) Updates the docs stable version

2024-03-17 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-34713: Summary: Updates the docs stable version (was: CLONE - Updates the docs stable version) > Update

[jira] [Updated] (FLINK-34714) Start End of Life discussion thread for now outdated Flink minor version

2024-03-17 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-34714: Summary: Start End of Life discussion thread for now outdated Flink minor version (was: CLONE - S

[jira] [Updated] (FLINK-34714) Start End of Life discussion thread for now outdated Flink minor version

2024-03-17 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-34714: Reporter: Lincoln Lee (was: Matthias Pohl) > Start End of Life discussion thread for now outdated

[jira] [Updated] (FLINK-34713) Updates the docs stable version

2024-03-17 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34713?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-34713: Reporter: Lincoln Lee (was: Sergey Nuyanzin) > Updates the docs stable version >

[jira] [Updated] (FLINK-34711) Other announcements

2024-03-17 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34711?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-34711: Reporter: Lincoln Lee (was: Sergey Nuyanzin) > Other announcements > --- > >

[jira] [Updated] (FLINK-34711) Other announcements

2024-03-17 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34711?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-34711: Summary: Other announcements (was: CLONE - Other announcements) > Other announcements > -

[jira] [Resolved] (FLINK-34687) Home Page of Flink CDC Documentation

2024-03-17 Thread Leonard Xu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Leonard Xu resolved FLINK-34687. Resolution: Resolved Resolved in flink-cdc(master) via : aa9e91ce4599d8c5a51df82cea4e31aed7d2f634

Re: [PR] [FLINK-34687][cdc][docs] Build the home page of Flink CDC documentation [flink-cdc]

2024-03-17 Thread via GitHub
leonardBang merged PR #3156: URL: https://github.com/apache/flink-cdc/pull/3156 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink

Re: [PR] [FLINK-34648] add waitChangeResultRequest and WaitChangeResultResponse to avoid RPC timeout. [flink-cdc]

2024-03-17 Thread via GitHub
BaoPiao commented on PR #3128: URL: https://github.com/apache/flink-cdc/pull/3128#issuecomment-2003029727 > @BaoPiao Yeah, this is because SchemaRegistryRequestHandler doesn't clear pendingSchemaChanges when SchemaOperator restarted, I've added one commit [7aba6a4](https://github.com/apache

[jira] [Updated] (FLINK-34710) Apache mailing lists announcements

2024-03-17 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-34710: Summary: Apache mailing lists announcements (was: CLONE - Apache mailing lists announcements) >

[jira] [Updated] (FLINK-34710) Apache mailing lists announcements

2024-03-17 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-34710: Reporter: Lincoln Lee (was: Sergey Nuyanzin) > Apache mailing lists announcements > -

[jira] [Updated] (FLINK-34708) Merge website pull request

2024-03-17 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-34708: Summary: Merge website pull request (was: CLONE - Merge website pull request) > Merge website pu

[jira] [Updated] (FLINK-34709) Remove outdated versions

2024-03-17 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34709?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-34709: Summary: Remove outdated versions (was: CLONE - Remove outdated versions) > Remove outdated versi

[jira] [Assigned] (FLINK-34712) CLONE - Update reference data for Migration Tests

2024-03-17 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee reassigned FLINK-34712: --- Assignee: lincoln lee (was: Sergey Nuyanzin) > CLONE - Update reference data for Migration

[jira] [Updated] (FLINK-34712) CLONE - Update reference data for Migration Tests

2024-03-17 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-34712: Reporter: Lincoln Lee (was: Sergey Nuyanzin) > CLONE - Update reference data for Migration Tests

[jira] [Updated] (FLINK-34712) CLONE - Update reference data for Migration Tests

2024-03-17 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-34712: Fix Version/s: 1.20.0 1.19.1 (was: 1.19.0)

[jira] [Updated] (FLINK-34712) Update reference data for Migration Tests

2024-03-17 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-34712: Summary: Update reference data for Migration Tests (was: CLONE - Update reference data for Migrat

[jira] [Updated] (FLINK-34709) Remove outdated versions

2024-03-17 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34709?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-34709: Reporter: Lincoln Lee (was: Sergey Nuyanzin) > Remove outdated versions > ---

[jira] [Updated] (FLINK-34707) CLONE - Update japicmp configuration

2024-03-17 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-34707: Fix Version/s: 1.20.0 1.19.1 (was: 1.19.0)

[jira] [Assigned] (FLINK-34708) CLONE - Merge website pull request

2024-03-17 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee reassigned FLINK-34708: --- Assignee: lincoln lee > CLONE - Merge website pull request > --

[jira] [Updated] (FLINK-34707) Update japicmp configuration

2024-03-17 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-34707: Summary: Update japicmp configuration (was: CLONE - Update japicmp configuration) > Update japic

[jira] [Updated] (FLINK-34708) CLONE - Merge website pull request

2024-03-17 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34708?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-34708: Reporter: Lincoln Lee (was: Sergey Nuyanzin) > CLONE - Merge website pull request > -

Re: [PR] [FLINK-34648] add waitChangeResultRequest and WaitChangeResultResponse to avoid RPC timeout. [flink-cdc]

2024-03-17 Thread via GitHub
yanghuaiGit commented on PR #3128: URL: https://github.com/apache/flink-cdc/pull/3128#issuecomment-2003023705 如果schemaRegister的pending里有多个待执行schema事件,isSchemaChangeApplying代表的是正在执行schema变更事件,但是无法得知是哪个schema事件执行,isSchemaChangeApplying无法和客户端的事件绑定,导致schemaoperator可能需要等待所有的schema事件执行完才会转为非阻塞 -

[jira] [Assigned] (FLINK-34707) CLONE - Update japicmp configuration

2024-03-17 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee reassigned FLINK-34707: --- Assignee: lincoln lee (was: Sergey Nuyanzin) > CLONE - Update japicmp configuration >

[jira] [Created] (FLINK-34714) CLONE - Start End of Life discussion thread for now outdated Flink minor version

2024-03-17 Thread lincoln lee (Jira)
lincoln lee created FLINK-34714: --- Summary: CLONE - Start End of Life discussion thread for now outdated Flink minor version Key: FLINK-34714 URL: https://issues.apache.org/jira/browse/FLINK-34714 Projec

[jira] [Created] (FLINK-34711) CLONE - Other announcements

2024-03-17 Thread lincoln lee (Jira)
lincoln lee created FLINK-34711: --- Summary: CLONE - Other announcements Key: FLINK-34711 URL: https://issues.apache.org/jira/browse/FLINK-34711 Project: Flink Issue Type: Sub-task Re

[jira] [Assigned] (FLINK-34706) Promote release 1.19

2024-03-17 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee reassigned FLINK-34706: --- Assignee: lincoln lee (was: Jing Ge) > Promote release 1.19 > > >

[jira] [Updated] (FLINK-34706) Promote release 1.19

2024-03-17 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34706?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-34706: Reporter: Lincoln Lee (was: Sergey Nuyanzin) > Promote release 1.19 > > >

[jira] [Created] (FLINK-34713) CLONE - Updates the docs stable version

2024-03-17 Thread lincoln lee (Jira)
lincoln lee created FLINK-34713: --- Summary: CLONE - Updates the docs stable version Key: FLINK-34713 URL: https://issues.apache.org/jira/browse/FLINK-34713 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-34712) CLONE - Update reference data for Migration Tests

2024-03-17 Thread lincoln lee (Jira)
lincoln lee created FLINK-34712: --- Summary: CLONE - Update reference data for Migration Tests Key: FLINK-34712 URL: https://issues.apache.org/jira/browse/FLINK-34712 Project: Flink Issue Type: S

[jira] [Created] (FLINK-34710) CLONE - Apache mailing lists announcements

2024-03-17 Thread lincoln lee (Jira)
lincoln lee created FLINK-34710: --- Summary: CLONE - Apache mailing lists announcements Key: FLINK-34710 URL: https://issues.apache.org/jira/browse/FLINK-34710 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-34709) CLONE - Remove outdated versions

2024-03-17 Thread lincoln lee (Jira)
lincoln lee created FLINK-34709: --- Summary: CLONE - Remove outdated versions Key: FLINK-34709 URL: https://issues.apache.org/jira/browse/FLINK-34709 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-34708) CLONE - Merge website pull request

2024-03-17 Thread lincoln lee (Jira)
lincoln lee created FLINK-34708: --- Summary: CLONE - Merge website pull request Key: FLINK-34708 URL: https://issues.apache.org/jira/browse/FLINK-34708 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-34707) CLONE - Update japicmp configuration

2024-03-17 Thread lincoln lee (Jira)
lincoln lee created FLINK-34707: --- Summary: CLONE - Update japicmp configuration Key: FLINK-34707 URL: https://issues.apache.org/jira/browse/FLINK-34707 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-34706) Promote release 1.19

2024-03-17 Thread lincoln lee (Jira)
lincoln lee created FLINK-34706: --- Summary: Promote release 1.19 Key: FLINK-34706 URL: https://issues.apache.org/jira/browse/FLINK-34706 Project: Flink Issue Type: New Feature Affects Versio

Re: [PR] [build] fix jackson conflicts among cdc connectors [flink-cdc]

2024-03-17 Thread via GitHub
Shawn-Hx commented on code in PR #2987: URL: https://github.com/apache/flink-cdc/pull/2987#discussion_r1527909731 ## pom.xml: ## @@ -95,6 +96,36 @@ under the License. + +com.fasterxml.jackson.core Review Comment: Thanks for your

Re: [PR] [FLINK-34668][checkpoint] Report operator state handle of file merging directory to JM [flink]

2024-03-17 Thread via GitHub
flinkbot commented on PR #24513: URL: https://github.com/apache/flink/pull/24513#issuecomment-2003011938 ## CI report: * 8cc6814c6ea3b5dee6280f350ec293cb06ece658 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [FLINK-34684 & 34683][docs] Add licenses & contributing docs in Flink CDC [flink-cdc]

2024-03-17 Thread via GitHub
LYanquan commented on code in PR #3159: URL: https://github.com/apache/flink-cdc/pull/3159#discussion_r1527773536 ## docs/content/docs/developer-guide/contribute-to-flink-cdc.md: ## @@ -23,3 +23,62 @@ KIND, either express or implied. See the License for the specific language g

[jira] [Updated] (FLINK-34668) Report State handle of file merging directory to JM

2024-03-17 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34668: --- Labels: pull-request-available (was: ) > Report State handle of file merging directory to J

[PR] [FLINK-34668][checkpoint] Report operator state handle of file merging directory to JM [flink]

2024-03-17 Thread via GitHub
fredia opened a new pull request, #24513: URL: https://github.com/apache/flink/pull/24513 ## What is the purpose of the change Operator states are stored in `taskownd/` dir when file merging is enabled, this PR reports the operator state handle of file merging directory to JM

Re: [PR] [FLINK-34548][api] Introduce DataStream, Partitioning and ProcessFunction [flink]

2024-03-17 Thread via GitHub
reswqa commented on code in PR #24422: URL: https://github.com/apache/flink/pull/24422#discussion_r1527893607 ## flink-process-function-parent/flink-process-function-api/src/main/java/org/apache/flink/process/api/stream/KeyedPartitionStream.java: ## @@ -0,0 +1,186 @@ +/* + * Lic

Re: [PR] [build] fix inconsistent Kafka shading among cdc connectors [flink-cdc]

2024-03-17 Thread via GitHub
link3280 commented on code in PR #2988: URL: https://github.com/apache/flink-cdc/pull/2988#discussion_r1527893588 ## flink-cdc-connect/flink-cdc-source-connectors/flink-sql-connector-tidb-cdc/pom.xml: ## @@ -60,6 +60,12 @@ under the License.

Re: [PR] [FLINK-34548][api] Introduce DataStream, Partitioning and ProcessFunction [flink]

2024-03-17 Thread via GitHub
reswqa commented on code in PR #24422: URL: https://github.com/apache/flink/pull/24422#discussion_r1527888923 ## flink-process-function-parent/flink-process-function-api/src/main/java/org/apache/flink/process/api/stream/BroadcastStream.java: ## @@ -0,0 +1,68 @@ +/* + * Licensed

Re: [PR] [build] fix inconsistent Kafka shading among cdc connectors [flink-cdc]

2024-03-17 Thread via GitHub
link3280 commented on code in PR #2988: URL: https://github.com/apache/flink-cdc/pull/2988#discussion_r1527886955 ## flink-cdc-connect/flink-cdc-source-connectors/flink-sql-connector-tidb-cdc/pom.xml: ## @@ -60,6 +60,12 @@ under the License.

Re: [PR] [FLINK-34548][api] Introduce DataStream, Partitioning and ProcessFunction [flink]

2024-03-17 Thread via GitHub
reswqa commented on code in PR #24422: URL: https://github.com/apache/flink/pull/24422#discussion_r1527883895 ## flink-core-api/pom.xml: ## @@ -0,0 +1,60 @@ + + +http://maven.apache.org/POM/4.0.0"; xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; +xsi:sche

Re: [PR] [FLINK-34548][api] Introduce DataStream, Partitioning and ProcessFunction [flink]

2024-03-17 Thread via GitHub
reswqa commented on code in PR #24422: URL: https://github.com/apache/flink/pull/24422#discussion_r1527879616 ## flink-process-function-parent/flink-process-function/src/main/java/org/apache/flink/process/impl/ExecutionEnvironmentImpl.java: ## @@ -0,0 +1,341 @@ +/* + * Licensed

Re: [PR] [build] fix inconsistent Kafka shading among cdc connectors [flink-cdc]

2024-03-17 Thread via GitHub
leonardBang commented on code in PR #2988: URL: https://github.com/apache/flink-cdc/pull/2988#discussion_r1527879357 ## flink-cdc-connect/flink-cdc-source-connectors/flink-sql-connector-tidb-cdc/pom.xml: ## @@ -60,6 +60,12 @@ under the License.

Re: [PR] [FLINK-34679][cdc] add doc under core-concept. [flink-cdc]

2024-03-17 Thread via GitHub
LYanquan commented on PR #3153: URL: https://github.com/apache/flink-cdc/pull/3153#issuecomment-2002977044 address it. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To un

Re: [PR] [FLINK-34548][api] Introduce DataStream, Partitioning and ProcessFunction [flink]

2024-03-17 Thread via GitHub
reswqa commented on code in PR #24422: URL: https://github.com/apache/flink/pull/24422#discussion_r1527870916 ## flink-process-function-parent/flink-process-function/src/main/java/org/apache/flink/streaming/api/transformations/ProcessFunctionSinkTransformation.java: ## @@ -0,0 +

Re: [PR] [FLINK-34548][api] Introduce DataStream, Partitioning and ProcessFunction [flink]

2024-03-17 Thread via GitHub
reswqa commented on code in PR #24422: URL: https://github.com/apache/flink/pull/24422#discussion_r1527867946 ## flink-process-function-parent/flink-process-function/src/main/java/org/apache/flink/process/impl/operators/ProcessOperator.java: ## @@ -0,0 +1,71 @@ +/* + * Licensed

Re: [PR] [FLINK-34689][MySQL][Feature] check binlog_row_value_optoins [flink-cdc]

2024-03-17 Thread via GitHub
leonardBang commented on PR #3148: URL: https://github.com/apache/flink-cdc/pull/3148#issuecomment-2002970708 Thanks @SML0127 for the contribution, @ruanhang1993 Would you like to help review this PR? -- This is an automated message from the Apache Git Service. To respond to the message,

Re: [PR] [FLINK-34548][api] Introduce DataStream, Partitioning and ProcessFunction [flink]

2024-03-17 Thread via GitHub
reswqa commented on code in PR #24422: URL: https://github.com/apache/flink/pull/24422#discussion_r1527863818 ## flink-process-function-parent/flink-process-function-api/src/main/java/org/apache/flink/process/api/function/ProcessFunction.java: ## @@ -0,0 +1,50 @@ +/* + * License

[jira] [Commented] (FLINK-34702) Rank should not convert to StreamExecDuplicate when the input is not insert only

2024-03-17 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34702?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17827843#comment-17827843 ] lincoln lee commented on FLINK-34702: - [~jackylau] Thank you for reporting this!  Th

[jira] [Commented] (FLINK-34689) check binlog_row_value_optoins

2024-03-17 Thread Lee SeungMin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34689?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17827840#comment-17827840 ] Lee SeungMin commented on FLINK-34689: -- Assign this pr to me please > check binlog

[jira] [Updated] (FLINK-34680) "Connectors - Overview" Page for Flink CDC Documentation

2024-03-17 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34680: --- Labels: pull-request-available (was: ) > "Connectors - Overview" Page for Flink CDC Docume

[jira] [Updated] (FLINK-34705) org.apache.flink.connector.elasticsearch.sink.ElasticsearchWriterITCase FAILURE

2024-03-17 Thread baihailiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] baihailiang updated FLINK-34705: Description:   {code:java} // code placeholder [ERROR] Tests run: 1, Failures: 0, Errors: 1, Skipp

[jira] [Updated] (FLINK-34548) FLIP-409: DataStream V2 Building Blocks: DataStream, Partitioning and ProcessFunction

2024-03-17 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34548: --- Labels: pull-request-available (was: ) > FLIP-409: DataStream V2 Building Blocks: DataStrea

[jira] [Created] (FLINK-34705) org.apache.flink.connector.elasticsearch.sink.ElasticsearchWriterITCase FAILURE

2024-03-17 Thread baihailiang (Jira)
baihailiang created FLINK-34705: --- Summary: org.apache.flink.connector.elasticsearch.sink.ElasticsearchWriterITCase FAILURE Key: FLINK-34705 URL: https://issues.apache.org/jira/browse/FLINK-34705 Project

Re: [PR] [FLINK-34548][api] Introduce DataStream, Partitioning and ProcessFunction [flink]

2024-03-17 Thread via GitHub
WencongLiu commented on code in PR #24422: URL: https://github.com/apache/flink/pull/24422#discussion_r1523101423 ## flink-process-function-parent/flink-process-function-api/src/main/java/org/apache/flink/process/api/stream/BroadcastStream.java: ## @@ -0,0 +1,68 @@ +/* + * Licen

Re: [PR] [FLINK-29114][connector][filesystem] Fix issue of file overwriting caused by multiple writes to the same sink table and shared staging directory [flink]

2024-03-17 Thread via GitHub
flinkbot commented on PR #24512: URL: https://github.com/apache/flink/pull/24512#issuecomment-2002894151 ## CI report: * 79ca29c5dd966fe4af885c9e5b18a737c5e5b6e9 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[PR] [FLINK-29114][connector][filesystem] Fix issue of file overwriting caused by multiple writes to the same sink table and shared staging directory [flink]

2024-03-17 Thread via GitHub
LadyForest opened a new pull request, #24512: URL: https://github.com/apache/flink/pull/24512 ## What is the purpose of the change This PR is cherry-picked from https://github.com/apache/flink/pull/24390 ## Brief change log - Fix unstable TableSourceITCase#testTableHintWi

Re: [PR] [FLINK-34684 & 34683][docs] Add licenses & contributing docs in Flink CDC [flink-cdc]

2024-03-17 Thread via GitHub
LYanquan commented on code in PR #3159: URL: https://github.com/apache/flink-cdc/pull/3159#discussion_r1527773536 ## docs/content/docs/developer-guide/contribute-to-flink-cdc.md: ## @@ -23,3 +23,62 @@ KIND, either express or implied. See the License for the specific language g

Re: [PR] [FLINK-34684 & 34683][docs] Add licenses & contributing docs in Flink CDC [flink-cdc]

2024-03-17 Thread via GitHub
LYanquan commented on code in PR #3159: URL: https://github.com/apache/flink-cdc/pull/3159#discussion_r1527773536 ## docs/content/docs/developer-guide/contribute-to-flink-cdc.md: ## @@ -23,3 +23,62 @@ KIND, either express or implied. See the License for the specific language g

Re: [PR] [FLINK-34679][cdc] add doc under core-concept. [flink-cdc]

2024-03-17 Thread via GitHub
leonardBang commented on code in PR #3153: URL: https://github.com/apache/flink-cdc/pull/3153#discussion_r1527763427 ## docs/content/docs/core-concept/data-pipeline.md: ## @@ -23,3 +23,80 @@ KIND, either express or implied. See the License for the specific language governing p

[jira] [Created] (FLINK-34704) Process checkpoint barrier in AsyncWaitOperator when the element queue is full

2024-03-17 Thread Zakelly Lan (Jira)
Zakelly Lan created FLINK-34704: --- Summary: Process checkpoint barrier in AsyncWaitOperator when the element queue is full Key: FLINK-34704 URL: https://issues.apache.org/jira/browse/FLINK-34704 Project:

Re: [PR] [FLINK-29114][connector][filesystem] Fix issue of file overwriting caused by multiple writes to the same sink table and shared staging directory [flink]

2024-03-17 Thread via GitHub
flinkbot commented on PR #24511: URL: https://github.com/apache/flink/pull/24511#issuecomment-2002875245 ## CI report: * 09a83bf383c13f3262a61279871cc0e9882f6e47 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [FLINK-34678][cdc] Add introduction page for Flink CDC docs [flink-cdc]

2024-03-17 Thread via GitHub
leonardBang commented on code in PR #3158: URL: https://github.com/apache/flink-cdc/pull/3158#discussion_r1527756592 ## docs/content/docs/get-started/introduction.md: ## @@ -23,3 +23,98 @@ KIND, either express or implied. See the License for the specific language governing per

[PR] [FLINK-29114][connector][filesystem] Fix issue of file overwriting caused by multiple writes to the same sink table and shared staging directory [flink]

2024-03-17 Thread via GitHub
LadyForest opened a new pull request, #24511: URL: https://github.com/apache/flink/pull/24511 ## What is the purpose of the change This PR is cherry-picked from https://github.com/apache/flink/pull/24390 ## Brief change log - Fix unstable TableSourceITCase#testTableHi

Re: [PR] [FLINK-34687][cdc][docs] Build the home page of Flink CDC documentation [flink-cdc]

2024-03-17 Thread via GitHub
PatrickRen commented on code in PR #3156: URL: https://github.com/apache/flink-cdc/pull/3156#discussion_r1527754771 ## docs/content/_index.md: ## @@ -22,17 +22,179 @@ specific language governing permissions and limitations under the License. --> - + + + +

[PR] [FLINK-34684 & 34683][docs] Add licenses & contributing docs in Flink CDC [flink-cdc]

2024-03-17 Thread via GitHub
ruanhang1993 opened a new pull request, #3159: URL: https://github.com/apache/flink-cdc/pull/3159 This PR adds licenses & contributing docs to Flink CDC. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to

[jira] [Updated] (FLINK-34684) "Developer Guide - Licenses" Page for Flink CDC Documentation

2024-03-17 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34684?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34684: --- Labels: pull-request-available (was: ) > "Developer Guide - Licenses" Page for Flink CDC Do

Re: [PR] [cdc][cli][2934]Submit CDC Job To Flink K8S Native Application Mode [flink-cdc]

2024-03-17 Thread via GitHub
czy006 commented on code in PR #3093: URL: https://github.com/apache/flink-cdc/pull/3093#discussion_r1527747030 ## flink-cdc-cli/src/main/java/org/apache/flink/cdc/cli/CliFrontendOptions.java: ## @@ -46,6 +46,16 @@ public class CliFrontendOptions { .desc("JA

Re: [PR] [FLINK-34648] add waitChangeResultRequest and WaitChangeResultResponse to avoid RPC timeout. [flink-cdc]

2024-03-17 Thread via GitHub
fanqiejiang8 commented on PR #3128: URL: https://github.com/apache/flink-cdc/pull/3128#issuecomment-2002855730 @lvyanquan @BaoPiao When task parallelism is multiple, task retry all sent SchemaRegistry task more the RefreshPendingListsRequest request, that each request will not cause data in

Re: [PR] [build] fix jackson conflicts among cdc connectors [flink-cdc]

2024-03-17 Thread via GitHub
link3280 commented on PR #2987: URL: https://github.com/apache/flink-cdc/pull/2987#issuecomment-2002817974 ping @leonardBang -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment.

Re: [PR] [build] fix inconsistent Kafka shading among cdc connectors [flink-cdc]

2024-03-17 Thread via GitHub
link3280 commented on PR #2988: URL: https://github.com/apache/flink-cdc/pull/2988#issuecomment-2002816885 ping @leonardBang -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment.

Re: [PR] [FLINK-34679][cdc] add doc under core-concept. [flink-cdc]

2024-03-17 Thread via GitHub
LYanquan commented on PR #3153: URL: https://github.com/apache/flink-cdc/pull/3153#issuecomment-2002777037 @leonardBang @PatrickRen PTAL. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the spec

[jira] [Updated] (FLINK-34678) "Introduction" Page for Flink CDC Documentation

2024-03-17 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-34678: --- Labels: pull-request-available (was: ) > "Introduction" Page for Flink CDC Documentation >

[PR] [FLINK-34678][cdc] Add introduction page for Flink CDC docs [flink-cdc]

2024-03-17 Thread via GitHub
PatrickRen opened a new pull request, #3158: URL: https://github.com/apache/flink-cdc/pull/3158 This pull request adds introduction page for Flink CDC docs. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above

Re: [PR] [FLINK-32074][checkpoint] Merge file across checkpoints [flink]

2024-03-17 Thread via GitHub
masteryhx commented on PR #24497: URL: https://github.com/apache/flink/pull/24497#issuecomment-2002763228 Thanks for the update. Merged 841f23c7 into master. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL a

[jira] [Resolved] (FLINK-32074) Support file merging across checkpoints

2024-03-17 Thread Hangxiang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-32074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu resolved FLINK-32074. -- Resolution: Fixed Merged 841f23c7 into master > Support file merging across checkpoints > ---

Re: [PR] [FLINK-32074][checkpoint] Merge file across checkpoints [flink]

2024-03-17 Thread via GitHub
masteryhx closed pull request #24497: [FLINK-32074][checkpoint] Merge file across checkpoints URL: https://github.com/apache/flink/pull/24497 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the spec

[jira] [Resolved] (FLINK-34334) Add sub-task level RocksDB file count metric

2024-03-17 Thread Hangxiang Yu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hangxiang Yu resolved FLINK-34334. -- Resolution: Fixed Merged  [{{0921968}}|https://github.com/apache/flink/commit/0921968bb7d38bfa

Re: [PR] [FLINK-34334][state] Add sub-task level RocksDB file count metrics [flink]

2024-03-17 Thread via GitHub
masteryhx closed pull request #24322: [FLINK-34334][state] Add sub-task level RocksDB file count metrics URL: https://github.com/apache/flink/pull/24322 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go

Re: [PR] Add announcement blog post for Flink 1.19 [flink-web]

2024-03-17 Thread via GitHub
lincoln-lil commented on PR #721: URL: https://github.com/apache/flink-web/pull/721#issuecomment-2002757799 Finalize the commits before merging... -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

Re: [PR] [FLINK-34687][cdc][docs] Build the home page of Flink CDC documentation [flink-cdc]

2024-03-17 Thread via GitHub
xleoken commented on PR #3156: URL: https://github.com/apache/flink-cdc/pull/3156#issuecomment-2002754671 👍 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe,

Re: [PR] [FLINK-34671][cdc] update README.md file to update links and description. [flink-cdc]

2024-03-17 Thread via GitHub
LYanquan commented on PR #3152: URL: https://github.com/apache/flink-cdc/pull/3152#issuecomment-2002750194 @leonardBang @PatrickRen PTAL. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the spec

[jira] [Commented] (FLINK-20578) Cannot create empty array using ARRAY[]

2024-03-17 Thread Nathan Taylor Armstrong Lewis (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17827826#comment-17827826 ] Nathan Taylor Armstrong Lewis commented on FLINK-20578: --- Does anyo

Re: [PR] [FLINK-34660][checkpoint] Parse cluster configuration for AutoRescalingITCase#testCheckpointRescalingInKeyedState [flink]

2024-03-17 Thread via GitHub
masteryhx commented on PR #24504: URL: https://github.com/apache/flink/pull/24504#issuecomment-2002742851 Thanks for the review. Merged e79df354 into master. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL a

Re: [PR] [FLINK-34660][checkpoint] Parse cluster configuration for AutoRescalingITCase#testCheckpointRescalingInKeyedState [flink]

2024-03-17 Thread via GitHub
masteryhx closed pull request #24504: [FLINK-34660][checkpoint] Parse cluster configuration for AutoRescalingITCase#testCheckpointRescalingInKeyedState URL: https://github.com/apache/flink/pull/24504 -- This is an automated message from the Apache Git Service. To respond to the message, pleas

[jira] [Closed] (FLINK-34571) SortMergeResultPartitionReadSchedulerTest.testOnReadBufferRequestError failed due an assertion

2024-03-17 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo closed FLINK-34571. -- Fix Version/s: 1.19.1 Resolution: Fixed > SortMergeResultPartitionReadSchedulerTest.testOnReadB

[jira] [Comment Edited] (FLINK-34571) SortMergeResultPartitionReadSchedulerTest.testOnReadBufferRequestError failed due an assertion

2024-03-17 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825198#comment-17825198 ] Weijie Guo edited comment on FLINK-34571 at 3/18/24 1:36 AM: -

Re: [PR] [BP-1.19][FLINK-34571][test] Fix flaky test SortMergeResultPartitionReadSchedulerTest.testOnReadBufferRequestError [flink]

2024-03-17 Thread via GitHub
reswqa merged PR #24479: URL: https://github.com/apache/flink/pull/24479 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.apache

Re: [PR] [Flink 34569][e2e] fail fast if AWS cli container fails to start [flink]

2024-03-17 Thread via GitHub
robobario commented on code in PR #24491: URL: https://github.com/apache/flink/pull/24491#discussion_r1527607029 ## flink-end-to-end-tests/test-scripts/common_s3_operations.sh: ## @@ -58,7 +64,11 @@ function aws_cli_stop() { if [[ $AWSCLI_CONTAINER_ID ]]; then aws_cli_stop

[jira] [Assigned] (FLINK-34633) Support unnesting array constants

2024-03-17 Thread Xingcan Cui (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xingcan Cui reassigned FLINK-34633: --- Assignee: Jeyhun Karimov > Support unnesting array constants >

Re: [PR] [FLINK-34633][table] Support unnesting array constants [flink]

2024-03-17 Thread via GitHub
flinkbot commented on PR #24510: URL: https://github.com/apache/flink/pull/24510#issuecomment-2002539941 ## CI report: * e239874a6d95df04d4c5919b09fc800b82cacc44 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

  1   2   >