[jira] [Updated] (FLINK-36166) testJoinDisorderChangeLog failed on AZP

2024-08-28 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-36166: --- Description: {code:java} Aug 23 03:59:33 03:59:33.972 [ERROR] Failures: Aug 23 03:59:33 03:59:33.97

[jira] [Created] (FLINK-36166) testJoinDisorderChangeLog failed on AZP

2024-08-28 Thread Weijie Guo (Jira)
Weijie Guo created FLINK-36166: -- Summary: testJoinDisorderChangeLog failed on AZP Key: FLINK-36166 URL: https://issues.apache.org/jira/browse/FLINK-36166 Project: Flink Issue Type: Bug Affec

[jira] [Commented] (FLINK-35810) AsyncWaitOperatorTest.testProcessingTimeRepeatedCompleteUnorderedWithRetry fails

2024-08-28 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35810?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17877267#comment-17877267 ] Weijie Guo commented on FLINK-35810: https://dev.azure.com/apache-flink/apache-flink

[jira] [Created] (FLINK-36167) testSinkDisorderChangeLog failed on AZP

2024-08-28 Thread Weijie Guo (Jira)
Weijie Guo created FLINK-36167: -- Summary: testSinkDisorderChangeLog failed on AZP Key: FLINK-36167 URL: https://issues.apache.org/jira/browse/FLINK-36167 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-36167) testSinkDisorderChangeLog failed on AZP

2024-08-28 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo updated FLINK-36167: --- Description: {code:java} Aug 25 01:42:49 01:42:49.806 [ERROR] Failures: Aug 25 01:42:49 01:42:49.80

[PR] [FLINK-35894][Follow] fix Elasticsearch dependency version [flink-cdc]

2024-08-28 Thread via GitHub
beryllw opened a new pull request, #3581: URL: https://github.com/apache/flink-cdc/pull/3581 Fix elasticsearch dependency version by use `${project.version}` -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL abo

Re: [PR] [FLINK-35894][Follow] fix Elasticsearch dependency version [flink-cdc]

2024-08-28 Thread via GitHub
beryllw commented on PR #3581: URL: https://github.com/apache/flink-cdc/pull/3581#issuecomment-2314533013 @lvyanquan @leonardBang cc, thanks. https://github.com/apache/flink-cdc/pull/3495#discussion_r1691215159 -- This is an automated message from the Apache Git Service. To respond to t

[jira] [Created] (FLINK-36168) AdaptiveSchedulerTest doesn't follow the production lifecycle

2024-08-28 Thread Matthias Pohl (Jira)
Matthias Pohl created FLINK-36168: - Summary: AdaptiveSchedulerTest doesn't follow the production lifecycle Key: FLINK-36168 URL: https://issues.apache.org/jira/browse/FLINK-36168 Project: Flink

[PR] [BP-3.2][hotfix][mysql] Fix primary key restraints missing when using inline `PRIMARY KEY` declaration syntax [flink-cdc]

2024-08-28 Thread via GitHub
yuxiqian opened a new pull request, #3582: URL: https://github.com/apache/flink-cdc/pull/3582 Cherry-picked from #3579. -- 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 u

Re: [PR] [FLINK-35579] update frocksdb version to v8.10.0 [flink]

2024-08-28 Thread via GitHub
mayuehappy commented on PR #25253: URL: https://github.com/apache/flink/pull/25253#issuecomment-2314642891 @Zakelly the CI can pass now , I've two minor changes , please take a look -- This is an automated message from the Apache Git Service. To respond to the message, please log on to Git

Re: [PR] [FLINK-35773][docs] Document s5cmd [flink]

2024-08-28 Thread via GitHub
pnowojski merged PR #25235: URL: https://github.com/apache/flink/pull/25235 -- 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-35773) Document s5cmd

2024-08-28 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-35773. -- Resolution: Fixed merged commit 20e6d63 into apache:master > Document s5cmd > --

[jira] [Closed] (FLINK-35739) FLIP-444: Native file copy support

2024-08-28 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-35739. -- Fix Version/s: 2.0.0 Release Note: Users can now configure Flink to use s5cmd to speed up

[jira] [Updated] (FLINK-35739) FLIP-444: Native file copy support

2024-08-28 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-35739: --- Release Note: Users can now configure Flink to use s5cmd to speed up downloading files from

Re: [PR] fixup! (1.20 backport) [FLINK-35886][task] Fix watermark idleness timeout accounting when subtask is backpressured/blocked [flink]

