[jira] [Commented] (FLINK-36389) Fix DelegationTokenReceiverRepository to check if Delegation Token is enabled

2024-09-26 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36389?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17885232#comment-17885232 ] Luke Chen commented on FLINK-36389: --- I think we did check if delegation tokens is enab

[jira] [Updated] (FLINK-36395) Graceful quit for Forst StateBackend

2024-09-26 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36395?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-36395: --- Labels: pull-request-available (was: ) > Graceful quit for Forst StateBackend > ---

[PR] [FLINK-36395][state/forst] Graceful quit for Forst StateBackend [flink]

2024-09-26 Thread via GitHub
Zakelly opened a new pull request, #25416: URL: https://github.com/apache/flink/pull/25416 ## What is the purpose of the change There are many threads in forst statebackends. This PR makes them quit gracefully when task stop. ## Brief change log - Change the order o

[jira] [Resolved] (FLINK-36390) Remove deprecate RichFunction#open(Configuration)

2024-09-26 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo resolved FLINK-36390. Fix Version/s: 2.0-preview Resolution: Done master(2.0) via 6a290caf82a49639a60f2f31082e021

Re: [PR] [FLINK-36390][core] Remove deprecated open(Configuration) method in RichFunction [flink]

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

[jira] [Updated] (FLINK-36344) Introduce lastCheckpointCompletedTimestamp metrics

