yiyutian1 commented on code in PR #25752:
URL: https://github.com/apache/flink/pull/25752#discussion_r1875520022
##
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/plan/rules/physical/stream/StreamLogicalOptimizeSelectDistinctRule.scala:
##
@@ -0,0
flinkbot commented on PR #25763:
URL: https://github.com/apache/flink/pull/25763#issuecomment-2527181717
## CI report:
* 6c910de13b2e652f6e02f59ec7fa878af9a68f10 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-36862?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36862:
---
Labels: pull-request-available (was: )
> Implement additional TO_TIMESTAMP_LTZ() functions
yiyutian1 opened a new pull request, #25763:
URL: https://github.com/apache/flink/pull/25763
## 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
[
https://issues.apache.org/jira/browse/FLINK-28927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17904048#comment-17904048
]
yanpengshi edited comment on FLINK-28927 at 12/9/24 7:46 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-28927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17904048#comment-17904048
]
yanpengshi edited comment on FLINK-28927 at 12/9/24 7:45 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-28927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17904048#comment-17904048
]
yanpengshi commented on FLINK-28927:
[~ChangjiGuo], This issue seems like
the[FLINK
[
https://issues.apache.org/jira/browse/FLINK-35652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo resolved FLINK-35652.
Fix Version/s: 2.0.0
Resolution: Done
master(2.0) via cfaa00e215e4b5fd72a0a4271449d2ca47eae
[
https://issues.apache.org/jira/browse/FLINK-35652?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17904043#comment-17904043
]
Weijie Guo commented on FLINK-35652:
[~liming] Yes, 2.0-preview1 doesn't include thi
reswqa commented on PR #25729:
URL: https://github.com/apache/flink/pull/25729#issuecomment-2527141363
Thanks all for the review, merged into master.
--
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
reswqa closed pull request #25729: [FLINK-35652] Support Custom Data
Distribution for Input Stream of Lookup Join
URL: https://github.com/apache/flink/pull/25729
--
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
fredia commented on code in PR #25676:
URL: https://github.com/apache/flink/pull/25676#discussion_r1875399573
##
flink-runtime/src/test/java/org/apache/flink/runtime/state/v2/StateBackendTestV2Base.java:
##
@@ -177,8 +182,8 @@ protected AsyncKeyedStateBackend
restoreAsyncKeyed
[
https://issues.apache.org/jira/browse/FLINK-36370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17904020#comment-17904020
]
Aniruddh J commented on FLINK-36370:
[~gyfora] can you please share some insight on
fredia commented on code in PR #25760:
URL: https://github.com/apache/flink/pull/25760#discussion_r1875309207
##
flink-runtime/src/main/java/org/apache/flink/runtime/asyncprocessing/AsyncExecutionController.java:
##
@@ -291,13 +291,21 @@ public InternalStateFuture handleRequest
huyuanfeng2018 commented on code in PR #921:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/921#discussion_r1875302925
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/ScalingMetricEvaluator.java:
##
@@ -296,8 +297,14 @@ protected static void compute
yux created FLINK-36864:
---
Summary: YAML Pipeline could not write number literals that
exceeds Int32 range
Key: FLINK-36864
URL: https://issues.apache.org/jira/browse/FLINK-36864
Project: Flink
Issue T
1996fanrui commented on code in PR #921:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/921#discussion_r1875279589
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/ScalingMetricEvaluator.java:
##
@@ -296,8 +297,14 @@ protected static void computeProc
leonardBang commented on PR #3434:
URL: https://github.com/apache/flink-cdc/pull/3434#issuecomment-2526768471
@umeshdangat Thanks for your updating, and we will have a final review for
this PR ASAP.
--
This is an automated message from the Apache Git Service.
To respond to the message, pl
leonardBang commented on code in PR #3460:
URL: https://github.com/apache/flink-cdc/pull/3460#discussion_r1875268855
##
flink-cdc-connect/flink-cdc-source-connectors/flink-connector-mysql-cdc/src/test/java/org/apache/flink/cdc/connectors/mysql/source/NewlyAddedTableITCase.java:
leonardBang commented on PR #3590:
URL: https://github.com/apache/flink-cdc/pull/3590#issuecomment-2526757300
@ruanhang1993 Would you like to help review this PR?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
lvyanquan opened a new pull request, #3590:
URL: https://github.com/apache/flink-cdc/pull/3590
Support parsing SQL like following and emit new SchemaChangeEvent to
downstream.
```
CREATE TABLE `user_log_copy` LIKE `user_log`
```
and
```
CREATE TABLE `user_log_copy` AS SELEC
[
https://issues.apache.org/jira/browse/FLINK-36863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-36863:
Description:
FLINK-36535 uses the maximum parallelism since the scale down trigger when
scaling down. Bec
[
https://issues.apache.org/jira/browse/FLINK-36863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36863:
---
Labels: pull-request-available (was: )
> Use the maximum parallelism in the past scale-down
1996fanrui opened a new pull request, #922:
URL: https://github.com/apache/flink-kubernetes-operator/pull/922
## What is the purpose of the change
[FLINK-36863][autoscaler] Use the maximum parallelism in the **_past
scale-down.interval window_** when scaling down
## Brief chang
[
https://issues.apache.org/jira/browse/FLINK-36863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-36863:
Description:
FLINK-36535 uses the maximum parallelism since the scale down trigger when
scaling down. Bec
fredia commented on code in PR #25745:
URL: https://github.com/apache/flink/pull/25745#discussion_r1875228444
##
flink-state-backends/flink-statebackend-forst/src/main/java/org/apache/flink/state/forst/ForStKeyedStateBackend.java:
##
@@ -227,6 +233,21 @@ public void setup(@Nonnu
[
https://issues.apache.org/jira/browse/FLINK-36863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-36863:
Description:
FLINK-36535 uses the maximum parallelism since the scale down trigger when
scaling down. Bec
[
https://issues.apache.org/jira/browse/FLINK-36859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17904007#comment-17904007
]
Zakelly Lan commented on FLINK-36859:
-
Merge d62dc68 into master.
> Wrong epoch/wat
[
https://issues.apache.org/jira/browse/FLINK-36859?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zakelly Lan resolved FLINK-36859.
-
Resolution: Fixed
> Wrong epoch/watermark firing in async state processing
> ---
Rui Fan created FLINK-36863:
---
Summary: Use the maximum parallelism in the past
scale-down.interval window when scaling down
Key: FLINK-36863
URL: https://issues.apache.org/jira/browse/FLINK-36863
Project: F
Zakelly merged PR #25761:
URL: https://github.com/apache/flink/pull/25761
--
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
Zakelly commented on PR #25761:
URL: https://github.com/apache/flink/pull/25761#issuecomment-2526722949
Thanks for the review, merging...
--
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 speci
[
https://issues.apache.org/jira/browse/FLINK-36613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zakelly Lan resolved FLINK-36613.
-
Assignee: Zakelly Lan
Resolution: Fixed
> RescaleCheckpointManuallyITCase.testCheckpointRe
[
https://issues.apache.org/jira/browse/FLINK-36863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-36863:
Description:
FLINK-36535 uses the maximum parallelism since the scale down trigger when
scaling down. Bec
liuyongvs commented on code in PR #25742:
URL: https://github.com/apache/flink/pull/25742#discussion_r1875174539
##
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/plan/rules/logical/SortFetchZeroRuleTest.scala:
##
@@ -22,11 +22,12 @@ import
org.ap
yunfengzhou-hub commented on PR #25729:
URL: https://github.com/apache/flink/pull/25729#issuecomment-2526617613
Thanks for the update! LGTM.
--
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
reswqa commented on PR #25729:
URL: https://github.com/apache/flink/pull/25729#issuecomment-2526621464
@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.
T
liuyongvs commented on code in PR #25690:
URL: https://github.com/apache/flink/pull/25690#discussion_r1875168910
##
flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/rules/logical/PruneEmptyRulesTest.xml:
##
Review Comment:
if you think
liuyongvs commented on code in PR #25690:
URL: https://github.com/apache/flink/pull/25690#discussion_r1875162913
##
flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/rules/logical/PruneEmptyRulesTest.xml:
##
Review Comment:
@snuyanzin te
liuyongvs commented on code in PR #25690:
URL: https://github.com/apache/flink/pull/25690#discussion_r1875162913
##
flink-table/flink-table-planner/src/test/resources/org/apache/flink/table/planner/plan/rules/logical/PruneEmptyRulesTest.xml:
##
Review Comment:
@snuyanzin Pr
github-actions[bot] commented on PR #3590:
URL: https://github.com/apache/flink-cdc/pull/3590#issuecomment-2526525052
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
github-actions[bot] closed pull request #3590:
[FLINK-36178][pipeline-connector/mysql] Parse `CREATE TABLE ... LIKE …` syntax.
URL: https://github.com/apache/flink-cdc/pull/3590
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
henneberger commented on PR #25616:
URL: https://github.com/apache/flink/pull/25616#issuecomment-2526325155
It's was just a patch commit from the webui, i'll have to drop it. I took a
look at the full scope and replacing all of the references is a bit more
involved. If I get some time I'll
henneberger closed pull request #25616: [HOTFIX] Fix avro specification link in
Docs
URL: https://github.com/apache/flink/pull/25616
--
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
rmetzger commented on PR #25735:
URL: https://github.com/apache/flink/pull/25735#issuecomment-2525938575
Are the test failures related to the change?
--
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
rmetzger commented on PR #25529:
URL: https://github.com/apache/flink/pull/25529#issuecomment-2525930576
@twalthr @wuchong is it okay to remove this method?
--
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
[
https://issues.apache.org/jira/browse/FLINK-36508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17903912#comment-17903912
]
Robert Metzger commented on FLINK-36508:
[~xuyangzhong] can you review the PR?
gaborgsomogyi commented on PR #25755:
URL: https://github.com/apache/flink/pull/25755#issuecomment-2525556359
@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
snuyanzin commented on code in PR #25757:
URL: https://github.com/apache/flink/pull/25757#discussion_r1874717063
##
flink-core/src/main/java/org/apache/flink/api/java/typeutils/TypeExtractor.java:
##
@@ -2046,7 +2046,9 @@ private boolean isValidPojoField(Field f, Class clazz,
L
zhuzhurk commented on code in PR #25593:
URL: https://github.com/apache/flink/pull/25593#discussion_r1871331676
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/join/adaptive/AdaptiveJoinOperatorFactory.java:
##
@@ -0,0 +1,125 @@
+/*
+ *
huyuanfeng2018 commented on code in PR #921:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/921#discussion_r1874712171
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/ScalingMetricEvaluator.java:
##
@@ -296,8 +297,14 @@ protected static void compute
huyuanfeng2018 commented on code in PR #921:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/921#discussion_r1874712096
##
flink-autoscaler/src/main/java/org/apache/flink/autoscaler/ScalingMetricEvaluator.java:
##
@@ -296,8 +297,14 @@ protected static void compute
52 matches
Mail list logo