2024-08-28 Thread via GitHub
pnowojski merged PR #25246: URL: https://github.com/apache/flink/pull/25246 -- 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-35177] Fix DataGen Connector documentation [flink]

2024-08-28 Thread via GitHub
GOODBOY008 commented on code in PR #25259: URL: https://github.com/apache/flink/pull/25259#discussion_r1734244374 ## flink-connectors/flink-connector-datagen/src/main/java/org/apache/flink/connector/datagen/source/DataGeneratorSource.java: ## @@ -76,14 +76,14 @@ * Long values

[jira] [Commented] (FLINK-28554) Kubernetes-Operator allow readOnlyRootFilesystem via operatorSecurityContext

2024-08-28 Thread pgodowski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17877289#comment-17877289 ] pgodowski commented on FLINK-28554: --- Refreshing this old issue, given that the initial

Re: [PR] [FLINK-34555][table] Migrate JoinConditionTypeCoerceRule to java. [flink]

2024-08-28 Thread via GitHub
liuyongvs commented on PR #24420: URL: https://github.com/apache/flink/pull/24420#issuecomment-2314720848 hi @snuyanzin ci passed -- 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 comm

Re: [PR] [FLINK-33678][streaming-java] Remove configuration getters/setters that return/set complex Java objects. [flink]

2024-08-28 Thread via GitHub
JunRuiLee commented on PR #25256: URL: https://github.com/apache/flink/pull/25256#issuecomment-2314735549 @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.

[jira] [Updated] (FLINK-36162) Remove flinkStateSnapshotReference and namespace from FlinkStateSnapshot jobReference

2024-08-28 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-36162: --- Labels: pull-request-available (was: ) > Remove flinkStateSnapshotReference and namespace f

[PR] [FLINK-36162] Remove flinkStateSnapshotReference and namespace from FlinkStateSnapshot jobReference [flink-kubernetes-operator]

2024-08-28 Thread via GitHub
gyfora opened a new pull request, #874: URL: https://github.com/apache/flink-kubernetes-operator/pull/874 ## Change log - *Remove the namespace from snapshot job reference* - *Remove job.flinkStateSnapshotReference* - *Rename upgradeSavepointReference to upgradeSavepointPat

Re: [PR] [FLINK-34896][table] Migrate CorrelateSortToRankRule to java [flink]

2024-08-28 Thread via GitHub
snuyanzin merged PR #24545: URL: https://github.com/apache/flink/pull/24545 -- 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-35054][table] Migrate TemporalJoinRewriteWithUniqueKeyRule to … [flink]

2024-08-28 Thread via GitHub
snuyanzin closed pull request #24635: [FLINK-35054][table] Migrate TemporalJoinRewriteWithUniqueKeyRule to … URL: https://github.com/apache/flink/pull/24635 -- 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] [Commented] (FLINK-34896) Migrate CorrelateSortToRankRule

2024-08-28 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17877312#comment-17877312 ] Sergey Nuyanzin commented on FLINK-34896: - Merged as [f01de3c4303c4f9ec2b5781af

[jira] [Resolved] (FLINK-34896) Migrate CorrelateSortToRankRule

2024-08-28 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-34896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin resolved FLINK-34896. - Fix Version/s: 2.0.0 Resolution: Fixed > Migrate CorrelateSortToRankRule > --

Re: [PR] [FLINK-35266][snapshot] Add E2E tests for FlinkStateSnapshot [flink-kubernetes-operator]

2024-08-28 Thread via GitHub
gyfora merged PR #862: URL: https://github.com/apache/flink-kubernetes-operator/pull/862 -- 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

[jira] [Closed] (FLINK-35266) Add e2e tests for FlinkStateSnapshot CRs

2024-08-28 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35266?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-35266. -- Fix Version/s: kubernetes-operator-1.10.0 Resolution: Fixed merged to main cdd81c7973a9920916f6

Re: [PR] [FLINK-31380][table] Support enhanced show catalogs syntax [flink]

2024-08-28 Thread via GitHub
snuyanzin commented on PR #22179: URL: https://github.com/apache/flink/pull/22179#issuecomment-2314886822 Hi @chucheng92 thanks for your contribution and sorry for the long delay there was a refactoring for show operations within FLINK-36085 to extract common logic Do you mind

Re: [PR] [FLINK-35062][table] Migrate RewriteMultiJoinConditionRule to java [flink]

