Re: [PR] [FLINK-35192] support jemalloc in image [flink-kubernetes-operator]

2024-05-19 Thread via GitHub
gaborgsomogyi commented on PR #825: URL: https://github.com/apache/flink-kubernetes-operator/pull/825#issuecomment-2119718027 Intended to merge this in a day when no new comments arrive. -- This is an automated message from the Apache Git Service. To respond to the message, please log on

Re: [PR] [FLINK-35049][state] Implement Map Async State API for ForStStateBackend [flink]

2024-05-19 Thread via GitHub
flinkbot commented on PR #24812: URL: https://github.com/apache/flink/pull/24812#issuecomment-2119713722 ## CI report: * 1e616c7d7ad22833c01e8ee5a99eb56345ab3d32 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-35049) Implement Map Async State API for ForStStateBackend

2024-05-19 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-35049: --- Labels: pull-request-available (was: ) > Implement Map Async State API for

[PR] [FLINK-35049][state] Implement Map Async State API for ForStStateBackend [flink]

2024-05-19 Thread via GitHub
fredia opened a new pull request, #24812: URL: https://github.com/apache/flink/pull/24812 ## What is the purpose of the change This PR implements Map Async State API for ForStStateBackend. ## Brief change log - Introduce `ForStDBIterRequest` and

[jira] [Commented] (FLINK-35382) ChangelogCompatibilityITCase.testRestore fails with an NPE

2024-05-19 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17847774#comment-17847774 ] Weijie Guo commented on FLINK-35382:

[jira] [Commented] (FLINK-35138) Release flink-connector-kafka v3.2.0 for Flink 1.19

2024-05-19 Thread Tamir Sagi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17847773#comment-17847773 ] Tamir Sagi commented on FLINK-35138: Hi  Any update about the status here?  Thanks! > Release

[jira] (FLINK-35138) Release flink-connector-kafka v3.2.0 for Flink 1.19

2024-05-19 Thread Tamir Sagi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35138 ] Tamir Sagi deleted comment on FLINK-35138: was (Author: JIRAUSER283777): Hi  Any update about the status here?  Thanks! > Release flink-connector-kafka v3.2.0 for Flink 1.19 >

[jira] [Comment Edited] (FLINK-35138) Release flink-connector-kafka v3.2.0 for Flink 1.19

2024-05-19 Thread Tamir Sagi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17847772#comment-17847772 ] Tamir Sagi edited comment on FLINK-35138 at 5/20/24 5:28 AM: - Hi  Any

[jira] [Commented] (FLINK-35138) Release flink-connector-kafka v3.2.0 for Flink 1.19

2024-05-19 Thread Tamir Sagi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35138?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17847772#comment-17847772 ] Tamir Sagi commented on FLINK-35138: Hi  Any update about the status here?  Thanks. > Release

[jira] [Commented] (FLINK-35341) Retraction stop working with Clock dependent function in Filter

2024-05-19 Thread Benchao Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17847771#comment-17847771 ] Benchao Li commented on FLINK-35341: I think it's a known issue, and has been resolved with the

Re: [PR] [FLINK-25537][JUnit5 Migration] Module: flink-core with,Package: types [flink]

2024-05-19 Thread via GitHub
1996fanrui commented on PR #24613: URL: https://github.com/apache/flink/pull/24613#issuecomment-2119678527 Hi @GOODBOY008 , would you mind rebasing master branch before merging? It can ensure the master branch works well after merging. Also, I will merge this PR if no other comments

Re: [PR] [FLINK-33212][runtime] add job status changed listener for lineage [flink]

2024-05-19 Thread via GitHub
HuangZhenQiu commented on PR #24754: URL: https://github.com/apache/flink/pull/24754#issuecomment-2119645723 @gyfora @JingGe Thanks for your review. I have partially resolved your comments. The lineage graph info is set into StreamGraph in this correlated PR

[jira] [Updated] (FLINK-33212) Introduce job status changed listener for lineage

2024-05-19 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang updated FLINK-33212: -- Description: # Introduce job status changed listener relevant interfaces and its

[jira] [Updated] (FLINK-33212) Introduce job status changed listener for lineage

2024-05-19 Thread Zhenqiu Huang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhenqiu Huang updated FLINK-33212: -- Description: Introduce job status changed listener relevant interfaces and its

Re: [PR] [FLINK-35351][checkpoint] Fix fail during restore from unaligned chec… [flink]

2024-05-19 Thread via GitHub
ldadima commented on code in PR #24784: URL: https://github.com/apache/flink/pull/24784#discussion_r1606228058 ## flink-tests/src/test/java/org/apache/flink/test/checkpointing/UnalignedCheckpointCustomRescaleITCase.java: ## @@ -0,0 +1,182 @@ +/* + * Licensed to the Apache

