[jira] [Commented] (FLINK-16686) [State TTL] Make user class loader available in native RocksDB compaction thread

2025-02-27 Thread liting liu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17931382#comment-17931382 ] liting liu commented on FLINK-16686: it still happens to flink 1.18.1 {code:java} //

[jira] [Commented] (FLINK-37067) Cross-team verification for “Introduce DataStream API V2”

2025-02-27 Thread Yutong Han (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17931384#comment-17931384 ] Yutong Han commented on FLINK-37067: Tested for  * Event Timer Service  * Windowin

[jira] [Updated] (FLINK-36702) FLIP-480: Support to deploy SQL script in application mode

2025-02-27 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-36702: --- Fix Version/s: 2.0.0 > FLIP-480: Support to deploy SQL script in application mode >

[jira] [Commented] (FLINK-37318) RocksDBKeyedStateBackend disposed before task exit

2025-02-27 Thread Nil Madhab (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17931381#comment-17931381 ] Nil Madhab commented on FLINK-37318: I am new to flink and trying to contribute. Can

Re: [PR] [FLINK-37397][python] Fix deactivate error build-wheel.sh script [flink]

2025-02-27 Thread via GitHub
snuyanzin commented on PR #26225: URL: https://github.com/apache/flink/pull/26225#issuecomment-2689918471 fyi: this night the nightly is green 👍 🎉 -- 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-36172][metrics][rest] Optimize transient metric cleanup [flink]

2025-02-27 Thread via GitHub
JunRuiLee commented on PR #26204: URL: https://github.com/apache/flink/pull/26204#issuecomment-2689852623 @flinkbot run azure -- 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-37386] Emit CreateTableEvent only when met the related SourceRecord. [flink-cdc]

2025-02-27 Thread via GitHub
lvyanquan commented on code in PR #3932: URL: https://github.com/apache/flink-cdc/pull/3932#discussion_r1974878864 ## flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/source/reader/MySqlPipelineRecordE

Re: [PR] [FLINK-37386] Emit CreateTableEvent only when met the related SourceRecord. [flink-cdc]

2025-02-27 Thread via GitHub
lvyanquan commented on code in PR #3932: URL: https://github.com/apache/flink-cdc/pull/3932#discussion_r1974878864 ## flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/source/reader/MySqlPipelineRecordE

Re: [PR] [FLINK-37403] Convert interval join to regular join for updating source [flink]

2025-02-27 Thread via GitHub
flinkbot commented on PR #26230: URL: https://github.com/apache/flink/pull/26230#issuecomment-2689845339 ## CI report: * 68f318d7f9fbb40514c08db81c440e081417ada8 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [FLINK-37386] Emit CreateTableEvent only when met the related SourceRecord. [flink-cdc]

2025-02-27 Thread via GitHub
yuxiqian commented on code in PR #3932: URL: https://github.com/apache/flink-cdc/pull/3932#discussion_r1974819667 ## flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/source/reader/MySqlPipelineRecordEm

Re: [PR] [FLINK-31949][python] make CountTumblingWindow default trigger to purge all elements on fire [flink]

2025-02-27 Thread via GitHub
flinkbot commented on PR #26229: URL: https://github.com/apache/flink/pull/26229#issuecomment-2689822301 ## CI report: * f24dfbbc49aa199ebb2f4c6887a4983a6b8831b2 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-37403) Support retractions/updates for IntervalJoin operator

2025-02-27 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-37403: --- Labels: pull-request-available (was: ) > Support retractions/updates for IntervalJoin opera

Re: [PR] [FLINK-16080][docs-zh] Translate new DISTRIBUTED BY documentation into Chinese [flink]

2025-02-27 Thread via GitHub
JinkunLiu commented on code in PR #26196: URL: https://github.com/apache/flink/pull/26196#discussion_r1974824154 ## docs/content/docs/dev/table/sourcesSinks.md: ## @@ -335,8 +335,8 @@ the `ParallelismProvider` interface. Enables to write partitioned data in a DynamicTa

Re: [PR] [FLINK-37386] Emit CreateTableEvent only when met the related SourceRecord. [flink-cdc]

2025-02-27 Thread via GitHub
yuxiqian commented on code in PR #3932: URL: https://github.com/apache/flink-cdc/pull/3932#discussion_r1974819667 ## flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-mysql/src/main/java/org/apache/flink/cdc/connectors/mysql/source/reader/MySqlPipelineRecordEm

[jira] [Updated] (FLINK-31949) The state of CountTumblingWindowAssigner of Python DataStream API were never purged

2025-02-27 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-31949: --- Labels: pull-request-available (was: ) > The state of CountTumblingWindowAssigner of Python

Re: [PR] [FLINK-16080][docs-zh] Translate new DISTRIBUTED BY documentation into Chinese [flink]

2025-02-27 Thread via GitHub
JinkunLiu commented on code in PR #26196: URL: https://github.com/apache/flink/pull/26196#discussion_r1972685145 ## docs/content/docs/dev/table/sql/create.md: ## @@ -502,7 +502,7 @@ You can control the merging behavior of: * GENERATED - computed columns * METADATA - metadata c

[PR] [FLINK-31949][python] make CountTumblingWindow default trigger to purge all elements on fire [flink]

2025-02-27 Thread via GitHub
suez1224 opened a new pull request, #26229: URL: https://github.com/apache/flink/pull/26229 … ## What is the purpose of the change *(For example: This pull request makes task deployment go through the blob server, rather than through RPC. That way we avoid re-transferri

Re: [PR] [FLINK-25920] bump flink version to 1.20.1. [flink-connector-kafka]

2025-02-27 Thread via GitHub
loserwang1024 commented on PR #158: URL: https://github.com/apache/flink-connector-kafka/pull/158#issuecomment-2689781695 @AHeise @leonardBang , CC -- 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 t

Re: [PR] [BP-2.0][FLINK-37384][runtime] Optimize the parallelism decide logic for pointwise [flink]

2025-02-27 Thread via GitHub
JunRuiLee closed pull request #26215: [BP-2.0][FLINK-37384][runtime] Optimize the parallelism decide logic for pointwise URL: https://github.com/apache/flink/pull/26215 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the

Re: [PR] [FLINK-36652] Upgrade Apache ORC Version to 1.9.4 [flink]

2025-02-27 Thread via GitHub
dyccode closed pull request #26194: [FLINK-36652] Upgrade Apache ORC Version to 1.9.4 URL: https://github.com/apache/flink/pull/26194 -- 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 com

[jira] [Updated] (FLINK-37386) Avoid sending too much CreateTableEvents when job failover

2025-02-27 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37386?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-37386: --- Labels: pull-request-available (was: ) > Avoid sending too much CreateTableEvents when job

Re: [PR] [FLINK-37386] Emit CreateTableEvent only when met the related SourceRecord. [flink-cdc]

2025-02-27 Thread via GitHub
lvyanquan commented on PR #3932: URL: https://github.com/apache/flink-cdc/pull/3932#issuecomment-2689714283 Hi @yuxiqian. Could you help to review this? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL ab

Re: [PR] Bump io.netty:netty-common from 4.1.46.Final to 4.1.118.Final in /flink-end-to-end-tests/flink-end-to-end-tests-hive [flink]

2025-02-27 Thread via GitHub
dependabot[bot] commented on PR #26158: URL: https://github.com/apache/flink/pull/26158#issuecomment-2689701365 Dependabot couldn't find a pom.xml. Because of this, Dependabot cannot update this pull request. -- This is an automated message from the Apache Git Service. To respond to the m

Re: [PR] Bump org.apache.hive:hive-exec from 2.3.10 to 4.0.1 in /flink-connectors/flink-sql-connector-hive-2.3.10 [flink]

2025-02-27 Thread via GitHub
dependabot[bot] commented on PR #26090: URL: https://github.com/apache/flink/pull/26090#issuecomment-2689701353 Dependabot couldn't find a pom.xml. Because of this, Dependabot cannot update this pull request. -- This is an automated message from the Apache Git Service. To respond to the m

Re: [PR] [FLINK-36997] Add Log4j JSONTemplateLayout to flink-dist [flink]

2025-02-27 Thread via GitHub
Zakelly merged PR #25888: URL: https://github.com/apache/flink/pull/25888 -- 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.apach

[jira] [Commented] (FLINK-36997) Add Log4j JSONTemplateLayout to Flink-Dist

2025-02-27 Thread Zakelly Lan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17931366#comment-17931366 ] Zakelly Lan commented on FLINK-36997: - Merge 85a9fc8a016aec31671667ccb5d1ea19be51682

[jira] [Resolved] (FLINK-36997) Add Log4j JSONTemplateLayout to Flink-Dist

2025-02-27 Thread Zakelly Lan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36997?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan resolved FLINK-36997. - Assignee: Ryan van Huuksloot Resolution: Fixed > Add Log4j JSONTemplateLayout to Flink-Dis

[jira] [Comment Edited] (FLINK-25920) Allow receiving updates of CommittableSummary

2025-02-27 Thread Hongshun Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17931359#comment-17931359 ] Hongshun Wang edited comment on FLINK-25920 at 2/28/25 3:05 AM: --

Re: [PR] [BP-2.0][FLINK-37400] Remove redundant serializer duplication during value serialization of ForSt states [flink]

2025-02-27 Thread via GitHub
Zakelly merged PR #26228: URL: https://github.com/apache/flink/pull/26228 -- 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.apach

[jira] [Commented] (FLINK-37403) Support retractions/updates for IntervalJoin operator

2025-02-27 Thread Xuyang Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37403?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17931365#comment-17931365 ] Xuyang Zhong commented on FLINK-37403: -- Hi, [~bvarghese] . I'm curious why don't we

[jira] [Comment Edited] (FLINK-25920) Allow receiving updates of CommittableSummary

2025-02-27 Thread Hongshun Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17931359#comment-17931359 ] Hongshun Wang edited comment on FLINK-25920 at 2/28/25 3:16 AM: --

[PR] [FLINK-25920] bump flink version to 1.20.1. [flink-connector-kafka]

2025-02-27 Thread via GitHub
loserwang1024 opened a new pull request, #158: URL: https://github.com/apache/flink-connector-kafka/pull/158 Currently, test often error with "Currently it is not supported to update the CommittableSummary for a checkpoint coming from the same subtask. Please check the status of FLINK-25920

[jira] [Updated] (FLINK-37400) Redundant serializer duplication during value serialization of ForSt states

2025-02-27 Thread Zakelly Lan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan updated FLINK-37400: Affects Version/s: 2.0.0 > Redundant serializer duplication during value serialization of ForSt st

[jira] [Commented] (FLINK-37400) Redundant serializer duplication during value serialization of ForSt states

2025-02-27 Thread Zakelly Lan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17931363#comment-17931363 ] Zakelly Lan commented on FLINK-37400: - * master ** fe1b77785fca59f9c46f4de92a3b6432

[jira] [Updated] (FLINK-37400) Redundant serializer duplication during value serialization of ForSt states

2025-02-27 Thread Zakelly Lan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan updated FLINK-37400: Fix Version/s: 2.0.0 > Redundant serializer duplication during value serialization of ForSt states

[jira] [Resolved] (FLINK-37400) Redundant serializer duplication during value serialization of ForSt states

2025-02-27 Thread Zakelly Lan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan resolved FLINK-37400. - Resolution: Fixed > Redundant serializer duplication during value serialization of ForSt states

Re: [PR] [FLINK-37400] Remove redundant serializer duplication during value serialization of ForSt states [flink]

2025-02-27 Thread via GitHub
Zakelly merged PR #26227: URL: https://github.com/apache/flink/pull/26227 -- 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.apach

[jira] [Commented] (FLINK-25920) Allow receiving updates of CommittableSummary

2025-02-27 Thread Hongshun Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17931359#comment-17931359 ] Hongshun Wang commented on FLINK-25920: --- [~arvid] Hi, I have met this in kafka con

[jira] [Comment Edited] (FLINK-25920) Allow receiving updates of CommittableSummary

2025-02-27 Thread Hongshun Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-25920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17931359#comment-17931359 ] Hongshun Wang edited comment on FLINK-25920 at 2/28/25 3:02 AM: --

[jira] [Closed] (FLINK-37384) the execution time of DefaultVertexParallelismAndInputInfosDecider exceeds expectations in specific scenarios

2025-02-27 Thread Junrui Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37384?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Junrui Lee closed FLINK-37384. -- Resolution: Fixed master  741ff29b67535427eedb7b8a757b6acbd12c40e5 d45f0da6d02e5260e015f771c36bea447

Re: [PR] [FLINK-37384][runtime] Optimize the parallelism decide logic for pointwise [flink]

2025-02-27 Thread via GitHub
JunRuiLee closed pull request #26210: [FLINK-37384][runtime] Optimize the parallelism decide logic for pointwise URL: https://github.com/apache/flink/pull/26210 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL abov

[jira] [Updated] (FLINK-37382) Early optimization for adaptive join when one input is below broadcast threshold

2025-02-27 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37382?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-37382: Fix Version/s: (was: 2.0.1) > Early optimization for adaptive join when one input is below broadcast

Re: [PR] [BP-2.0][FLINK-37400] Remove redundant serializer duplication during value serialization of ForSt states [flink]

2025-02-27 Thread via GitHub
Zakelly commented on PR #26228: URL: https://github.com/apache/flink/pull/26228#issuecomment-2689561681 @flinkbot run azure -- 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] add updateBinlogStartPoint function [flink-cdc]

2025-02-27 Thread via GitHub
github-actions[bot] closed pull request #3671: add updateBinlogStartPoint function URL: https://github.com/apache/flink-cdc/pull/3671 -- 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 com

Re: [PR] add updateBinlogStartPoint function [flink-cdc]

2025-02-27 Thread via GitHub
github-actions[bot] commented on PR #3671: URL: https://github.com/apache/flink-cdc/pull/3671#issuecomment-2689384867 This pull request has been closed because it has not had recent activity. You could reopen it if you try to continue your work, and anyone who are interested in it are encou

[jira] [Created] (FLINK-37404) Reenable Migration Tests for Filnk 2.x

2025-02-27 Thread Kurt Ostfeld (Jira)
Kurt Ostfeld created FLINK-37404: Summary: Reenable Migration Tests for Filnk 2.x Key: FLINK-37404 URL: https://issues.apache.org/jira/browse/FLINK-37404 Project: Flink Issue Type: Technical

[jira] [Updated] (FLINK-37404) Reenable Migration Tests for Filnk 2.x

2025-02-27 Thread Kurt Ostfeld (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Ostfeld updated FLINK-37404: - Priority: Blocker (was: Major) > Reenable Migration Tests for Filnk 2.x > -

[jira] [Updated] (FLINK-37404) Reenable Migration Tests for Filnk 2.x

2025-02-27 Thread Kurt Ostfeld (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kurt Ostfeld updated FLINK-37404: - Issue Type: Improvement (was: Technical Debt) > Reenable Migration Tests for Filnk 2.x > --

Re: [PR] [FLINK-16080][docs-zh] Translate new DISTRIBUTED BY documentation into Chinese [flink]

2025-02-27 Thread via GitHub
jnh5y commented on code in PR #26196: URL: https://github.com/apache/flink/pull/26196#discussion_r1974376977 ## docs/content/docs/dev/table/sourcesSinks.md: ## @@ -335,8 +335,8 @@ the `ParallelismProvider` interface. Enables to write partitioned data in a DynamicTableS

Re: [PR] [FLINK-36146][connector] Fix SingleThreadFetcherManager race condition [flink]

2025-02-27 Thread via GitHub
kimgr commented on PR #25340: URL: https://github.com/apache/flink/pull/25340#issuecomment-2689161591 @becketqin Ping! -- 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

[jira] [Updated] (FLINK-37381) Typo in Join document

2025-02-27 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin updated FLINK-37381: Priority: Minor (was: Critical) > Typo in Join document > - > >

Re: [PR] [FLINK-37381] [doc] Fix typo in Join document [flink]

2025-02-27 Thread via GitHub
snuyanzin commented on PR #26209: URL: https://github.com/apache/flink/pull/26209#issuecomment-2689054204 @cnsky1103 can you please also create backports to at least 2.0 and 1.20 ? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitH

[jira] [Commented] (FLINK-37381) Typo in Join document

2025-02-27 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37381?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17931289#comment-17931289 ] Sergey Nuyanzin commented on FLINK-37381: - it is definitely not critical > Typo

Re: [PR] [FLINK-37385][table] Add support for smile format [flink]

2025-02-27 Thread via GitHub
snuyanzin merged PR #26217: URL: https://github.com/apache/flink/pull/26217 -- 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.apa

[jira] [Closed] (FLINK-37398) State processor API blows up with cryptic error when changelog used

2025-02-27 Thread Gabor Somogyi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi closed FLINK-37398. - > State processor API blows up with cryptic error when changelog used >

[jira] [Resolved] (FLINK-37398) State processor API blows up with cryptic error when changelog used

2025-02-27 Thread Gabor Somogyi (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gabor Somogyi resolved FLINK-37398. --- Fix Version/s: 2.1.0 Resolution: Fixed [{{940d746}}|https://github.com/apache/flink/c

Re: [PR] [FLINK-37398][state] Add proper message when state processor API is used with changelog [flink]

2025-02-27 Thread via GitHub
gaborgsomogyi merged PR #26226: URL: https://github.com/apache/flink/pull/26226 -- 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-36652] Upgrade Apache ORC Version to 1.9.4 [flink]

2025-02-27 Thread via GitHub
snuyanzin commented on PR #26195: URL: https://github.com/apache/flink/pull/26195#issuecomment-2688711405 I tend to think it was fixed at https://github.com/apache/flink/pull/26198 rebase might help -- This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Assigned] (FLINK-31949) The state of CountTumblingWindowAssigner of Python DataStream API were never purged

2025-02-27 Thread Shuyi Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31949?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shuyi Chen reassigned FLINK-31949: -- Assignee: Shuyi Chen > The state of CountTumblingWindowAssigner of Python DataStream API were

[jira] [Commented] (FLINK-31949) The state of CountTumblingWindowAssigner of Python DataStream API were never purged

2025-02-27 Thread Shuyi Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-31949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17931241#comment-17931241 ] Shuyi Chen commented on FLINK-31949: [~dianfu] shall we make the default to be Trigg

[jira] [Commented] (FLINK-37397) Python wheel builds broken in nightly

2025-02-27 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17931239#comment-17931239 ] Sergey Nuyanzin commented on FLINK-37397: - Merged as [b633f9851eba34126d3b876ba

[jira] [Resolved] (FLINK-37397) Python wheel builds broken in nightly

2025-02-27 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin resolved FLINK-37397. - Fix Version/s: 2.0.1 Resolution: Fixed > Python wheel builds broken in nightly >

Re: [PR] [FLINK-37397][python] Fix deactivate error build-wheel.sh script [flink]

2025-02-27 Thread via GitHub
snuyanzin merged PR #26225: URL: https://github.com/apache/flink/pull/26225 -- 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.apa

Re: [PR] [FLINK-37397][python] Fix deactivate error build-wheel.sh script [flink]

2025-02-27 Thread via GitHub
snuyanzin commented on PR #26225: URL: https://github.com/apache/flink/pull/26225#issuecomment-2688662422 Each such check requires a separate job(resource). Now multiply by the amount of PRs everyday. The We can not add all the checks to PR's checks. We need to have a kind of balance. Th

[jira] [Updated] (FLINK-37399) Watermark alignment can prevent backlogged jobs from using all available resources

2025-02-27 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-37399: --- Description: Imagine the following scenario. Max allowed watermark alignment drift is set to

Re: [PR] [FLINK-37400] Remove redundant serializer duplication during value serialization of ForSt states [flink]

2025-02-27 Thread via GitHub
flinkbot commented on PR #26227: URL: https://github.com/apache/flink/pull/26227#issuecomment-2688519334 ## CI report: * 79aa21dd180ecacf8b3564249237cf98d5a7ba1b UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-37403) Support retractions/updates for IntervalJoin operator

2025-02-27 Thread Bonnie Varghese (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37403?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bonnie Varghese updated FLINK-37403: Description: This can be done by converting the IntervalJoin node to RegularJoin node if t

[jira] [Created] (FLINK-37403) Support retractions/updates for IntervalJoin operator

2025-02-27 Thread Bonnie Varghese (Jira)
Bonnie Varghese created FLINK-37403: --- Summary: Support retractions/updates for IntervalJoin operator Key: FLINK-37403 URL: https://issues.apache.org/jira/browse/FLINK-37403 Project: Flink I

Re: [PR] [BP-2.0][FLINK-37400] Remove redundant serializer duplication during value serialization of ForSt states [flink]

2025-02-27 Thread via GitHub
flinkbot commented on PR #26228: URL: https://github.com/apache/flink/pull/26228#issuecomment-2688519683 ## CI report: * 5cbcebbeb19897b107b3fc109b0706344d1d3294 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Assigned] (FLINK-37401) Add Job ID to logging context of slotmanager classes

2025-02-27 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan reassigned FLINK-37401: - Assignee: Aleksandr Savonin > Add Job ID to logging context of slotmanager clas

[jira] [Created] (FLINK-37402) SQL testing sources produce incorrect watermarks

2025-02-27 Thread Timo Walther (Jira)
Timo Walther created FLINK-37402: Summary: SQL testing sources produce incorrect watermarks Key: FLINK-37402 URL: https://issues.apache.org/jira/browse/FLINK-37402 Project: Flink Issue Type:

[jira] [Created] (FLINK-37401) Add Job ID to logging context of slotmanager classes

2025-02-27 Thread Aleksandr Savonin (Jira)
Aleksandr Savonin created FLINK-37401: - Summary: Add Job ID to logging context of slotmanager classes Key: FLINK-37401 URL: https://issues.apache.org/jira/browse/FLINK-37401 Project: Flink

[PR] [BP-2.0][FLINK-37400] Remove redundant serializer duplication during value serialization of ForSt states [flink]

2025-02-27 Thread via GitHub
Zakelly opened a new pull request, #26228: URL: https://github.com/apache/flink/pull/26228 ## What is the purpose of the change When serializing values in ForSt states, the serializer is duplicated every time, which introduces unnecessary overhead. This PR optimize it out. ## B

[jira] [Closed] (FLINK-37269) Add new DESCRIPTOR data type

2025-02-27 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-37269. Fix Version/s: 2.1.0 Resolution: Fixed Fixed in master: 356f5bb8e2e199e3e1c80ed3332d3381699

[jira] [Closed] (FLINK-37336) Introduce TablePipeline to Python API

2025-02-27 Thread Timo Walther (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Timo Walther closed FLINK-37336. Fix Version/s: 2.1.0 Resolution: Fixed Fixed in master: cd62c6cf6783741f2d040518e9b987c43a4

[jira] [Updated] (FLINK-37400) Redundant serializer duplication during value serialization of ForSt states

2025-02-27 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-37400: --- Labels: pull-request-available (was: ) > Redundant serializer duplication during value seri

[PR] [FLINK-37400] Remove redundant serializer duplication during value serialization of ForSt states [flink]

2025-02-27 Thread via GitHub
Zakelly opened a new pull request, #26227: URL: https://github.com/apache/flink/pull/26227 ## What is the purpose of the change When serializing values in ForSt states, the serializer is duplicated every time, which introduces unnecessary overhead. This PR optimize it out. ## B

Re: [PR] [FLINK-37336][python] Introduce TablePipeline descriptor to Python Table API [flink]

2025-02-27 Thread via GitHub
twalthr merged PR #26167: URL: https://github.com/apache/flink/pull/26167 -- 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.apach

[jira] [Updated] (FLINK-37399) Watermark alignment can prevent backlogged jobs from using all available resources

2025-02-27 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-37399: --- Description: Imagine the following scenario. Max allowed watermark alignment drift is set to

[jira] [Created] (FLINK-37400) Redundant serializer duplication during value serialization of ForSt states

2025-02-27 Thread Zakelly Lan (Jira)
Zakelly Lan created FLINK-37400: --- Summary: Redundant serializer duplication during value serialization of ForSt states Key: FLINK-37400 URL: https://issues.apache.org/jira/browse/FLINK-37400 Project: Fl

[jira] [Updated] (FLINK-37399) Watermark alignment can prevent backlogged jobs from using all available resources

2025-02-27 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-37399: --- Description: Imagine the following scenario. Max allowed watermark alignment drift is set to

[jira] [Updated] (FLINK-37399) Watermark alignment can prevent backlogged jobs from using all available resources

2025-02-27 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-37399: --- Description: Imagine the following scenario. Max allowed watermark alignment drift is set to

[jira] [Commented] (FLINK-35076) Watermark alignment will cause data flow to experience serious shake

2025-02-27 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35076?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17931219#comment-17931219 ] Piotr Nowojski commented on FLINK-35076: Hi, selecting {{mean}} instead of {{min

[jira] [Updated] (FLINK-37399) Watermark alignment can prevent backlogged jobs from using all available resources

2025-02-27 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37399?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-37399: --- Description: Imagine the following scenario. Max allowed watermark alignment drift is set to

[jira] [Created] (FLINK-37399) Watermark alignment can prevent backlogged jobs from using all available resources

2025-02-27 Thread Piotr Nowojski (Jira)
Piotr Nowojski created FLINK-37399: -- Summary: Watermark alignment can prevent backlogged jobs from using all available resources Key: FLINK-37399 URL: https://issues.apache.org/jira/browse/FLINK-37399

Re: [PR] [FLINK-36652] Upgrade Apache ORC Version to 1.9.4 [flink]

2025-02-27 Thread via GitHub
dyccode commented on PR #26195: URL: https://github.com/apache/flink/pull/26195#issuecomment-2688289984 @flinkbot run azure -- 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-16080][docs-zh] Translate new DISTRIBUTED BY documentation into Chinese [flink]

2025-02-27 Thread via GitHub
JinkunLiu commented on code in PR #26196: URL: https://github.com/apache/flink/pull/26196#discussion_r1973776002 ## docs/content/docs/dev/table/sourcesSinks.md: ## @@ -335,8 +335,8 @@ the `ParallelismProvider` interface. Enables to write partitioned data in a DynamicTa

Re: [PR] [FLINK-16080][docs-zh] Translate new DISTRIBUTED BY documentation into Chinese [flink]

2025-02-27 Thread via GitHub
JinkunLiu commented on code in PR #26196: URL: https://github.com/apache/flink/pull/26196#discussion_r1973776002 ## docs/content/docs/dev/table/sourcesSinks.md: ## @@ -335,8 +335,8 @@ the `ParallelismProvider` interface. Enables to write partitioned data in a DynamicTa

Re: [PR] [FLINK-37398][state] Add proper message when state processor API is used with changelog [flink]

2025-02-27 Thread via GitHub
gaborgsomogyi commented on PR #26226: URL: https://github.com/apache/flink/pull/26226#issuecomment-2688188046 Mailing list discussion: https://lists.apache.org/thread/z1kdgwnw9ms16p44ny4zyj8dl30ompnd -- This is an automated message from the Apache Git Service. To respond to the message, p

Re: [PR] [FLINK-16080][docs-zh] Translate new DISTRIBUTED BY documentation into Chinese [flink]

2025-02-27 Thread via GitHub
JinkunLiu commented on code in PR #26196: URL: https://github.com/apache/flink/pull/26196#discussion_r1973776002 ## docs/content/docs/dev/table/sourcesSinks.md: ## @@ -335,8 +335,8 @@ the `ParallelismProvider` interface. Enables to write partitioned data in a DynamicTa

Re: [PR] [FLINK-16080][docs-zh] Translate new DISTRIBUTED BY documentation into Chinese [flink]

2025-02-27 Thread via GitHub
JinkunLiu commented on code in PR #26196: URL: https://github.com/apache/flink/pull/26196#discussion_r1973776002 ## docs/content/docs/dev/table/sourcesSinks.md: ## @@ -335,8 +335,8 @@ the `ParallelismProvider` interface. Enables to write partitioned data in a DynamicTa

Re: [PR] [FLINK-37398][state] Add proper message when state processor API is used with changelog [flink]

2025-02-27 Thread via GitHub
flinkbot commented on PR #26226: URL: https://github.com/apache/flink/pull/26226#issuecomment-2688213939 ## CI report: * d63d70a167bb5375c6e18dadb5c1d7b38685b5b0 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [FLINK-36652] Upgrade Apache ORC Version to 1.9.4 [flink]

2025-02-27 Thread via GitHub
dyccode commented on PR #26195: URL: https://github.com/apache/flink/pull/26195#issuecomment-2688195928 > ## CI report: > * [b00ac74](https://github.com/apache/flink/commit/b00ac74ed5f8cdcbe429f1a4b03a3289e9edc613) Azure: [FAILURE](https://dev.azure.com/apache-flink/98463496-1af2-4620-8

Re: [PR] [FLINK-37398][state] Add proper message when state processor API is used with changelog [flink]

2025-02-27 Thread via GitHub
gaborgsomogyi commented on PR #26226: URL: https://github.com/apache/flink/pull/26226#issuecomment-2688188645 cc @Zakelly -- 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. T

Re: [PR] [FLINK-16080][docs-zh] Translate new DISTRIBUTED BY documentation into Chinese [flink]

2025-02-27 Thread via GitHub
jnh5y commented on code in PR #26196: URL: https://github.com/apache/flink/pull/26196#discussion_r1973730506 ## docs/content/docs/dev/table/sourcesSinks.md: ## @@ -335,8 +335,8 @@ the `ParallelismProvider` interface. Enables to write partitioned data in a DynamicTableS

[jira] [Updated] (FLINK-37398) State processor API blows up with cryptic error when changelog used

2025-02-27 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-37398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-37398: --- Labels: pull-request-available (was: ) > State processor API blows up with cryptic error wh

[PR] [FLINK-37398][state] Add proper message when state processor API is used with changelog [flink]

2025-02-27 Thread via GitHub
gaborgsomogyi opened a new pull request, #26226: URL: https://github.com/apache/flink/pull/26226 ## What is the purpose of the change At the moment state processor API blows up with cryptic error when changelog used. ``` Caused by: java.io.IOException: Failed to restore state ba

Re: [PR] [FLINK-36997] Add Log4j JSONTemplateLayout to flink-dist [flink]

2025-02-27 Thread via GitHub
ryanvanhuuksloot commented on code in PR #25888: URL: https://github.com/apache/flink/pull/25888#discussion_r1973718880 ## docs/.gitignore: ## @@ -7,3 +7,4 @@ ruby2/.rubydeps/ public/ resources/ .hugo_build.lock +hugo_extended_*_*-*.tar.gz Review Comment: Removed, I added

Re: [PR] [FLINK-37269][table] Add new DESCRIPTOR type [flink]

2025-02-27 Thread via GitHub
twalthr merged PR #26144: URL: https://github.com/apache/flink/pull/26144 -- 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.apach

Re: [PR] [FLINK-35014] SqlNode to operation conversion for models [flink]

2025-02-27 Thread via GitHub
twalthr commented on code in PR #25834: URL: https://github.com/apache/flink/pull/25834#discussion_r1973700721 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/converters/SqlAlterModelResetConverter.java: ## @@ -0,0 +1,82 @@ +/* + * Lice

  1   2   >