2024-08-28 Thread via GitHub
liuyongvs commented on PR #24642: URL: https://github.com/apache/flink/pull/24642#issuecomment-2314897443 hi @snuyanzin will you help 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 above to go to

Re: [PR] [FLINK-35751][table] Migrate SplitPythonConditionFromCorrelateRule to java [flink]

2024-08-28 Thread via GitHub
liuyongvs commented on PR #25014: URL: https://github.com/apache/flink/pull/25014#issuecomment-2314901558 hi @snuyanzin will you help 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 above to go to

[jira] [Assigned] (FLINK-35054) Migrate TemporalJoinRewriteWithUniqueKeyRule

2024-08-28 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin reassigned FLINK-35054: --- Assignee: Jacky Lau > Migrate TemporalJoinRewriteWithUniqueKeyRule > --

[jira] [Commented] (FLINK-35054) Migrate TemporalJoinRewriteWithUniqueKeyRule

2024-08-28 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17877318#comment-17877318 ] Sergey Nuyanzin commented on FLINK-35054: - Merged as https://github.com/apache/

[jira] [Resolved] (FLINK-35054) Migrate TemporalJoinRewriteWithUniqueKeyRule

2024-08-28 Thread Sergey Nuyanzin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sergey Nuyanzin resolved FLINK-35054. - Resolution: Fixed > Migrate TemporalJoinRewriteWithUniqueKeyRule > -

Re: [PR] [FLINK-36145][snapshot] Rename flinkStateSnapshotReference to snapshotReference [flink-kubernetes-operator]

2024-08-28 Thread via GitHub
gyfora closed pull request #870: [FLINK-36145][snapshot] Rename flinkStateSnapshotReference to snapshotReference URL: https://github.com/apache/flink-kubernetes-operator/pull/870 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub an

Re: [PR] [FLINK-36145][snapshot] Rename flinkStateSnapshotReference to snapshotReference [flink-kubernetes-operator]

2024-08-28 Thread via GitHub
gyfora commented on PR #870: URL: https://github.com/apache/flink-kubernetes-operator/pull/870#issuecomment-2314916329 Closing this in favour of actually removing this feature for now as discussed in https://issues.apache.org/jira/browse/FLINK-36162 -- This is an automated message from t

[jira] [Closed] (FLINK-36145) Change JobSpec.flinkStateSnapshotReference to snapshotReference

2024-08-28 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora closed FLINK-36145. -- Resolution: Won't Fix > Change JobSpec.flinkStateSnapshotReference to snapshotReference >

Re: [PR] [hotfix][mysql] Fix primary key restraints missing when using inline `PRIMARY KEY` declaration syntax [flink-cdc]

2024-08-28 Thread via GitHub
leonardBang merged PR #3579: URL: https://github.com/apache/flink-cdc/pull/3579 -- 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-35579] update frocksdb version to v8.10.0 [flink]

2024-08-28 Thread via GitHub
Zakelly commented on code in PR #25253: URL: https://github.com/apache/flink/pull/25253#discussion_r1734490350 ## flink-end-to-end-tests/test-scripts/common.sh: ## @@ -296,7 +296,7 @@ function relocate_rocksdb_logs { # After FLINK-24785, RocksDB's log would be created under F

Re: [PR] [FLINK-36117] Implement AsyncKeyedStateBackend for RocksDBKeyedStateBackend and HeapKeyedStateBackend [flink]

2024-08-28 Thread via GitHub
Zakelly commented on code in PR #25233: URL: https://github.com/apache/flink/pull/25233#discussion_r1734500935 ## flink-runtime/src/test/java/org/apache/flink/runtime/state/v2/AsyncKeyedStateBackendAdaptorTest.java: ## @@ -0,0 +1,188 @@ +/* + * Licensed to the Apache Software Fo

Re: [PR] [FLINK-36117] Implement AsyncKeyedStateBackend for RocksDBKeyedStateBackend and HeapKeyedStateBackend [flink]

2024-08-28 Thread via GitHub
Zakelly commented on PR #25233: URL: https://github.com/apache/flink/pull/25233#issuecomment-2315075690 And a rebase is needed since there are conflicts with master branch. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and u

Re: [PR] [FLINK-35177] Fix DataGen Connector documentation [flink]

2024-08-28 Thread via GitHub
morozov commented on code in PR #25259: URL: https://github.com/apache/flink/pull/25259#discussion_r1734530400 ## docs/content.zh/docs/connectors/datastream/datagen.md: ## @@ -65,14 +65,13 @@ Rate Limiting `Long` values at the overall source rate (across all source subtasks) no