Re: [PR] [FLINK-35351][checkpoint] Fix fail during restore from unaligned chec… [flink]

2024-05-19 Thread via GitHub
ldadima commented on code in PR #24784: URL: https://github.com/apache/flink/pull/24784#discussion_r1606228058 ## flink-tests/src/test/java/org/apache/flink/test/checkpointing/UnalignedCheckpointCustomRescaleITCase.java: ## @@ -0,0 +1,182 @@ +/* + * Licensed to the Apache

Re: [PR] [hotfix] [streaming] Correct copying StreamPartitioner in rescale case [flink]

2024-05-19 Thread via GitHub
flinkbot commented on PR #24811: URL: https://github.com/apache/flink/pull/24811#issuecomment-2119624639 ## CI report: * 9d1678a93712d67f5ad599431adf649817061869 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [FLINK-35351][checkpoint] Fix fail during restore from unaligned chec… [flink]

2024-05-19 Thread via GitHub
ldadima commented on code in PR #24784: URL: https://github.com/apache/flink/pull/24784#discussion_r1606219365 ## flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/recovery/RescalingStreamTaskNetworkInput.java: ## @@ -232,7 +232,9 @@ public Predicate>

Re: [PR] [FLINK-35351][checkpoint] Fix fail during restore from unaligned chec… [flink]

2024-05-19 Thread via GitHub
ldadima commented on code in PR #24784: URL: https://github.com/apache/flink/pull/24784#discussion_r1606219365 ## flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/recovery/RescalingStreamTaskNetworkInput.java: ## @@ -232,7 +232,9 @@ public Predicate>

[PR] [hotfix] [streaming] Correct copying StreamPartitioner in rescale case [flink]

2024-05-19 Thread via GitHub
ldadima opened a new pull request, #24811: URL: https://github.com/apache/flink/pull/24811 ## What is the purpose of the change Fix copying StreamPartitioner in rescale ## Does this pull request potentially affect one of the following parts: - Dependencies (does it add

[jira] [Commented] (FLINK-35334) Code generation: init method exceeds 64 KB when there is a long array field with Table API

2024-05-19 Thread Simon Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17847765#comment-17847765 ] Simon Lee commented on FLINK-35334: --- Hi [~TsReaper] , I noticed that you solved a similar issue

Re: [PR] [FLINK-35253][docs-zh]Translate "State Processor API "page into Chinese [flink]

2024-05-19 Thread via GitHub
reswqa commented on PR #24780: URL: https://github.com/apache/flink/pull/24780#issuecomment-2119594171 > Hi @drymatini, thanks for your contribution, "State Processor API" was already translated in master, I think documents do not need to be backported to the historical release branch,

Re: [PR] [FLINK-35253][docs-zh]Translate "State Processor API "page into Chinese [flink]

2024-05-19 Thread via GitHub
reswqa closed pull request #24780: [FLINK-35253][docs-zh]Translate "State Processor API "page into Chinese URL: https://github.com/apache/flink/pull/24780 -- 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] [Closed] (FLINK-35253) Translate "State Processor API "page into Chinese

2024-05-19 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo closed FLINK-35253. -- Resolution: Invalid This page is already translated to Chinese in the master branch, I will close

[jira] [Commented] (FLINK-9043) Introduce a friendly way to resume the job from externalized checkpoints automatically

2024-05-19 Thread Michas Szacillo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17847759#comment-17847759 ] Michas Szacillo commented on FLINK-9043: Hi [~sewen], Have there been any updates or decisions

Re: [PR] [FLINK-35221][hive] Support SQL 2011 reserved keywords as identifiers in HiveParser [flink-connector-hive]

2024-05-19 Thread via GitHub
WencongLiu commented on code in PR #18: URL: https://github.com/apache/flink-connector-hive/pull/18#discussion_r1606184817 ## flink-connector-hive/src/main/java/org/apache/flink/table/planner/delegation/hive/HiveParserConstants.java: ## @@ -30,4 +30,6 @@ public class

Re: [PR] [FLINK-35221][hive] Support SQL 2011 reserved keywords as identifiers in HiveParser [flink-connector-hive]

2024-05-19 Thread via GitHub
WencongLiu commented on code in PR #18: URL: https://github.com/apache/flink-connector-hive/pull/18#discussion_r1606184637 ## flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveDialectSupportSQL11ReservedKeywordAsIdentifierTest.java: ## @@ -0,0 +1,230 @@

Re: [PR] [FLINK-35221][hive] Support SQL 2011 reserved keywords as identifiers in HiveParser [flink-connector-hive]

