Zakelly opened a new pull request, #25918:
URL: https://github.com/apache/flink/pull/25918
## What is the purpose of the change
This PR enables the lazy-initialization for state serializer in state v2.
This is useful for datastream api, and is also a pre-work for exposing state v2
ap
[
https://issues.apache.org/jira/browse/FLINK-37030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37030:
---
Labels: pull-request-available (was: )
> Support lazy initialization for state serializer i
[
https://issues.apache.org/jira/browse/FLINK-36510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17910954#comment-17910954
]
Ferenc Csaky commented on FLINK-36510:
--
[~hepin], [~fanningpj] I focus now primaril
beryllw commented on PR #3728:
URL: https://github.com/apache/flink-cdc/pull/3728#issuecomment-2576979013
> @beryllw sorry for late response, could you base the PR to latest master
and then we can start the review?
Sure, thanks for help.
--
This is an automated message from the Apa
snuyanzin merged PR #25843:
URL: https://github.com/apache/flink/pull/25843
--
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
snuyanzin commented on code in PR #25907:
URL: https://github.com/apache/flink/pull/25907#discussion_r1906180383
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/CatalogManager.java:
##
@@ -1045,6 +1054,7 @@ public void createTable(
yiyutian1 commented on code in PR #25874:
URL: https://github.com/apache/flink/pull/25874#discussion_r1906204298
##
flink-python/pyflink/table/expressions.py:
##
@@ -350,14 +350,21 @@ def temporal_overlaps(left_time_point,
def date_format(timestamp, format) -> Expression:
yangjf2019 opened a new pull request, #927:
URL: https://github.com/apache/flink-kubernetes-operator/pull/927
## What is the purpose of the change
Hi @mxm ,Now that it's 2025,maybe we should update NOTICE files.Please take
a look in your spare time,thank you!
## Brief c
Zakelly merged PR #25901:
URL: https://github.com/apache/flink/pull/25901
--
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
[
https://issues.apache.org/jira/browse/FLINK-35167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu resolved FLINK-35167.
Resolution: Implemented
Implemented in master: 92081dfe58a550df9df35077f88ecd128b47eb02
> Introdu
Zakelly Lan created FLINK-37030:
---
Summary: Support lazy initialization for state serializer in State
V2
Key: FLINK-37030
URL: https://issues.apache.org/jira/browse/FLINK-37030
Project: Flink
I
[
https://issues.apache.org/jira/browse/FLINK-36950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sergey Nuyanzin resolved FLINK-36950.
-
Assignee: Jacky Lau
Resolution: Fixed
Merged as
[63edfd6bf7140c8be63cd76727784a87
huyuanfeng2018 commented on PR #921:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/921#issuecomment-2576559250
Thanks @1996fanrui @gyfora for the reply
Well, let me summarize our conclusion,
* we need to remove the boundary parameter in the future (deprecate
yuxiqian commented on code in PR #3802:
URL: https://github.com/apache/flink-cdc/pull/3802#discussion_r1906259219
##
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/event/FlushEvent.java:
##
@@ -17,25 +17,49 @@
package org.apache.flink.cdc.common.event;
+import j
lvyanquan commented on PR #3818:
URL: https://github.com/apache/flink-cdc/pull/3818#issuecomment-2576600660
Last CI passed and rebase master to fix the conflict.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
Zakelly Lan created FLINK-37028:
---
Summary: Datastream Window operator with async state processing
Key: FLINK-37028
URL: https://issues.apache.org/jira/browse/FLINK-37028
Project: Flink
Issue Ty
hanyuzheng7 commented on PR #25897:
URL: https://github.com/apache/flink/pull/25897#issuecomment-2576614644
> @hanyuzheng7 thanks for the PR
>
> would be also great if you fill the PR form
Thank you, I forget add description, I will add it.
--
This is an automated message fro
Zakelly commented on PR #25894:
URL: https://github.com/apache/flink/pull/25894#issuecomment-2576626029
Rebased master to resolve conflicts.
--
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 sp
GOODBOY008 commented on PR #3668:
URL: https://github.com/apache/flink-cdc/pull/3668#issuecomment-2576782890
@yuxiqian Mysql UT failed.
--
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 specifi
yuxiqian commented on PR #3668:
URL: https://github.com/apache/flink-cdc/pull/3668#issuecomment-2576800570
Seems there's some [compatibility
issue](https://forums.percona.com/t/percona-toolkit-execution-failure/34610)
between Percona Toolkit 3.7 and MySQL. Locked to a lower version should s
Weijie Guo created FLINK-37031:
--
Summary: Core dump in
StateBackendTestV2Base.testAsyncStateBackendScaleDown
Key: FLINK-37031
URL: https://issues.apache.org/jira/browse/FLINK-37031
Project: Flink
Xintong Song created FLINK-37038:
Summary: CLONE - [Release-1.20] Cross team testing
Key: FLINK-37038
URL: https://issues.apache.org/jira/browse/FLINK-37038
Project: Flink
Issue Type: Sub-tas
Xintong Song created FLINK-37037:
Summary: CLONE - [Release-1.20] Review Release Notes in JIRA
Key: FLINK-37037
URL: https://issues.apache.org/jira/browse/FLINK-37037
Project: Flink
Issue Typ
Xintong Song created FLINK-37035:
Summary: CLONE - [Release-1.20] Create a release branch
Key: FLINK-37035
URL: https://issues.apache.org/jira/browse/FLINK-37035
Project: Flink
Issue Type: S
Xintong Song created FLINK-37036:
Summary: CLONE - [Release-1.20] Prepare RC0 release
Key: FLINK-37036
URL: https://issues.apache.org/jira/browse/FLINK-37036
Project: Flink
Issue Type: Sub-ta
Xintong Song created FLINK-37040:
Summary: CLONE - [Release-1.20] Review and update documentation
Key: FLINK-37040
URL: https://issues.apache.org/jira/browse/FLINK-37040
Project: Flink
Issue
yangjf2019 opened a new pull request, #25916:
URL: https://github.com/apache/flink/pull/25916
## What is the purpose of the change
Update copyright NOTICE year to 2025.
## Brief change log
*(for example:)*
- *The TaskInfo is stored in the blob store on job cr
yangjf2019 commented on PR #25916:
URL: https://github.com/apache/flink/pull/25916#issuecomment-2576528324
Hi @rmetzger ,Now that it's 2025, maybe we should update it.Please take a
look in your spare time,thank you very much!
--
This is an automated message from the Apache Git Service.
T
flinkbot commented on PR #25916:
URL: https://github.com/apache/flink/pull/25916#issuecomment-2576532171
## CI report:
* 35c5ce715d85e72d8ec73523d104b9e154f62a99 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
hanyuzheng7 commented on code in PR #25897:
URL: https://github.com/apache/flink/pull/25897#discussion_r1906221025
##
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/codegen/calls/FloorCeilCallGen.scala:
##
@@ -65,15 +65,17 @@ class FloorCeilCallGen
hanyuzheng7 commented on code in PR #25897:
URL: https://github.com/apache/flink/pull/25897#discussion_r1906226179
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/TimeFunctionsITCase.java:
##
@@ -588,34 +588,50 @@ private Stream ceilTest
Xintong Song created FLINK-37043:
Summary: [Umbrella] Test Flink Release 2.0
Key: FLINK-37043
URL: https://issues.apache.org/jira/browse/FLINK-37043
Project: Flink
Issue Type: Technical Debt
ChaomingZhang created FLINK-37042:
-
Summary: Unify option names using kebab-case in
MaxComputeDataSinkOptions
Key: FLINK-37042
URL: https://issues.apache.org/jira/browse/FLINK-37042
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-36832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu reassigned FLINK-36832:
--
Assignee: Yanquan Lv
> Remove deprecated class in flink-connector-kafka
> ---
leonardBang commented on code in PR #139:
URL:
https://github.com/apache/flink-connector-kafka/pull/139#discussion_r1906558378
##
flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/KafkaITCase.java:
##
@@ -1,380 +0,0 @@
-/*
- * Licensed to the Apach
[
https://issues.apache.org/jira/browse/FLINK-37042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17910939#comment-17910939
]
ChaomingZhang commented on FLINK-37042:
---
@[~Leonard]
> Unify option names using k
leonardBang merged PR #3840:
URL: https://github.com/apache/flink-cdc/pull/3840
--
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
gyfora commented on PR #921:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/921#issuecomment-257687
> Thanks @1996fanrui @gyfora for the reply
>
> Well, let me summarize our conclusion,
>
> * we need to remove the boundary parameter in the future (deprecate n
beryllw commented on PR #3728:
URL: https://github.com/apache/flink-cdc/pull/3728#issuecomment-2576889420
@leonardBang PTAL
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
xuyangzhong commented on code in PR #25815:
URL: https://github.com/apache/flink/pull/25815#discussion_r1906571795
##
flink-runtime/src/test/java/org/apache/flink/streaming/util/KeyedTwoInputStreamOperatorTestHarness.java:
##
@@ -64,8 +67,24 @@ public KeyedTwoInputStreamOperator
301 - 340 of 340 matches
Mail list logo