Re: [PR] [FLINK-35579] update frocksdb version to v8.10.0 [flink]

2024-08-28 Thread via GitHub
mayuehappy commented on code in PR #25253: URL: https://github.com/apache/flink/pull/25253#discussion_r1734556704 ## flink-end-to-end-tests/test-scripts/common.sh: ## @@ -296,7 +296,7 @@ function relocate_rocksdb_logs { # After FLINK-24785, RocksDB's log would be created unde

Re: [PR] [FLINK-35579] update frocksdb version to v8.10.0 [flink]

2024-08-28 Thread via GitHub
Zakelly commented on code in PR #25253: URL: https://github.com/apache/flink/pull/25253#discussion_r1734569350 ## flink-end-to-end-tests/test-scripts/common.sh: ## @@ -296,7 +296,7 @@ function relocate_rocksdb_logs { # After FLINK-24785, RocksDB's log would be created under F

Re: [PR] [FLINK-35579] update frocksdb version to v8.10.0 [flink]

2024-08-28 Thread via GitHub
mayuehappy commented on code in PR #25253: URL: https://github.com/apache/flink/pull/25253#discussion_r1734574904 ## flink-end-to-end-tests/test-scripts/common.sh: ## @@ -296,7 +296,7 @@ function relocate_rocksdb_logs { # After FLINK-24785, RocksDB's log would be created unde

[jira] [Updated] (FLINK-36168) AdaptiveSchedulerTest doesn't follow the production lifecycle

2024-08-28 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-36168: --- Labels: pull-request-available (was: ) > AdaptiveSchedulerTest doesn't follow the productio

[PR] [FLINK-36168] [runtime] AdaptiveSchedulerTest doesn't follow the production lifecycle [flink]

2024-08-28 Thread via GitHub
ztison opened a new pull request, #25260: URL: https://github.com/apache/flink/pull/25260 ## What is the purpose of the change This ensures that the `AdaptiveSchedulerTest` follows the correct production lifecycle. Specifically, the change aims to address the issue where t

Re: [PR] [FLINK-22748] Allow dynamic target topic selection in SQL Kafka sinks [flink-connector-kafka]

2024-08-28 Thread via GitHub
AHeise commented on PR #109: URL: https://github.com/apache/flink-connector-kafka/pull/109#issuecomment-2315256803 LGTM from my side, I'd approve once CI passes. Thank you very much for your contribution! -- This is an automated message from the Apache Git Service. To respond to the mess

Re: [PR] [FLINK-36168] [runtime] AdaptiveSchedulerTest doesn't follow the production lifecycle [flink]

2024-08-28 Thread via GitHub
flinkbot commented on PR #25260: URL: https://github.com/apache/flink/pull/25260#issuecomment-2315261205 ## CI report: * e5bf6b3beef6f0883ac88ad2762f33cada0caae5 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [FLINK-36149][table] Make the RocksdbCompactFilter parameters take effect directly at the statebackend level [flink]

2024-08-28 Thread via GitHub
lincoln-lil commented on code in PR #25257: URL: https://github.com/apache/flink/pull/25257#discussion_r1734689530 ## flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/plan/nodes/exec/stream/StreamExecRank.java: ## @@ -232,6 +232,7 @@ protected Transfo

[PR] [FLINK-36018][autoscaler] Support lazy scale down to avoid frequent rescaling [flink-kubernetes-operator]

2024-08-28 Thread via GitHub
1996fanrui opened a new pull request, #875: URL: https://github.com/apache/flink-kubernetes-operator/pull/875 ## What is the purpose of the change When the source traffic decreases, the autoscaler scales down job in time to save resources. It causes that each job rescales more than 20

[jira] [Updated] (FLINK-36018) Support lazy scale down to avoid frequent rescaling

2024-08-28 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-36018: --- Labels: pull-request-available (was: ) > Support lazy scale down to avoid frequent rescalin

Re: [PR] [FLINK-36149][table] Make the RocksdbCompactFilter parameters take effect directly at the statebackend level [flink]

2024-08-28 Thread via GitHub
lincoln-lil commented on PR #25257: URL: https://github.com/apache/flink/pull/25257#issuecomment-2315355534 cc @Zakelly @masteryhx since you're the expert in this area, would one of you help the review if you have time? -- This is an automated message from the Apache Git Service. To respo

Re: [PR] [BP-3.2][hotfix][mysql] Fix primary key restraints missing when using inline `PRIMARY KEY` declaration syntax [flink-cdc]

2024-08-28 Thread via GitHub
leonardBang merged PR #3582: URL: https://github.com/apache/flink-cdc/pull/3582 -- 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] [minor][tests] Fix `testDanglingDroppingTableDuringBinlogMode` tests case due to imprecise timestamp startup [flink-cdc]

2024-08-28 Thread via GitHub
leonardBang merged PR #3580: URL: https://github.com/apache/flink-cdc/pull/3580 -- 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-22748] Allow dynamic target topic selection in SQL Kafka sinks [flink-connector-kafka]

2024-08-28 Thread via GitHub
klam-shop commented on PR #109: URL: https://github.com/apache/flink-connector-kafka/pull/109#issuecomment-2315389055 Thanks for your review @AHeise! I see CI is failing, I'll look into it. -- This is an automated message from the Apache Git Service. To respond to the message, please log

Re: [PR] [FLINK-35988][table]Reduce the number of state queries in the AppendOnlyFirstNFunction [flink]

2024-08-28 Thread via GitHub
lincoln-lil commented on PR #25159: URL: https://github.com/apache/flink/pull/25159#issuecomment-2315389136 @lexluo09 could you rebase the latest master to see if the ci can pass? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHu

[jira] [Updated] (FLINK-35988) Reduce the number of state queries in the AppendOnlyFirstNFunction.

2024-08-28 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-35988: Fix Version/s: 2.0.0 > Reduce the number of state queries in the AppendOnlyFirstNFunction. > -

[jira] [Assigned] (FLINK-35988) Reduce the number of state queries in the AppendOnlyFirstNFunction.

2024-08-28 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee reassigned FLINK-35988: --- Assignee: luolei > Reduce the number of state queries in the AppendOnlyFirstNFunction. > --

[jira] [Updated] (FLINK-35988) Reduce the number of state queries in the AppendOnlyFirstNFunction.

2024-08-28 Thread lincoln lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35988?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lincoln lee updated FLINK-35988: Issue Type: Improvement (was: New Feature) > Reduce the number of state queries in the AppendOnly

Re: [PR] [FLINK-35988][table]Reduce the number of state queries in the AppendOnlyFirstNFunction [flink]

2024-08-28 Thread via GitHub
lexluo09 commented on PR #25159: URL: https://github.com/apache/flink/pull/25159#issuecomment-2315410172 Thank you, I have already performed the rebase. > @lexluo09 could you rebase the latest master to see if the ci can pass? Thank you, I have already performed the rebase.

Re: [PR] [FLINK-36149][state] Make the RocksdbCompactFilter parameters take effect directly at the statebackend level [flink]

2024-08-28 Thread via GitHub
lexluo09 commented on PR #25257: URL: https://github.com/apache/flink/pull/25257#issuecomment-2315424500 > @lexluo09 thanks for contributing this! Since the scope of the pr changes, the module name in the commit msg should be updated as well(`table` -> `state`). Thank you for helping

Re: [PR] [FLINK-35988][table]Reduce the number of state queries in the AppendOnlyFirstNFunction [flink]

2024-08-28 Thread via GitHub
lexluo09 commented on PR #25159: URL: https://github.com/apache/flink/pull/25159#issuecomment-2315481455 @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 specif

Re: [PR] [FLINK-35177] Fix DataGen Connector documentation [flink]

2024-08-28 Thread via GitHub
GOODBOY008 commented on code in PR #25259: URL: https://github.com/apache/flink/pull/25259#discussion_r1734863739 ## flink-connectors/flink-connector-datagen/src/main/java/org/apache/flink/connector/datagen/source/DataGeneratorSource.java: ## @@ -73,17 +73,17 @@ * * This sou

Re: [PR] [FLINK-35177] Fix DataGen Connector documentation [flink]

2024-08-28 Thread via GitHub
GOODBOY008 commented on code in PR #25259: URL: https://github.com/apache/flink/pull/25259#discussion_r1734863739 ## flink-connectors/flink-connector-datagen/src/main/java/org/apache/flink/connector/datagen/source/DataGeneratorSource.java: ## @@ -73,17 +73,17 @@ * * This sou

Re: [PR] [FLINK-36117] Implement AsyncKeyedStateBackend for RocksDBKeyedStateBackend and HeapKeyedStateBackend [flink]

2024-08-28 Thread via GitHub
wqshr12345 commented on code in PR #25233: URL: https://github.com/apache/flink/pull/25233#discussion_r1734875852 ## flink-runtime/src/main/java/org/apache/flink/runtime/state/v2/adaptor/ValueStateWrapper.java: ## @@ -0,0 +1,83 @@ +/* + * Licensed to the Apache Software Foundati

Re: [PR] [FLINK-36117] Implement AsyncKeyedStateBackend for RocksDBKeyedStateBackend and HeapKeyedStateBackend [flink]

2024-08-28 Thread via GitHub
wqshr12345 commented on code in PR #25233: URL: https://github.com/apache/flink/pull/25233#discussion_r1734876123 ## flink-runtime/src/test/java/org/apache/flink/runtime/state/v2/AsyncKeyedStateBackendAdaptorTest.java: ## @@ -0,0 +1,188 @@ +/* + * Licensed to the Apache Software

Re: [PR] [FLINK-36117] Implement AsyncKeyedStateBackend for RocksDBKeyedStateBackend and HeapKeyedStateBackend [flink]

2024-08-28 Thread via GitHub
wqshr12345 commented on code in PR #25233: URL: https://github.com/apache/flink/pull/25233#discussion_r1734877680 ## flink-runtime/src/main/java/org/apache/flink/runtime/state/v2/StateDescriptorUtils.java: ## @@ -0,0 +1,50 @@ +/* + * Licensed to the Apache Software Foundation (A

Re: [PR] [FLINK-36117] Implement AsyncKeyedStateBackend for RocksDBKeyedStateBackend and HeapKeyedStateBackend [flink]

2024-08-28 Thread via GitHub
wqshr12345 commented on code in PR #25233: URL: https://github.com/apache/flink/pull/25233#discussion_r1734876074 ## flink-runtime/src/test/java/org/apache/flink/runtime/state/v2/AsyncKeyedStateBackendAdaptorTest.java: ## @@ -0,0 +1,188 @@ +/* + * Licensed to the Apache Software

Re: [PR] [FLINK-35177] Fix DataGen Connector documentation [flink]

2024-08-28 Thread via GitHub
morozov commented on code in PR #25259: URL: https://github.com/apache/flink/pull/25259#discussion_r1734938323 ## flink-connectors/flink-connector-datagen/src/main/java/org/apache/flink/connector/datagen/source/DataGeneratorSource.java: ## @@ -73,17 +73,17 @@ * * This source

Re: [PR] [FLINK-35177] Fix DataGen Connector documentation [flink]

2024-08-28 Thread via GitHub
morozov commented on code in PR #25259: URL: https://github.com/apache/flink/pull/25259#discussion_r1734938323 ## flink-connectors/flink-connector-datagen/src/main/java/org/apache/flink/connector/datagen/source/DataGeneratorSource.java: ## @@ -73,17 +73,17 @@ * * This source

Re: [PR] [FLINK-36086] Set isSnapshotCompleted only immediately after snapshot [flink-cdc]

2024-08-28 Thread via GitHub
morozov commented on PR #3552: URL: https://github.com/apache/flink-cdc/pull/3552#issuecomment-2315749782 @GOODBOY008 do you have an idea why the test introduced in https://github.com/apache/flink-cdc/pull/2176 passes even with the fix reverted? I'd like to make sure that I'm not breaking t

[jira] [Created] (FLINK-36169) Support namespace level resource check before scaling up

2024-08-28 Thread Zhenqiu Huang (Jira)
Zhenqiu Huang created FLINK-36169: - Summary: Support namespace level resource check before scaling up Key: FLINK-36169 URL: https://issues.apache.org/jira/browse/FLINK-36169 Project: Flink Is

[jira] [Assigned] (FLINK-36169) Support namespace level resource check before scaling up

2024-08-28 Thread Gyula Fora (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gyula Fora reassigned FLINK-36169: -- Assignee: Zhenqiu Huang > Support namespace level resource check before scaling up >

[jira] [Commented] (FLINK-36131) FlinkSQL upgraded from 1.13.1 to 1.18.1 metrics does not display data

2024-08-28 Thread Feng Jin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36131?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17877467#comment-17877467 ] Feng Jin commented on FLINK-36131: -- Version 3.0.2 looks fine, you can check again if th

Re: [PR] [WIP] [FLINK-XXXX] Generalized watermark wip [flink]

2024-08-28 Thread via GitHub
jeyhunkarimov commented on PR #24997: URL: https://github.com/apache/flink/pull/24997#issuecomment-2315863616 @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 comm

[PR] [FLINK-14068][streaming] Removes deprecated org.apache.flink.streaming.api.windowing.time.Time [flink]

2024-08-28 Thread via GitHub
XComp opened a new pull request, #25261: URL: https://github.com/apache/flink/pull/25261 ## What is the purpose of the change Removes deprecated `org.apache.flink.streaming.api.windowing.time.Time` ## Brief change log The changes where done using the IDE refactoring and f

Re: [PR] [FLINK-14068][streaming] Removes deprecated org.apache.flink.streaming.api.windowing.time.Time [flink]

2024-08-28 Thread via GitHub
flinkbot commented on PR #25261: URL: https://github.com/apache/flink/pull/25261#issuecomment-2316011088 ## CI report: * e8fe75ea19d3de0a9ada8da66c38b2bd4343d0cd UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Created] (FLINK-36170) Bump assertj-core version

2024-08-28 Thread Siddharth R (Jira)
Siddharth R created FLINK-36170: --- Summary: Bump assertj-core version Key: FLINK-36170 URL: https://issues.apache.org/jira/browse/FLINK-36170 Project: Flink Issue Type: Improvement Com

[PR] [FLINK-36170] bump assert4j version [flink-kubernetes-operator]

2024-08-28 Thread via GitHub
r-sidd opened a new pull request, #876: URL: https://github.com/apache/flink-kubernetes-operator/pull/876 Bump the **assertj-core** version to remediate vulnerabilities on the dependant packages. Package info: https://mvnrepository.com/artifact/org.assertj/assertj-core/3.26.3

[jira] [Updated] (FLINK-36170) Bump assertj-core version

2024-08-28 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-36170: --- Labels: pull-request-available (was: ) > Bump assertj-core version > --

Re: [PR] [FLINK-27758][tests][table] Migrate flink-table-runtime to JUnit5 [flink]

2024-08-28 Thread via GitHub
snuyanzin commented on PR #19811: URL: https://github.com/apache/flink/pull/19811#issuecomment-2316095327 @Jiabao-Sun since you are one of those who is active in junit4-junit5 migration may I ask you to have a look here? -- This is an automated message from the Apache Git Service. To r

[PR] [FLINK-36009] Architecture tests refactor and fixes [flink-connector-jdbc]

2024-08-28 Thread via GitHub
eskabetxe opened a new pull request, #140: URL: https://github.com/apache/flink-connector-jdbc/pull/140 - Created the module flink-connector-jdbc-architecture to have all tests, we need to add the modules as dependency to validate that module.. - Created the package "org.apache.flink.conn

[jira] [Updated] (FLINK-36009) Change configs to use CondigOptions

2024-08-28 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36009?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-36009: --- Labels: pull-request-available (was: ) > Change configs to use CondigOptions >

Re: [PR] [WIP] [FLINK-XXXX] Generalized watermark wip [flink]

2024-08-28 Thread via GitHub
jeyhunkarimov commented on PR #24997: URL: https://github.com/apache/flink/pull/24997#issuecomment-2316377718 @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 comm

[jira] [Created] (FLINK-36171) Remove APIs about ManagedTable

2024-08-28 Thread xuyang (Jira)
xuyang created FLINK-36171: -- Summary: Remove APIs about ManagedTable Key: FLINK-36171 URL: https://issues.apache.org/jira/browse/FLINK-36171 Project: Flink Issue Type: Technical Debt Compo

[jira] [Commented] (FLINK-36171) Remove APIs about ManagedTable

2024-08-28 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17877562#comment-17877562 ] xuyang commented on FLINK-36171: Hi, [~qingyue] . I noticed that you were involved in th

Re: [PR] [FLINK-36117] Implement AsyncKeyedStateBackend for RocksDBKeyedStateBackend and HeapKeyedStateBackend [flink]

2024-08-28 Thread via GitHub
wqshr12345 commented on code in PR #25233: URL: https://github.com/apache/flink/pull/25233#discussion_r1735476915 ## flink-runtime/src/main/java/org/apache/flink/runtime/state/v2/adaptor/AsyncKeyedStateBackendAdaptor.java: ## @@ -0,0 +1,83 @@ +/* + * Licensed to the Apache Softw

Re: [PR] [FLINK-36117] Implement AsyncKeyedStateBackend for RocksDBKeyedStateBackend and HeapKeyedStateBackend [flink]

2024-08-28 Thread via GitHub
wqshr12345 commented on code in PR #25233: URL: https://github.com/apache/flink/pull/25233#discussion_r1735477237 ## flink-runtime/src/test/java/org/apache/flink/runtime/state/v2/AsyncKeyedStateBackendAdaptorTest.java: ## @@ -0,0 +1,188 @@ +/* + * Licensed to the Apache Software

[jira] [Updated] (FLINK-35177) Datagen examples in documentation do not compile

2024-08-28 Thread Zhongqiang Gong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhongqiang Gong updated FLINK-35177: Fix Version/s: 1.20.0 > Datagen examples in documentation do not compile > ---

Re: [PR] [FLINK-35177] Fix DataGen Connector documentation [flink]

2024-08-28 Thread via GitHub
GOODBOY008 merged PR #25259: URL: https://github.com/apache/flink/pull/25259 -- 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.ap

[jira] [Commented] (FLINK-35177) Datagen examples in documentation do not compile

2024-08-28 Thread Zhongqiang Gong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35177?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17877564#comment-17877564 ] Zhongqiang Gong commented on FLINK-35177: - Merged to branch : release-1.20 , via

Re: [PR] [FLINK-27758][tests][table] Migrate flink-table-runtime to JUnit5 [flink]

2024-08-28 Thread via GitHub
Jiabao-Sun commented on code in PR #19811: URL: https://github.com/apache/flink/pull/19811#discussion_r1735459879 ## flink-table/flink-table-runtime/src/test/java/org/apache/flink/table/runtime/hashtable/BinaryHashTableTest.java: ## @@ -56,7 +57,7 @@ import static org.assertj.c

Re: [PR] [FLINK-35988][table]Reduce the number of state queries in the AppendOnlyFirstNFunction [flink]

2024-08-28 Thread via GitHub
lincoln-lil commented on PR #25159: URL: https://github.com/apache/flink/pull/25159#issuecomment-2316602157 @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 commen

Re: [PR] [FLINK-35936][cdc-connector][paimon] Fix paimon cdc schema evolution failure when restart job [flink-cdc]

2024-08-28 Thread via GitHub
MOBIN-F commented on code in PR #3502: URL: https://github.com/apache/flink-cdc/pull/3502#discussion_r1735512726 ## flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-paimon/src/test/java/org/apache/flink/cdc/connectors/paimon/sink/PaimonMetadataApplierTest.jav

Re: [PR] [FLINK-35579] update frocksdb version to v8.10.0 [flink]

2024-08-28 Thread via GitHub
mayuehappy commented on code in PR #25253: URL: https://github.com/apache/flink/pull/25253#discussion_r1735514453 ## flink-end-to-end-tests/test-scripts/common.sh: ## @@ -296,7 +296,7 @@ function relocate_rocksdb_logs { # After FLINK-24785, RocksDB's log would be created unde

Re: [PR] [FLINK-35579] update frocksdb version to v8.10.0 [flink]

2024-08-28 Thread via GitHub
Zakelly merged PR #25253: URL: https://github.com/apache/flink/pull/25253 -- 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-35579) Update the FrocksDB version in FLINK

2024-08-28 Thread Zakelly Lan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17877567#comment-17877567 ] Zakelly Lan commented on FLINK-35579: - Merged into master via 576ec2b9361a3f8d58fb22

[jira] [Resolved] (FLINK-35579) Update the FrocksDB version in FLINK

2024-08-28 Thread Zakelly Lan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan resolved FLINK-35579. - Assignee: Yue Ma Resolution: Fixed > Update the FrocksDB version in FLINK > --

[jira] [Commented] (FLINK-35579) Update the FrocksDB version in FLINK

2024-08-28 Thread Zakelly Lan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-35579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17877568#comment-17877568 ] Zakelly Lan commented on FLINK-35579: - Bump FrocksDB version to 8.10.0-ververica-bet

Re: [PR] [FLINK-36149][state] Make the RocksdbCompactFilter parameters take effect directly at the statebackend level [flink]

2024-08-28 Thread via GitHub
Zakelly commented on code in PR #25257: URL: https://github.com/apache/flink/pull/25257#discussion_r1735521732 ## flink-state-backends/flink-statebackend-rocksdb/src/main/java/org/apache/flink/contrib/streaming/state/ttl/RocksDbTtlCompactFiltersManager.java: ## @@ -125,11 +144,2

  1   2   >