2024-05-19 Thread via GitHub
WencongLiu commented on code in PR #18: URL: https://github.com/apache/flink-connector-hive/pull/18#discussion_r1606184227 ## flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveDialectSupportSQL11ReservedKeywordAsIdentifierTest.java: ## @@ -0,0 +1,230 @@

Re: [PR] [FLINK-35221][hive] Support SQL 2011 reserved keywords as identifiers in HiveParser [flink-connector-hive]

2024-05-19 Thread via GitHub
WencongLiu commented on code in PR #18: URL: https://github.com/apache/flink-connector-hive/pull/18#discussion_r1606183796 ## flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveDialectSupportSQL11ReservedKeywordAsIdentifierTest.java: ## @@ -0,0 +1,230 @@

[jira] [Assigned] (FLINK-35342) MaterializedTableStatementITCase test can check for wrong status

2024-05-19 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo reassigned FLINK-35342: -- Assignee: Feng Jin > MaterializedTableStatementITCase test can check for wrong status >

[jira] [Comment Edited] (FLINK-35342) MaterializedTableStatementITCase test can check for wrong status

2024-05-19 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17847757#comment-17847757 ] Weijie Guo edited comment on FLINK-35342 at 5/20/24 2:38 AM: - 1.20

[jira] [Commented] (FLINK-35342) MaterializedTableStatementITCase test can check for wrong status

2024-05-19 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17847758#comment-17847758 ] Weijie Guo commented on FLINK-35342: 1.20

[jira] [Commented] (FLINK-35342) MaterializedTableStatementITCase test can check for wrong status

2024-05-19 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17847757#comment-17847757 ] Weijie Guo commented on FLINK-35342:

[jira] [Created] (FLINK-35399) Add documents for batch job master failure recovery

2024-05-19 Thread Zhu Zhu (Jira)
Zhu Zhu created FLINK-35399: --- Summary: Add documents for batch job master failure recovery Key: FLINK-35399 URL: https://issues.apache.org/jira/browse/FLINK-35399 Project: Flink Issue Type:

Re: [PR] [hotfix][tests] Fix occasional pipeline E2e testcases failure [flink-cdc]

2024-05-19 Thread via GitHub
yuxiqian commented on PR #3309: URL: https://github.com/apache/flink-cdc/pull/3309#issuecomment-2119538415 Could @PatrickRen help take a look? Thanks! -- 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

Re: [PR] [FLINK-35323][runtime] Fix transform failure when one rule matches multiple tables with incompatible schema [flink-cdc]

2024-05-19 Thread via GitHub
yuxiqian commented on PR #3313: URL: https://github.com/apache/flink-cdc/pull/3313#issuecomment-2119538130 Could @PatrickRen please take a look? Thanks! -- 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

Re: [PR] [BP-3.1][FLINK-35323][runtime] Fix transform failure when one rule matches multiple schemas [flink-cdc]

2024-05-19 Thread via GitHub
yuxiqian commented on PR #3312: URL: https://github.com/apache/flink-cdc/pull/3312#issuecomment-2119537914 Could @PatrickRen help take a look? Thanks! -- 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

Re: [PR] [FLINK-35272][cdc][runtime] Transform projection & filter feature overhaul [flink-cdc]

2024-05-19 Thread via GitHub
yuxiqian commented on PR #3285: URL: https://github.com/apache/flink-cdc/pull/3285#issuecomment-2119537106 cc @PatrickRen @lvyanquan -- 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

[jira] [Commented] (FLINK-35382) ChangelogCompatibilityITCase.testRestore fails with an NPE

2024-05-19 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17847751#comment-17847751 ] Weijie Guo commented on FLINK-35382:

[jira] [Updated] (FLINK-35398) SqlGatewayE2ECase failed to pull image

2024-05-19 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-35398: --- Description: {code:java} Caused by: org.testcontainers.containers.ContainerFetchException: Failed

[jira] [Created] (FLINK-35398) SqlGatewayE2ECase failed to pull image

2024-05-19 Thread Weijie Guo (Jira)
Weijie Guo created FLINK-35398: -- Summary: SqlGatewayE2ECase failed to pull image Key: FLINK-35398 URL: https://issues.apache.org/jira/browse/FLINK-35398 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-35391) Bump dependency of Paimon Pipeline connector to 0.8.0

2024-05-19 Thread LvYanquan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17847748#comment-17847748 ] LvYanquan commented on FLINK-35391: --- Thanks for taking this, please go ahead, I am willing to help

[jira] [Commented] (FLINK-35391) Bump dependency of Paimon Pipeline connector to 0.8.0