2024-09-26 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-36344: - Summary: Introduce lastCheckpointCompletedTimestamp metrics (was: Introduce lastCompletedCheckpointTime

[jira] [Updated] (FLINK-36344) Introduce lastCheckpointCompletedTimestamp metrics

2024-09-26 Thread Yun Tang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yun Tang updated FLINK-36344: - Description: Currently, we cannot know how long no new checkpoint ever completed based on the existing m

Re: [PR] [FLINK-36362][table] Remove dependency `flink-java` in table modules [flink]

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

Re: [PR] [FLINK-36323][StateBackend] Remove deprecated MemoryStateBackend, FsStateBackend and RocksDBStateBackend [flink]

2024-09-26 Thread via GitHub
xing1mo commented on PR #25409: URL: https://github.com/apache/flink/pull/25409#issuecomment-2378487339 @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-36394) Configure Init Metaspace size by default

2024-09-26 Thread JieTan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JieTan updated FLINK-36394: --- Description: We should set the size of the Init JVM Metaspace to a sane default, like {{{}-XX:MetaspaceSize

[jira] [Updated] (FLINK-36362) Remove dependency `flink-java` in table module

2024-09-26 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36362?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-36362: --- Labels: pull-request-available (was: ) > Remove dependency `flink-java` in table module > -

[PR] [FLINK-36362][table] Remove dependency `flink-java` in table modules [flink]

2024-09-26 Thread via GitHub
xuyangzhong opened a new pull request, #25415: URL: https://github.com/apache/flink/pull/25415 ## What is the purpose of the change Remove all class dependencies from `flink-java` in table modules. Note: I have ensured that all table modules does not depend on the `flink-java`

[jira] [Commented] (FLINK-36362) Remove dependency `flink-java` in table module

2024-09-26 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17885219#comment-17885219 ] xuyang commented on FLINK-36362: Checked way: `mvn dependency:tree -Dincludes=org.apache

[jira] [Commented] (FLINK-33634) Add Conditions to Flink CRD's Status field

2024-09-26 Thread lajith (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17885217#comment-17885217 ] lajith commented on FLINK-33634: [~ryanvanhuuksloot] . Thanks for the comments.  Regard

[jira] [Commented] (FLINK-36362) Remove dependency `flink-java` in table module

2024-09-26 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17885216#comment-17885216 ] xuyang commented on FLINK-36362: We need to ensure that all table modules does not depen

[jira] [Created] (FLINK-36396) Remove dependency flink-java in all flink-table-api-xxx module

2024-09-26 Thread xuyang (Jira)
xuyang created FLINK-36396: -- Summary: Remove dependency flink-java in all flink-table-api-xxx module Key: FLINK-36396 URL: https://issues.apache.org/jira/browse/FLINK-36396 Project: Flink Issue Typ

[jira] [Updated] (FLINK-36385) Remove dependency flink-java in flink-sql-gateway and flink-sql-gateway-api module

2024-09-26 Thread xuyang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36385?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xuyang updated FLINK-36385: --- Summary: Remove dependency flink-java in flink-sql-gateway and flink-sql-gateway-api module (was: Remove de

Re: [PR] FLINK-36332 Add option to select the Fabric8 httpclient implemention [flink-kubernetes-operator]

2024-09-26 Thread via GitHub
SamBarker commented on PR #881: URL: https://github.com/apache/flink-kubernetes-operator/pull/881#issuecomment-2378413829 > I think the e2e workflow is now correctly setup (and has passed on [my fork](https://github.com/SamBarker/flink-kubernetes-operator/actions/runs/11061322378/job/307354

Re: [PR] [FLINK-34738][cdc][docs-zh] "Deployment - YARN" Page for Flink CDC Chinese Documentation [flink-cdc]

2024-09-26 Thread via GitHub
Vincent-Woo commented on PR #3205: URL: https://github.com/apache/flink-cdc/pull/3205#issuecomment-2378400832 > @Vincent-Woo Thanks for your contributions. I left some comments. @GOODBOY008 Thanks for the guidance, I made some changes, PTAL -- This is an automated message from the A

[jira] [Created] (FLINK-36395) Graceful quit for Forst StateBackend

2024-09-26 Thread Zakelly Lan (Jira)
Zakelly Lan created FLINK-36395: --- Summary: Graceful quit for Forst StateBackend Key: FLINK-36395 URL: https://issues.apache.org/jira/browse/FLINK-36395 Project: Flink Issue Type: Sub-task

Re: [PR] FLINK-36332 Add option to select the Fabric8 httpclient implemention [flink-kubernetes-operator]

2024-09-26 Thread via GitHub
SamBarker commented on PR #881: URL: https://github.com/apache/flink-kubernetes-operator/pull/881#issuecomment-2378387438 I should note I'm not convinced the workflow is doing what its expected to do I've documented my findings as [FLINK-36392](https://issues.apache.org/jira/browse/FLINK-3

Re: [PR] FLINK-36332 Add option to select the Fabric8 httpclient implemention [flink-kubernetes-operator]

2024-09-26 Thread via GitHub
SamBarker commented on PR #881: URL: https://github.com/apache/flink-kubernetes-operator/pull/881#issuecomment-2378385726 I think the e2e workflow is now correctly setup (and has passed on [my fork](https://github.com/SamBarker/flink-kubernetes-operator/actions/runs/11061322378/job/30735483

[jira] [Commented] (FLINK-33634) Add Conditions to Flink CRD's Status field

2024-09-26 Thread Ryan van Huuksloot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17885191#comment-17885191 ] Ryan van Huuksloot commented on FLINK-33634: I can't easily respond to the m

Re: [PR] [FLINK-36181][build] Bump CI Java version to 11 [flink]

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

Re: [PR] [FLINK-36066][runtime] Introducing the AdaptiveGraphManager component [flink]

2024-09-26 Thread via GitHub
flinkbot commented on PR #25414: URL: https://github.com/apache/flink/pull/25414#issuecomment-2378356562 ## CI report: * 783cb8a16e366c22206ac1fd1e9e5d5a9f2b2d84 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[jira] [Updated] (FLINK-36394) Configure Init Metaspace size by default

2024-09-26 Thread JieTan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JieTan updated FLINK-36394: --- Fix Version/s: 1.17.0 1.16.0 > Configure Init Metaspace size by default > ---

[jira] [Updated] (FLINK-36394) Configure Init Metaspace size by default

2024-09-26 Thread JieTan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JieTan updated FLINK-36394: --- Attachment: (was: image.png) > Configure Init Metaspace size by default > --

Re: [PR] [FLINK-36066][runtime] Introducing the AdaptiveGraphManager component [flink]

2024-09-26 Thread via GitHub
noorall commented on PR #25414: URL: https://github.com/apache/flink/pull/25414#issuecomment-2378346728 @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-36066) Introducing the AdaptiveGraphGenerator component

2024-09-26 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-36066: --- Labels: pull-request-available (was: ) > Introducing the AdaptiveGraphGenerator component >

[PR] [FLINK-36066][runtime] Introducing the AdaptiveGraphManager component [flink]

2024-09-26 Thread via GitHub
noorall opened a new pull request, #25414: URL: https://github.com/apache/flink/pull/25414 ## What is the purpose of the change To support the incremental generation of JobGraph and update the StreamGraph based on runtime information, we plan to introduce the AdaptiveGraphManager com

Re: [PR] [FLINK-36323][StateBackend] Remove deprecated MemoryStateBackend, FsStateBackend and RocksDBStateBackend [flink]

2024-09-26 Thread via GitHub
xing1mo commented on PR #25409: URL: https://github.com/apache/flink/pull/25409#issuecomment-2378344358 @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-36323][StateBackend] Remove deprecated MemoryStateBackend, FsStateBackend and RocksDBStateBackend [flink]

2024-09-26 Thread via GitHub
Zakelly commented on code in PR #25409: URL: https://github.com/apache/flink/pull/25409#discussion_r1777959585 ## flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/operator/CEPOperatorTest.java: ## @@ -444,7 +447,7 @@ public void testKeyedCEPOperatorNFAUpdateWithRocks

Re: [PR] [FLINK-34975] Implement Aggregating Async State API for ForStStateBackend [flink]

2024-09-26 Thread via GitHub
jectpro7 commented on code in PR #25125: URL: https://github.com/apache/flink/pull/25125#discussion_r1777919463 ## flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStStateRequestClassifier.java: ## @@ -99,6 +99,20 @@ private void conve

[jira] [Updated] (FLINK-36394) Configure Init Metaspace size by default

2024-09-26 Thread JieTan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JieTan updated FLINK-36394: --- Description: We should set the size of the Init JVM Metaspace to a sane default, like {{{}-XX:MetaspaceSize

[jira] [Updated] (FLINK-36394) Configure Init Metaspace size by default

2024-09-26 Thread JieTan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JieTan updated FLINK-36394: --- Description: We should set the size of the Init JVM Metaspace to a sane default, like {{{}-XX:MetaspaceSize

[jira] [Updated] (FLINK-36394) Configure Init Metaspace size by default

2024-09-26 Thread JieTan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JieTan updated FLINK-36394: --- Attachment: JVMMetaspace.png JobManagerJVMOptions.png TaskManagerJVMOptions.p

[jira] [Updated] (FLINK-36394) Configure Init Metaspace size by default

2024-09-26 Thread JieTan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JieTan updated FLINK-36394: --- Attachment: (was: TaskManagerJVMOptions.png) > Configure Init Metaspace size by default > --

[jira] [Updated] (FLINK-36394) Configure Init Metaspace size by default

2024-09-26 Thread JieTan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JieTan updated FLINK-36394: --- Attachment: JobManagerJVMOptions.png > Configure Init Metaspace size by default > --

[jira] [Updated] (FLINK-36394) Configure Init Metaspace size by default

2024-09-26 Thread JieTan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JieTan updated FLINK-36394: --- Attachment: (was: JobManagerJVMOptions.png) > Configure Init Metaspace size by default > ---

[jira] [Updated] (FLINK-36394) Configure Init Metaspace size by default

2024-09-26 Thread JieTan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36394?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] JieTan updated FLINK-36394: --- Attachment: TaskManagerJVMOptions.png > Configure Init Metaspace size by default > -

[jira] [Closed] (FLINK-36307) Remove deprecated PyFlink config options

2024-09-26 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-36307. --- Resolution: Fixed Merged to master via fc3ace9bd652a8035c3a3d5a1b2cd580f4566a57 > Remove deprecated PyFlink

[jira] [Commented] (FLINK-36377) Support the use of the LAST_VALUE aggregate function on ROW type data

2024-09-26 Thread Feng Jin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36377?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17885203#comment-17885203 ] Feng Jin commented on FLINK-36377: -- I believe that adding support for the last_value ag

[jira] [Resolved] (FLINK-3992) Remove Key interface

2024-09-26 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-3992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo resolved FLINK-3992. --- Resolution: Done > Remove Key interface > > > Key: FLINK-3992 >

[jira] [Created] (FLINK-36394) Configure Init Metaspace size by default

2024-09-26 Thread JieTan (Jira)
JieTan created FLINK-36394: -- Summary: Configure Init Metaspace size by default Key: FLINK-36394 URL: https://issues.apache.org/jira/browse/FLINK-36394 Project: Flink Issue Type: Bug Compon

[jira] [Closed] (FLINK-36311) Remove deprecated flink-formats config options

2024-09-26 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-36311. --- > Remove deprecated flink-formats config options > -- > >

[jira] [Reopened] (FLINK-36347) Using the offset obtained after a query transaction as a high watermark cannot ensure exactly-once semantics.

2024-09-26 Thread Zhongmin Qiao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhongmin Qiao reopened FLINK-36347: --- > Using the offset obtained after a query transaction as a high watermark > cannot ensure exact

[jira] [Closed] (FLINK-36308) Remove deprecated CEP config options

2024-09-26 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-36308. --- > Remove deprecated CEP config options > > > Key: FLINK-363

[jira] [Updated] (FLINK-36377) Support the use of the LAST_VALUE aggregate function on ROW type data

2024-09-26 Thread Yang Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Li updated FLINK-36377: Description: h2. Introduction In Flink, after applying a group by, users may use LAST_VALUE to process c

Re: [PR] [FLINK-36307][python] Remove deprecated API in PyFlink module [flink]

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

[jira] [Updated] (FLINK-36377) Support the use of the LAST_VALUE aggregate function on ROW type data

2024-09-26 Thread Yang Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yang Li updated FLINK-36377: Description: h2. Introduction In Flink, after applying a group by, users may use LAST_VALUE to process c

[jira] [Commented] (FLINK-36355) Remove deprecate API in flink-runtime exclude connector and state part

2024-09-26 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36355?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17885194#comment-17885194 ] Weijie Guo commented on FLINK-36355: Remove deprecated xxxStreams#with: be4549de7e6c

Re: [PR] [FLINK-34975] Implement Aggregating Async State API for ForStStateBackend [flink]

2024-09-26 Thread via GitHub
fredia commented on code in PR #25125: URL: https://github.com/apache/flink/pull/25125#discussion_r1777943929 ## flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStStateRequestClassifier.java: ## @@ -111,6 +125,11 @@ private void conve

[jira] [Created] (FLINK-36393) Flink Operator uses out of date GitHub actions.

2024-09-26 Thread Sam Barker (Jira)
Sam Barker created FLINK-36393: -- Summary: Flink Operator uses out of date GitHub actions. Key: FLINK-36393 URL: https://issues.apache.org/jira/browse/FLINK-36393 Project: Flink Issue Type: Impro

Re: [PR] [FLINK-34975] Implement Aggregating Async State API for ForStStateBackend [flink]

2024-09-26 Thread via GitHub
fredia commented on code in PR #25125: URL: https://github.com/apache/flink/pull/25125#discussion_r1777942760 ## flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStAggregatingState.java: ## @@ -0,0 +1,157 @@ +/* + * Licensed to the Apac

[jira] [Commented] (FLINK-30614) Improve resolving schema compatibility -- Milestone two

2024-09-26 Thread Zakelly Lan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17885199#comment-17885199 ] Zakelly Lan commented on FLINK-30614: - Sorry [~zxcoccer], we're on a pretty tight sc

[jira] [Resolved] (FLINK-30614) Improve resolving schema compatibility -- Milestone two

2024-09-26 Thread Zakelly Lan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan resolved FLINK-30614. - Fix Version/s: 2.0-preview Resolution: Fixed > Improve resolving schema compatibility --

[jira] [Commented] (FLINK-30614) Improve resolving schema compatibility -- Milestone two

2024-09-26 Thread Zakelly Lan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30614?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17885200#comment-17885200 ] Zakelly Lan commented on FLINK-30614: - Merge 6a76eee ... be90707 into master > Impr

[jira] [Assigned] (FLINK-30614) Improve resolving schema compatibility -- Milestone two

2024-09-26 Thread Zakelly Lan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zakelly Lan reassigned FLINK-30614: --- Assignee: Han Yin > Improve resolving schema compatibility -- Milestone two > -

[jira] [Created] (FLINK-36392) Varying the Java version in the Operator CI has no effect

2024-09-26 Thread Sam Barker (Jira)
Sam Barker created FLINK-36392: -- Summary: Varying the Java version in the Operator CI has no effect Key: FLINK-36392 URL: https://issues.apache.org/jira/browse/FLINK-36392 Project: Flink Issue T

Re: [PR] [FLINK-30614][serializer] Remove old method of resolving schema compa… [flink]

2024-09-26 Thread via GitHub
Zakelly merged PR #25384: URL: https://github.com/apache/flink/pull/25384 -- 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] [Created] (FLINK-36391) Remove dependency flink-java in flink-table-runtime module

2024-09-26 Thread xuyang (Jira)
xuyang created FLINK-36391: -- Summary: Remove dependency flink-java in flink-table-runtime module Key: FLINK-36391 URL: https://issues.apache.org/jira/browse/FLINK-36391 Project: Flink Issue Type: Su

[jira] [Created] (FLINK-36390) Remove deprecate RichFunction#open(Configuration)

2024-09-26 Thread Weijie Guo (Jira)
Weijie Guo created FLINK-36390: -- Summary: Remove deprecate RichFunction#open(Configuration) Key: FLINK-36390 URL: https://issues.apache.org/jira/browse/FLINK-36390 Project: Flink Issue Type: Sub

Re: [PR] [FLINK-36390][core] Remove deprecated open(Configuration) method in RichFunction [flink]

2024-09-26 Thread via GitHub
reswqa commented on PR #25383: URL: https://github.com/apache/flink/pull/25383#issuecomment-2378283788 Thanks for the reveiw. >I have a small question: Why are the OpenContext interfaces empty, while the DefaultOpenContext and WithConfigurationOpenContext are quite simple? Could thes

[jira] [Updated] (FLINK-36390) Remove deprecate RichFunction#open(Configuration)

2024-09-26 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-36390: --- Labels: pull-request-available (was: ) > Remove deprecate RichFunction#open(Configuration)

[PR] [FLINK-36181][build] Bump CI Java version to 11 [flink]

2024-09-26 Thread via GitHub
Sxnan opened a new pull request, #25413: URL: https://github.com/apache/flink/pull/25413 ## 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-transferring them on e

Re: [PR] [FLINK-36355][runtime] Remove deprecated xxxStreams#with [flink]

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

[jira] [Comment Edited] (FLINK-3992) Remove Key interface

2024-09-26 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-3992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17885193#comment-17885193 ] Weijie Guo edited comment on FLINK-3992 at 9/27/24 2:11 AM: m

[jira] [Commented] (FLINK-3992) Remove Key interface

2024-09-26 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-3992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17885193#comment-17885193 ] Weijie Guo commented on FLINK-3992: --- master(2.0) via 21092bf229d0acdbac47a7d4d83cc5327b

Re: [PR] [FLINK-34975] Implement Aggregating Async State API for ForStStateBackend [flink]

2024-09-26 Thread via GitHub
jectpro7 commented on code in PR #25125: URL: https://github.com/apache/flink/pull/25125#discussion_r1777919760 ## flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStStateRequestClassifier.java: ## @@ -111,6 +125,11 @@ private void con

Re: [PR] [FLINK-3992][core] Do not implement deprecated Key interface [flink]

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

Re: [PR] [FLINK-34975] Implement Aggregating Async State API for ForStStateBackend [flink]

2024-09-26 Thread via GitHub
jectpro7 commented on code in PR #25125: URL: https://github.com/apache/flink/pull/25125#discussion_r1777920043 ## flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStAggregatingState.java: ## @@ -0,0 +1,157 @@ +/* + * Licensed to the Ap

Re: [PR] [FLINK-34975] Implement Aggregating Async State API for ForStStateBackend [flink]

2024-09-26 Thread via GitHub
jectpro7 commented on code in PR #25125: URL: https://github.com/apache/flink/pull/25125#discussion_r1777919385 ## flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStAggregatingState.java: ## @@ -0,0 +1,157 @@ +/* + * Licensed to the Ap

Re: [PR] [FLINK-34975] Implement Aggregating Async State API for ForStStateBackend [flink]

2024-09-26 Thread via GitHub
jectpro7 commented on code in PR #25125: URL: https://github.com/apache/flink/pull/25125#discussion_r1777917786 ## flink-runtime/src/test/java/org/apache/flink/runtime/state/v2/AbstractAggregatingStateTest.java: ## @@ -67,6 +67,12 @@ public Integer merge(Integer a, Integer b) {

[jira] [Commented] (FLINK-36378) type extraction problem between java BigDecimal and sql decimal

2024-09-26 Thread Jacky Lau (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36378?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17885189#comment-17885189 ] Jacky Lau commented on FLINK-36378: --- hi [~twalthr] , will you have time to have a look

Re: [PR] Add check in DelegationTokenReceiverRepository for DT enabled flag [flink]

2024-09-26 Thread via GitHub
flinkbot commented on PR #25412: URL: https://github.com/apache/flink/pull/25412#issuecomment-2378198394 ## CI report: * 3d8e14be7e7a1a624409c526328b0fbc3fe6b0e2 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] Add check in DelegationTokenReceiverRepository for DT enabled flag [flink]

2024-09-26 Thread via GitHub
venkata91 commented on code in PR #25412: URL: https://github.com/apache/flink/pull/25412#discussion_r1777885761 ## flink-runtime/src/test/java/org/apache/flink/runtime/security/token/DelegationTokenReceiverRepositoryTest.java: ## @@ -73,4 +73,18 @@ public void testAllReceiversL

Re: [PR] Add check in DelegationTokenReceiverRepository for DT enabled flag [flink]

2024-09-26 Thread via GitHub
venkata91 commented on PR #25412: URL: https://github.com/apache/flink/pull/25412#issuecomment-2378192099 cc @gaborgsomogyi -- 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.

[PR] Add check in DelegationTokenReceiverRepository for DT enabled flag [flink]

2024-09-26 Thread via GitHub
argoyal2212 opened a new pull request, #25412: URL: https://github.com/apache/flink/pull/25412 ## What is the purpose of the change This PR fixes an issue where the `DelegationTokenReceiverRepository` does not check the `DELEGATION_TOKENS_ENABLED` flag before initializing delegati

[jira] [Updated] (FLINK-36389) Fix DelegationTokenReceiverRepository to check if Delegation Token is enabled

2024-09-26 Thread Archit Goyal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Archit Goyal updated FLINK-36389: - Component/s: Deployment / Kubernetes Deployment / YARN > Fix DelegationTokenRec

[jira] [Updated] (FLINK-36389) Fix DelegationTokenReceiverRepository to check if Delegation Token is enabled

2024-09-26 Thread Archit Goyal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Archit Goyal updated FLINK-36389: - Description: {*}Issue{*}: During the initialization of the  {{DelegationTokenReceiverRepository}

[jira] [Updated] (FLINK-36389) Fix DelegationTokenReceiverRepository to check if Delegation Token is enabled

2024-09-26 Thread Archit Goyal (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36389?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Archit Goyal updated FLINK-36389: - Labels: security (was: ) > Fix DelegationTokenReceiverRepository to check if Delegation Token i

[jira] [Created] (FLINK-36389) Fix DelegationTokenReceiverRepository to check if Delegation Token is enabled

2024-09-26 Thread Archit Goyal (Jira)
Archit Goyal created FLINK-36389: Summary: Fix DelegationTokenReceiverRepository to check if Delegation Token is enabled Key: FLINK-36389 URL: https://issues.apache.org/jira/browse/FLINK-36389 Project

[jira] [Updated] (FLINK-36388) Truncate failure labels on web interface

2024-09-26 Thread Panagiotis Garefalakis (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Panagiotis Garefalakis updated FLINK-36388: --- Component/s: Runtime / Web Frontend > Truncate failure labels on web interfa

[jira] [Created] (FLINK-36388) Truncate failure labels on web interface

2024-09-26 Thread Panagiotis Garefalakis (Jira)
Panagiotis Garefalakis created FLINK-36388: -- Summary: Truncate failure labels on web interface Key: FLINK-36388 URL: https://issues.apache.org/jira/browse/FLINK-36388 Project: Flink

[jira] [Resolved] (FLINK-36292) SplitFetcherManagerTest.testCloseCleansUpPreviouslyClosedFetcher times out

2024-09-26 Thread Jiangjie Qin (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin resolved FLINK-36292. -- Resolution: Fixed Merged to master. cc0a8b3f69b8036534a5f0132bbe8f470d945ca0 > SplitFetcherM

Re: [PR] [FLINK-33045][format avro-confluent] disable auto-registering schema in registry [flink]

2024-09-26 Thread via GitHub
flinkbot commented on PR #25410: URL: https://github.com/apache/flink/pull/25410#issuecomment-2377373898 ## CI report: * 5c768a1322bba307da0a31711718c5148dcf4612 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [FLINK-36292][Connectors/Common]: remove timeout to avoid timeout exception [flink]

2024-09-26 Thread via GitHub
becketqin merged PR #25371: URL: https://github.com/apache/flink/pull/25371 -- 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] [DRAFT][FLINK-36336] Remove deprecated dataset API dependency exclude table module [flink]

2024-09-26 Thread via GitHub
codenohup commented on PR #25365: URL: https://github.com/apache/flink/pull/25365#issuecomment-2377628249 @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] [DRAFT][FLINK-36336] Remove deprecated dataset API dependency exclude table module [flink]

2024-09-26 Thread via GitHub
codenohup commented on PR #25365: URL: https://github.com/apache/flink/pull/25365#issuecomment-2377594057 @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-36325][statebackend] Implement basic restore from checkpoint for ForStStateBackend [flink]

2024-09-26 Thread via GitHub
Zakelly commented on code in PR #25397: URL: https://github.com/apache/flink/pull/25397#discussion_r1777423164 ## flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/restore/ForStIncrementalRestoreOperation.java: ## @@ -0,0 +1,393 @@ +/* + *

Re: [PR] [FLINK-36323][StateBackend] Remove deprecated MemoryStateBackend, FsStateBackend and RocksDBStateBackend [flink]

2024-09-26 Thread via GitHub
flinkbot commented on PR #25409: URL: https://github.com/apache/flink/pull/25409#issuecomment-2377325507 ## CI report: * 7dcdb8d2eae5fc9bbf4a84e86fddcf2086f7 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

Re: [PR] [DRAFT][FLINK-36336] Remove deprecated dataset API dependency exclude table module [flink]

2024-09-26 Thread via GitHub
codenohup commented on PR #25365: URL: https://github.com/apache/flink/pull/25365#issuecomment-2377454150 @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] Detect base href dynamically [flink]

2024-09-26 Thread via GitHub
flinkbot commented on PR #25411: URL: https://github.com/apache/flink/pull/25411#issuecomment-2377398499 ## CI report: * 24851cffc7e7574f14eba66e56665f2373a82dac UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run azure`

[PR] Detect base href dynamically [flink]

2024-09-26 Thread via GitHub
abhijitWakchaure opened a new pull request, #25411: URL: https://github.com/apache/flink/pull/25411 ## What is the purpose of the change This pull request makes flink-runtime-web project detect the base href dynamically so that it can work with paths like http://foo.bar/my-flink-dash

[jira] [Updated] (FLINK-33045) format avro-confluent - disable auto-registering schema in registry

2024-09-26 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-33045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-33045: --- Labels: pull-request-available (was: ) > format avro-confluent - disable auto-registering s

[PR] [FLINK-33045][format avro-confluent] disable auto-registering schema in registry [flink]

2024-09-26 Thread via GitHub
parisni opened a new pull request, #25410: URL: https://github.com/apache/flink/pull/25410 ## 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-transferring them on

[jira] [Created] (FLINK-36387) Remove dependency flink-java in flink-table-planner module

2024-09-26 Thread xuyang (Jira)
xuyang created FLINK-36387: -- Summary: Remove dependency flink-java in flink-table-planner module Key: FLINK-36387 URL: https://issues.apache.org/jira/browse/FLINK-36387 Project: Flink Issue Type: Su

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

2024-09-26 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36166?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo reassigned FLINK-36166: -- Assignee: xuyang > testJoinDisorderChangeLog failed on AZP >

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

2024-09-26 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-36166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17885031#comment-17885031 ] Weijie Guo commented on FLINK-36166: [~xuyangzhong] Sure, thanks for the help. > te

[jira] [Resolved] (FLINK-29741) [FLIP-265] Remove all Scala APIs

2024-09-26 Thread Weijie Guo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-29741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Weijie Guo resolved FLINK-29741. Resolution: Done master(2.0) via a27070a1059f8014151f7bd174f729abb419feb4. > [FLIP-265] Remove al

  1   2   >