xuyangzhong commented on code in PR #25680:
URL: https://github.com/apache/flink/pull/25680#discussion_r1908310186
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/aggregate/utils/GroupAggHelper.java:
##
@@ -0,0 +1,156 @@
+/*
+ * Licensed
xuyangzhong commented on code in PR #25680:
URL: https://github.com/apache/flink/pull/25680#discussion_r1908323169
##
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/harness/GroupAggregateHarnessTest.scala:
##
@@ -397,17 +450,19 @@ class Gro
Jzjsnow commented on code in PR #3823:
URL: https://github.com/apache/flink-cdc/pull/3823#discussion_r1908197660
##
flink-cdc-cli/src/test/java/org/apache/flink/cdc/cli/CliFrontendTest.java:
##
@@ -145,6 +147,70 @@ void testPipelineExecuting() throws Exception {
assert
xuyangzhong commented on code in PR #25680:
URL: https://github.com/apache/flink/pull/25680#discussion_r1908331665
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/aggregate/utils/GroupAggHelper.java:
##
@@ -0,0 +1,156 @@
+/*
+ * Licensed
xuyangzhong commented on code in PR #25680:
URL: https://github.com/apache/flink/pull/25680#discussion_r1908333884
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/aggregate/asyncprocessing/AsyncStateGroupAggFunction.java:
##
@@ -0,0 +1,1
xuyangzhong commented on PR #25680:
URL: https://github.com/apache/flink/pull/25680#issuecomment-2579426557
Hi, @Zakelly @lincoln-lil Thanks for reviewing. I have updated this pr and
could you please to take a look again?
--
This is an automated message from the Apache Git Service.
To res
fhueske commented on code in PR #25753:
URL: https://github.com/apache/flink/pull/25753#discussion_r1908354102
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/over/NonTimeUnboundedPrecedingFunction.java:
##
@@ -0,0 +1,591 @@
+/*
+ * Lice
xuyangzhong commented on code in PR #25717:
URL: https://github.com/apache/flink/pull/25717#discussion_r1909886994
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/rank/async/AbstractAsyncStateTopNFunction.java:
##
@@ -0,0 +1,60 @@
+/*
+
xuyangzhong commented on PR #25717:
URL: https://github.com/apache/flink/pull/25717#issuecomment-2581904311
@xishuaidelin Updated! Could you please take a look again?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
xuyangzhong commented on code in PR #25717:
URL: https://github.com/apache/flink/pull/25717#discussion_r1909899286
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/rank/FastTop1Function.java:
##
@@ -112,66 +89,58 @@ public void open(OpenC
xuyangzhong commented on code in PR #25717:
URL: https://github.com/apache/flink/pull/25717#discussion_r1909891982
##
flink-table/flink-table-planner/src/test/scala/org/apache/flink/table/planner/runtime/harness/RankHarnessTest.scala:
##
@@ -451,4 +467,128 @@ class RankHarnessTe
xuyangzhong commented on code in PR #25717:
URL: https://github.com/apache/flink/pull/25717#discussion_r1909891358
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/rank/AbstractSyncStateTopNFunction.java:
##
@@ -0,0 +1,98 @@
+/*
+ * Licen
MOBIN-F commented on code in PR #3749:
URL: https://github.com/apache/flink-cdc/pull/3749#discussion_r1909895338
##
flink-cdc-composer/src/test/java/org/apache/flink/cdc/composer/flink/FlinkPipelineTransformITCase.java:
##
@@ -370,6 +371,99 @@ void
testMultiTransformMissingProj
flinkbot commented on PR #25945:
URL: https://github.com/apache/flink/pull/25945#issuecomment-2581918768
## CI report:
* 051cad80e9dbc01a7f600b7c59455db5e3913a70 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
Mingcan Wang created FLINK-37093:
Summary: The catalog that failed validation due to no type still
exists in catalogStoreHolder
Key: FLINK-37093
URL: https://issues.apache.org/jira/browse/FLINK-37093
[
https://issues.apache.org/jira/browse/FLINK-34554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17911679#comment-17911679
]
Arvid Heise commented on FLINK-34554:
-
I'm opening a draft PR tomorrow. I figured ou
[
https://issues.apache.org/jira/browse/FLINK-36696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-36696:
Fix Version/s: kubernetes-operator-1.11.0
> JDBC Autoscaler plugin should use DataSource and not connectio
[
https://issues.apache.org/jira/browse/FLINK-37085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-37085:
---
Description:
{code:java}
Jan 09 13:28:50 13:28:50.648 [ERROR]
AdaptiveJoinTest.testAdaptiveJoinWi
Weijie Guo created FLINK-37085:
--
Summary: AdaptiveJoinTest.testAdaptiveJoinWithBatchJobRecovery
Key: FLINK-37085
URL: https://issues.apache.org/jira/browse/FLINK-37085
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-37079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
xuyang closed FLINK-37079.
--
Resolution: Duplicate
> ci fails at SqlYARNApplicationITCase.testDeployScriptViaSqlClient
> --
[
https://issues.apache.org/jira/browse/FLINK-37085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-37085:
---
Priority: Blocker (was: Major)
> AdaptiveJoinTest.testAdaptiveJoinWithBatchJobRecovery
> --
Rui Fan created FLINK-37086:
---
Summary: State leaks for JBBC state store after job is stopped
Key: FLINK-37086
URL: https://issues.apache.org/jira/browse/FLINK-37086
Project: Flink
Issue Type: Bug
JunRuiLee merged PR #25943:
URL: https://github.com/apache/flink/pull/25943
--
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
[
https://issues.apache.org/jira/browse/FLINK-37085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Junrui Lee resolved FLINK-37085.
Fix Version/s: 2.0.0
Resolution: Fixed
master:89c7c2b9c55702f6f54191c98c373ec2ce9f6c41
> A
[
https://issues.apache.org/jira/browse/FLINK-37081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17911780#comment-17911780
]
zhang commented on FLINK-37081:
---
@[~Leonard] Can you help me with this?
> The debezium ve
[
https://issues.apache.org/jira/browse/FLINK-36548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17911779#comment-17911779
]
xuyang commented on FLINK-36548:
https://dev.azure.com/apache-flink/apache-flink/_build/
ChaomingZhangCN commented on code in PR #3829:
URL: https://github.com/apache/flink-cdc/pull/3829#discussion_r1909923394
##
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/shade/ConfigShade.java:
##
@@ -0,0 +1,54 @@
+/*
+ * Licensed to the Apache Software Foundation (
ChaomingZhangCN commented on code in PR #3829:
URL: https://github.com/apache/flink-cdc/pull/3829#discussion_r1909923394
##
flink-cdc-common/src/main/java/org/apache/flink/cdc/common/shade/ConfigShade.java:
##
@@ -0,0 +1,54 @@
+/*
+ * Licensed to the Apache Software Foundation (
Zakelly commented on PR #25894:
URL: https://github.com/apache/flink/pull/25894#issuecomment-2581945109
Rebase master to resolve the CI failure.
--
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 th
lidoudou1993 opened a new pull request, #3848:
URL: https://github.com/apache/flink-cdc/pull/3848
(no comment)
--
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 unsubscrib
github-actions[bot] commented on PR #3708:
URL: https://github.com/apache/flink-cdc/pull/3708#issuecomment-2581477557
This pull request has been automatically marked as stale because it has not
had recent activity for 60 days. It will be closed in 30 days if no further
activity occurs.
--
[
https://issues.apache.org/jira/browse/FLINK-36941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17911716#comment-17911716
]
Yiyu Tian edited comment on FLINK-36941 at 1/10/25 1:16 AM:
[
https://issues.apache.org/jira/browse/FLINK-36773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
lincoln lee closed FLINK-36773.
---
Resolution: Fixed
fixed in master: bceca90aa7c492a15e5a0e3021586b1891ffec5d
> Introduce new Group A
lincoln-lil merged PR #25680:
URL: https://github.com/apache/flink/pull/25680
--
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.a
xuyangzhong commented on PR #25540:
URL: https://github.com/apache/flink/pull/25540#issuecomment-2581566400
No worries, I'll continue handling it :)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go t
lvyanquan commented on PR #140:
URL:
https://github.com/apache/flink-connector-kafka/pull/140#issuecomment-2581568558
[E2e](https://github.com/apache/flink-connector-kafka/tree/main/flink-connector-kafka-e2e-tests/flink-end-to-end-tests-common-kafka/src/test/java/org/apache/flink/tests/util
Zakelly commented on code in PR #25723:
URL: https://github.com/apache/flink/pull/25723#discussion_r1909824008
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/rank/UpdatableTopNFunction.java:
##
@@ -541,8 +541,10 @@ private void processE
[
https://issues.apache.org/jira/browse/FLINK-37081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17911786#comment-17911786
]
Leonard Xu commented on FLINK-37081:
[~edmond_j] Debeizum 2.0 + version required JDK
[
https://issues.apache.org/jira/browse/FLINK-37081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu reassigned FLINK-37081:
--
Assignee: zhang
> The debezium version of sqlserver cdc needs to be upgraded to 2.6 or higher
yuxiqian commented on code in PR #3749:
URL: https://github.com/apache/flink-cdc/pull/3749#discussion_r1909897648
##
flink-cdc-composer/src/test/java/org/apache/flink/cdc/composer/flink/FlinkPipelineTransformITCase.java:
##
@@ -370,6 +371,149 @@ void
testMultiTransformMissingPr
yuxiqian commented on code in PR #3749:
URL: https://github.com/apache/flink-cdc/pull/3749#discussion_r1909897648
##
flink-cdc-composer/src/test/java/org/apache/flink/cdc/composer/flink/FlinkPipelineTransformITCase.java:
##
@@ -370,6 +371,149 @@ void
testMultiTransformMissingPr
Junrui Lee created FLINK-37092:
--
Summary: Enable skewed join optimization in the TPC-DS e2e test.
Key: FLINK-37092
URL: https://issues.apache.org/jira/browse/FLINK-37092
Project: Flink
Issue Typ
X-czh opened a new pull request, #25945:
URL: https://github.com/apache/flink/pull/25945
## What is the purpose of the change
Remove Scala contents in serialization doc as Scala API has been removed.
## Verifying this change
Merely doc changes.
## Does this
[
https://issues.apache.org/jira/browse/FLINK-37015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37015:
---
Labels: pull-request-available (was: )
> Revise serialization doc to reflect the 2.0 breaki
dalongliu created FLINK-37091:
-
Summary: Remove deprecated CatalogLock interface
Key: FLINK-37091
URL: https://issues.apache.org/jira/browse/FLINK-37091
Project: Flink
Issue Type: Sub-task
X-czh commented on PR #25945:
URL: https://github.com/apache/flink/pull/25945#issuecomment-2581915749
@reswqa Hi, could you help take a review? Thx
--
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
[
https://issues.apache.org/jira/browse/FLINK-36941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17911716#comment-17911716
]
Yiyu Tian edited comment on FLINK-36941 at 1/10/25 12:59 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-36941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17911716#comment-17911716
]
Yiyu Tian edited comment on FLINK-36941 at 1/10/25 1:08 AM:
[
https://issues.apache.org/jira/browse/FLINK-36941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17911716#comment-17911716
]
Yiyu Tian edited comment on FLINK-36941 at 1/10/25 1:10 AM:
[
https://issues.apache.org/jira/browse/FLINK-37031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17911762#comment-17911762
]
Yanfei Lei commented on FLINK-37031:
Merged into master via a79f2e2f1b434d050cb1b2d7
[
https://issues.apache.org/jira/browse/FLINK-37031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yanfei Lei resolved FLINK-37031.
Resolution: Fixed
> Core dump in StateBackendTestV2Base.testAsyncStateBackendScaleDown
> -
baimafeima-yf opened a new pull request, #25944:
URL: https://github.com/apache/flink/pull/25944
## What is the purpose of the change
*flink application support host mount log for the JobManager/TaskManager
Container*
## Brief change log
- add FlinkLog
[
https://issues.apache.org/jira/browse/FLINK-37088?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37088:
---
Labels: pull-request-available (was: )
> When the Flink application is running in k8s, the
flinkbot commented on PR #25944:
URL: https://github.com/apache/flink/pull/25944#issuecomment-2581698922
## CI report:
* e575a7e253c4a27d9d9ad092aca9a8f48305690f UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
boring-cyborg[bot] commented on PR #32:
URL:
https://github.com/apache/flink-connector-cassandra/pull/32#issuecomment-2581423809
Thanks for opening this pull request! Please check out our contributing
guidelines. (https://flink.apache.org/contributing/how-to-contribute.html)
--
This
mkorolyov opened a new pull request, #32:
URL: https://github.com/apache/flink-connector-cassandra/pull/32
Hi,
I've implemented examples from the docs for Sinks with and without Pojo
classes and for Sources for Apache Cassandra. They were working as expected.
Than I just replaced con
Zakelly Lan created FLINK-37089:
---
Summary: Advanced scheduling for derived async state processing
Key: FLINK-37089
URL: https://issues.apache.org/jira/browse/FLINK-37089
Project: Flink
Issue Ty
[
https://issues.apache.org/jira/browse/FLINK-36946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan resolved FLINK-36946.
-
Fix Version/s: 2.0.0
Resolution: Fixed
Merged to master(2.0.0) via: b75d76e2f9484473285121d5d7af9
1996fanrui merged PR #25832:
URL: https://github.com/apache/flink/pull/25832
--
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
SinBex opened a new pull request, #25943:
URL: https://github.com/apache/flink/pull/25943
## What is the purpose of the change
*fix ut in AdaptiveJoinTest.testAdaptiveJoinWithBatchJobRecovery.*
## Brief change log
- *fix ut in AdaptiveJoinTest.testAdaptiveJoinWithBa
[
https://issues.apache.org/jira/browse/FLINK-37085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37085:
---
Labels: pull-request-available (was: )
> AdaptiveJoinTest.testAdaptiveJoinWithBatchJobRecov
flinkbot commented on PR #25943:
URL: https://github.com/apache/flink/pull/25943#issuecomment-2581660153
## CI report:
* b71f00feb2427a327c8aefc1cddaad1dc9b193a7 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-36844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36844:
---
Labels: pull-request-available (was: )
> Postgres CDC document add mapping from postgres ti
loserwang1024 opened a new pull request, #3847:
URL: https://github.com/apache/flink-cdc/pull/3847
Fix https://issues.apache.org/jira/browse/FLINK-36844
--
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
piotrp opened a new pull request, #25942:
URL: https://github.com/apache/flink/pull/25942
## What is the purpose of the change
Restores compatibility with Logback 1.2, fixes issues
[FLINK-36104](https://issues.apache.org/jira/browse/FLINK-36104) and
[FLINK-36227](https://issues.apach
piotrp commented on PR #25813:
URL: https://github.com/apache/flink/pull/25813#issuecomment-2581372726
That Jira issue is incorrectly tagged, release-1.19 branch has no references
to `MDC`.
PR for master: #25942.
--
This is an automated message from the Apache Git Service.
To respo
flinkbot commented on PR #25942:
URL: https://github.com/apache/flink/pull/25942#issuecomment-2581375495
## CI report:
* 46f15d1cc00c0e4eced52fdef9cba71e3ec81e87 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-36941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17911716#comment-17911716
]
Yiyu Tian commented on FLINK-36941:
---
Other functions that still use SimpleDateFormat a
[
https://issues.apache.org/jira/browse/FLINK-36941?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17911716#comment-17911716
]
Yiyu Tian edited comment on FLINK-36941 at 1/10/25 12:43 AM:
-
lvyanquan commented on PR #2571:
URL: https://github.com/apache/flink-cdc/pull/2571#issuecomment-2581667805
Hi @lzshlzsh. We plan to release 3.3.0 version soon. Do you have time to
continue with this change? If not, we will try to add this PR in version 3.4.0
or 3.3.1.
--
This is an auto
xishuaidelin commented on code in PR #25717:
URL: https://github.com/apache/flink/pull/25717#discussion_r1909730165
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/rank/async/AbstractAsyncStateTopNFunction.java:
##
@@ -0,0 +1,60 @@
+/*
+
baimafeimayf created FLINK-37088:
Summary: When the Flink application is running in k8s, the
taskmanager log lacks a mount mapping to the host machine. Once the container
is restarted, the log will disappear. It is necessary to have a log mount
[
https://issues.apache.org/jira/browse/FLINK-36753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17911757#comment-17911757
]
Rui Fan commented on FLINK-36753:
-
Thanks [~samrat007] for the summary! :)
{quote}1. Wou
sharath1709 opened a new pull request, #930:
URL: https://github.com/apache/flink-kubernetes-operator/pull/930
…n from autoscaler
## What is the purpose of the change
This pull request makes change to gracefully handle null execution plan
returned from the Flink Rest AP
[
https://issues.apache.org/jira/browse/FLINK-36645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36645:
---
Labels: pull-request-available (was: )
> Gracefully handle null execution plan from autosca
yuxiqian commented on code in PR #3749:
URL: https://github.com/apache/flink-cdc/pull/3749#discussion_r1909700869
##
flink-cdc-composer/src/test/java/org/apache/flink/cdc/composer/flink/FlinkPipelineTransformITCase.java:
##
@@ -370,6 +371,99 @@ void
testMultiTransformMissingPro
yuxiqian commented on code in PR #3749:
URL: https://github.com/apache/flink-cdc/pull/3749#discussion_r1909700869
##
flink-cdc-composer/src/test/java/org/apache/flink/cdc/composer/flink/FlinkPipelineTransformITCase.java:
##
@@ -370,6 +371,99 @@ void
testMultiTransformMissingPro
[
https://issues.apache.org/jira/browse/FLINK-37087?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dalongliu reassigned FLINK-37087:
-
Assignee: Feng Jin
> Add docs for alter materialized table as query
> -
dalongliu created FLINK-37087:
-
Summary: Add docs for alter materialized table as query
Key: FLINK-37087
URL: https://issues.apache.org/jira/browse/FLINK-37087
Project: Flink
Issue Type: Sub-task
loserwang1024 commented on PR #3030:
URL: https://github.com/apache/flink-cdc/pull/3030#issuecomment-2581628824
rebase 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 to the specific co
1996fanrui commented on code in PR #929:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/929#discussion_r1909700607
##
flink-autoscaler-plugin-jdbc/src/test/java/org/apache/flink/autoscaler/jdbc/state/AbstractJdbcStateStoreITCase.java:
##
@@ -45,24 +45,17 @@
abst
yuxiqian commented on PR #3673:
URL: https://github.com/apache/flink-cdc/pull/3673#issuecomment-2581636092
Rebased & resolved conflicts, would @lvyanquan like to take a look?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
[
https://issues.apache.org/jira/browse/FLINK-37085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Junrui Lee reassigned FLINK-37085:
--
Assignee: xingbe
> AdaptiveJoinTest.testAdaptiveJoinWithBatchJobRecovery
> --
[
https://issues.apache.org/jira/browse/FLINK-37083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Shengkai Fang reassigned FLINK-37083:
-
Assignee: Shengkai Fang
> SqlYARNApplicationITCase.testDeployScriptViaSqlClient failed
[
https://issues.apache.org/jira/browse/FLINK-37085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17911740#comment-17911740
]
Weijie Guo commented on FLINK-37085:
https://dev.azure.com/apache-flink/apache-flink
1996fanrui commented on code in PR #928:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/928#discussion_r1909685576
##
docs/content/docs/custom-resource/reference.md:
##
@@ -182,6 +182,7 @@ This serves as a full reference for FlinkDeployment and
FlinkSessionJob c
leonardBang merged PR #3846:
URL: https://github.com/apache/flink-cdc/pull/3846
--
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
[
https://issues.apache.org/jira/browse/FLINK-37079?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17911739#comment-17911739
]
xuyang commented on FLINK-37079:
Duplicated with https://issues.apache.org/jira/browse/F
[
https://issues.apache.org/jira/browse/FLINK-37086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan updated FLINK-37086:
Summary: State leaks for JDBC state store after job is stopped (was: State
leaks for JBBC state store aft
huyuanfeng2018 commented on PR #921:
URL:
https://github.com/apache/flink-kubernetes-operator/pull/921#issuecomment-2581610613
> Thanks for the update, LGTM assuming the CI is green.
Thanks for your quick reply
--
This is an automated message from the Apache Git Service.
To
[
https://issues.apache.org/jira/browse/FLINK-36960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo resolved FLINK-36960.
Fix Version/s: 2.0.0
Resolution: Resolved
master(2.0) via 75c26e8c9fd39b957fd1e79323b4fae97
beliefer commented on PR #25836:
URL: https://github.com/apache/flink/pull/25836#issuecomment-2581863491
@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.
beliefer commented on PR #25836:
URL: https://github.com/apache/flink/pull/25836#issuecomment-2581864316
> @beliefer this change looks reasonable - but why is the CI failing?
I don't know how, but let me rerun the tests.
--
This is an automated message from the Apache Git Service.
T
[
https://issues.apache.org/jira/browse/FLINK-37090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Junrui Lee updated FLINK-37090:
---
Summary: Introduce a TPC-DS E2E case for adaptive broadcast join (was:
Introduce tpc-ds e2e case fo
Junrui Lee created FLINK-37090:
--
Summary: Introduce tpc-ds e2e case for adaptive broadcast join
Key: FLINK-37090
URL: https://issues.apache.org/jira/browse/FLINK-37090
Project: Flink
Issue Type:
afedulov commented on PR #25830:
URL: https://github.com/apache/flink/pull/25830#issuecomment-2579620360
@mehdid93 I already rebased your branch, CI is green.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL abo
mehdid93 commented on PR #25830:
URL: https://github.com/apache/flink/pull/25830#issuecomment-2579633271
@afedulov Thanks a lot for rebasing and merging the PRs. I've rebased
because when I've opened this PR there was some conflicts with package.json and
package-lock.json after the merge of
afedulov opened a new pull request, #25934:
URL: https://github.com/apache/flink/pull/25934
Unmodified backport of https://github.com/apache/flink/pull/25921
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL abov
[
https://issues.apache.org/jira/browse/FLINK-33467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17911426#comment-17911426
]
He Pin commented on FLINK-33467:
Hi, This can be done in Pekko 2.0, would you like to co
twalthr commented on code in PR #25928:
URL: https://github.com/apache/flink/pull/25928#discussion_r1908556932
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/types/inference/SystemTypeInference.java:
##
@@ -0,0 +1,324 @@
+/*
+ * Licensed to the Apache Sof
1 - 100 of 266 matches
Mail list logo