2024-05-19 Thread wangjunbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35391?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17847746#comment-17847746 ] wangjunbo commented on FLINK-35391: --- Interested in this, please assign it to me, thanks. > Bump

Re: [PR] Use Schema#newBuilder instead of TableSchema#fromResolvedSchema [flink-cdc]

2024-05-19 Thread via GitHub
snuyanzin commented on PR #2061: URL: https://github.com/apache/flink-cdc/pull/2061#issuecomment-2119349878 sorry, seems I missed it rebased -- 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

[jira] [Commented] (FLINK-35396) DynamoDB Streams Consumer consumption data is out of order

2024-05-19 Thread Suxing Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17847701#comment-17847701 ] Suxing Lee commented on FLINK-35396: Thanks for your reply.  > DynamoDB Streams Consumer

[jira] [Closed] (FLINK-35396) DynamoDB Streams Consumer consumption data is out of order

2024-05-19 Thread Suxing Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35396?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Suxing Lee closed FLINK-35396. -- Resolution: Duplicate > DynamoDB Streams Consumer consumption data is out of order >

[jira] [Commented] (FLINK-35396) DynamoDB Streams Consumer consumption data is out of order

2024-05-19 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17847700#comment-17847700 ] Hong Liang Teoh commented on FLINK-35396: - Here is the Parent-Jira that will introduce the new

[jira] [Commented] (FLINK-35396) DynamoDB Streams Consumer consumption data is out of order

2024-05-19 Thread Hong Liang Teoh (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17847698#comment-17847698 ] Hong Liang Teoh commented on FLINK-35396: - Hi [~Suxing Lee], thanks for reporting this problem.

[jira] [Commented] (FLINK-35396) DynamoDB Streams Consumer consumption data is out of order

2024-05-19 Thread Suxing Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17847688#comment-17847688 ] Suxing Lee commented on FLINK-35396: [~chalixar] Thanks for your reply.

[jira] [Comment Edited] (FLINK-35396) DynamoDB Streams Consumer consumption data is out of order

2024-05-19 Thread Suxing Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17847688#comment-17847688 ] Suxing Lee edited comment on FLINK-35396 at 5/19/24 2:48 PM: - [~chalixar]

Re: [PR] [FLINK-35355][State] Internal async aggregating state and corresponding state descriptor [flink]

2024-05-19 Thread via GitHub
flinkbot commented on PR #24810: URL: https://github.com/apache/flink/pull/24810#issuecomment-2119250508 ## CI report: * febf64d82f15cf1916066709f69aa35a4eb43b25 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[PR] [FLINK-35355][State] Internal async aggregating state and corresponding state descriptor [flink]

2024-05-19 Thread via GitHub
jectpro7 opened a new pull request, #24810: URL: https://github.com/apache/flink/pull/24810 This PR defines the V2 `AggreatingState` and its `StateDescriptor`. And provides the default `InternalAggregatingState` implementation which delegates all aycn request to AEC. ## What

Re: [PR] [FLINK-35355][State] Internal async aggregating state and correspondi… [flink]

2024-05-19 Thread via GitHub
jectpro7 closed pull request #24809: [FLINK-35355][State] Internal async aggregating state and correspondi… URL: https://github.com/apache/flink/pull/24809 -- 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] [Created] (FLINK-35397) Translate Controller Flow documentation into Chinese

2024-05-19 Thread Caican Cai (Jira)
Caican Cai created FLINK-35397: -- Summary: Translate Controller Flow documentation into Chinese Key: FLINK-35397 URL: https://issues.apache.org/jira/browse/FLINK-35397 Project: Flink Issue Type:

[jira] [Updated] (FLINK-35397) Translate Controller Flow documentation into Chinese

2024-05-19 Thread Caican Cai (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Caican Cai updated FLINK-35397: --- Description: Translate Controller Flow documentation into Chinese > Translate Controller Flow

[jira] [Commented] (FLINK-35396) DynamoDB Streams Consumer consumption data is out of order

2024-05-19 Thread Ahmed Hamdy (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17847662#comment-17847662 ] Ahmed Hamdy commented on FLINK-35396: - [~Suxing Lee] Thanks for reporting and the deep dive, I will

[jira] [Closed] (FLINK-33983) Introduce JobEvent and JobEventStore for Batch Job Recovery

2024-05-19 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu closed FLINK-33983. --- Fix Version/s: 1.20.0 Resolution: Done master: c7c1d78752836b96591e31422c65b85eca38bd50 > Introduce

Re: [PR] [FLINK-33983][runtime] Introduce JobEvent and JobEventStore [flink]

2024-05-19 Thread via GitHub
zhuzhurk merged PR #24782: URL: https://github.com/apache/flink/pull/24782 -- 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: