[
https://issues.apache.org/jira/browse/FLINK-37069?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo reassigned FLINK-37069:
--
Assignee: Weijie Guo
> Cross-team verification for "Disaggregated State Management"
> ---
[
https://issues.apache.org/jira/browse/FLINK-37048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo reassigned FLINK-37048:
--
Assignee: Junrui Lee
> Cross-team verification for "Remove Deprecated methods/fields/classes
[
https://issues.apache.org/jira/browse/FLINK-37044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17927627#comment-17927627
]
Samrat Deb commented on FLINK-37044:
Hey Karan,
Thank you for creating the ticket
flinkbot commented on PR #26163:
URL: https://github.com/apache/flink/pull/26163#issuecomment-2662289834
## CI report:
* aedda14b91aa71137ee28277f3b415ae5e202d10 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
snuyanzin commented on PR #23899:
URL: https://github.com/apache/flink/pull/23899#issuecomment-2662278782
>
One small question: do we need sync the delta commits from the existing
master to the hive connector repo (the delta part compare to hive connector's
latest branch) before finally
[
https://issues.apache.org/jira/browse/FLINK-37304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37304:
---
Labels: pull-request-available (was: )
> Dynamic Kafka Source logs unnecessary information
lvyanquan opened a new pull request, #153:
URL: https://github.com/apache/flink-connector-kafka/pull/153
To avoid displaying a large amount of connection information.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
[
https://issues.apache.org/jira/browse/FLINK-37333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37333:
---
Labels: pull-request-available (was: )
> Use ForwardForUnspecifiedPartitioner when adaptive
SinBex opened a new pull request, #26163:
URL: https://github.com/apache/flink/pull/26163
## What is the purpose of the change
According to the design, we need to change the original forward partitioner
to a rescale partitioner after the adaptive broadcast join takes effect.
Accordin
bvarghese1 commented on code in PR #25753:
URL: https://github.com/apache/flink/pull/25753#discussion_r1957702817
##
flink-table/flink-table-runtime/src/test/java/org/apache/flink/table/runtime/operators/over/NonTimeRangeUnboundedPrecedingFunctionTest.java:
##
@@ -0,0 +1,2028 @@
bvarghese1 commented on code in PR #25753:
URL: https://github.com/apache/flink/pull/25753#discussion_r1957702535
##
flink-table/flink-table-runtime/src/test/java/org/apache/flink/table/runtime/operators/over/NonTimeRangeUnboundedPrecedingFunctionTest.java:
##
@@ -0,0 +1,2028 @@
[
https://issues.apache.org/jira/browse/FLINK-37333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-37333:
---
Assignee: xingbe
> Use ForwardForUnspecifiedPartitioner when adaptive broadcast join takes effect
>
bvarghese1 commented on code in PR #25753:
URL: https://github.com/apache/flink/pull/25753#discussion_r1957701908
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/over/NonTimeRangeUnboundedPrecedingFunction.java:
##
@@ -0,0 +1,689 @@
+/*
codenohup commented on code in PR #26119:
URL: https://github.com/apache/flink/pull/26119#discussion_r1957670167
##
docs/content.zh/docs/deployment/config.md:
##
@@ -597,15 +597,15 @@ You can configure environment variables to be set on the
JobManager and TaskMana
These option
xingbe created FLINK-37333:
--
Summary: Use ForwardForUnspecifiedPartitioner when adaptive
broadcast join takes effect
Key: FLINK-37333
URL: https://issues.apache.org/jira/browse/FLINK-37333
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-31960?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17927618#comment-17927618
]
yisha zhou commented on FLINK-31960:
[~jark] hi Jark, I encountered the same issue.
[
https://issues.apache.org/jira/browse/FLINK-37329?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Syed Shameerur Rahman updated FLINK-37329:
--
Description:
Currently when "table.optimizer.source.report-statistics-enabled"
shameersss1 commented on PR #26162:
URL: https://github.com/apache/flink/pull/26162#issuecomment-2662159840
@reswqa @JunRuiLee @dawidwys Could you please review the changes ?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub an
[
https://issues.apache.org/jira/browse/FLINK-37067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17927611#comment-17927611
]
xuhuang commented on FLINK-37067:
-
Hi, [~yutonghan1718]
Is the test still going on?
If
[
https://issues.apache.org/jira/browse/FLINK-37062?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17927610#comment-17927610
]
Weijie Guo commented on FLINK-37062:
Hi [~mapohl], could you please adding instructi
[
https://issues.apache.org/jira/browse/FLINK-37052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo closed FLINK-37052.
--
Resolution: Invalid
> Cross-team verification for FLINK-36245
> --
[
https://issues.apache.org/jira/browse/FLINK-37060?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo reassigned FLINK-37060:
--
Assignee: xuhuang
> Cross-team verification for FLIP-398
> --
[
https://issues.apache.org/jira/browse/FLINK-37049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo reassigned FLINK-37049:
--
Assignee: Zhanghao Chen
> Cross-team verification for "Remove all Scala APIs"
> -
[
https://issues.apache.org/jira/browse/FLINK-37047?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo reassigned FLINK-37047:
--
Assignee: Zhanghao Chen
> Cross-team verification for "Remove DataSet API"
>
reswqa merged PR #26161:
URL: https://github.com/apache/flink/pull/26161
--
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
[
https://issues.apache.org/jira/browse/FLINK-37194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17927597#comment-17927597
]
Weijie Guo commented on FLINK-37194:
master(2.1) via 20d5eb0a8cc9be84a3375e2968564b1
[
https://issues.apache.org/jira/browse/FLINK-37194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo reassigned FLINK-37194:
--
Assignee: Luke Chen
> WatermarkITCase.testAlignedWatermarkBlockUpstream failed
>
[
https://issues.apache.org/jira/browse/FLINK-37194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo resolved FLINK-37194.
Fix Version/s: 2.0.0
2.1.0
Assignee: (was: xuhuang)
Resoluti
reswqa merged PR #26048:
URL: https://github.com/apache/flink/pull/26048
--
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
showuon commented on PR #26048:
URL: https://github.com/apache/flink/pull/26048#issuecomment-2661883107
@reswqa , Rebased. I think it's good to be merged. Thanks.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL
reswqa commented on PR #26118:
URL: https://github.com/apache/flink/pull/26118#issuecomment-2661881669
Hi @davidradl, and feedback about this PR?
I plan to merge this PR tomorrow if you have no new comments.
--
This is an automated message from the Apache Git Service.
To respond to
GOODBOY008 commented on PR #3873:
URL: https://github.com/apache/flink-cdc/pull/3873#issuecomment-2661853083
@morozov Can you review the changes which I made to improve the robustness
of UT.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
lincoln-lil commented on PR #23899:
URL: https://github.com/apache/flink/pull/23899#issuecomment-2661793194
@luoyuxia would be great if you have time to have a double check for this.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Gi
[
https://issues.apache.org/jira/browse/FLINK-37097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17927582#comment-17927582
]
luoyuxia commented on FLINK-37097:
--
[~Sergey Nuyanzin] Thanks for the greate work.. I w
Shawnsuun commented on PR #25838:
URL: https://github.com/apache/flink/pull/25838#issuecomment-2661664038
> ## CI report:
> *
[026a975](https://github.com/apache/flink/commit/026a9756641272c5df243ec1e55c5205c860f6c1)
UNKNOWN
> *
[b17c658](https://github.com/apache/flink/commit/b17c65
juanvisoler commented on PR #24826:
URL: https://github.com/apache/flink/pull/24826#issuecomment-2661589222
@RyanSkraba should we merge 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 the s
[
https://issues.apache.org/jira/browse/FLINK-37097?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17927538#comment-17927538
]
Sergey Nuyanzin commented on FLINK-37097:
-
Hey [~lincoln.86xy], [~luoyuxia]
the
snuyanzin commented on code in PR #25834:
URL: https://github.com/apache/flink/pull/25834#discussion_r1957366433
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/converters/SqlAlterModelSetConverter.java:
##
@@ -0,0 +1,105 @@
+/*
+ * Lic
snuyanzin commented on code in PR #25834:
URL: https://github.com/apache/flink/pull/25834#discussion_r1957365112
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/converters/SqlAlterModelRenameConverter.java:
##
@@ -0,0 +1,70 @@
+/*
+ * L
snuyanzin commented on code in PR #25834:
URL: https://github.com/apache/flink/pull/25834#discussion_r1957363319
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/DescribeModelOperation.java:
##
@@ -0,0 +1,156 @@
+/*
+ * Licensed to the Apache S
snuyanzin commented on code in PR #25834:
URL: https://github.com/apache/flink/pull/25834#discussion_r1957361662
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/CatalogManager.java:
##
@@ -1512,18 +1513,52 @@ public void createTemporaryModel(
snuyanzin commented on code in PR #25834:
URL: https://github.com/apache/flink/pull/25834#discussion_r1957356371
##
flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/ddl/SqlAlterModelReset.java:
##
@@ -0,0 +1,76 @@
+/*
+ * Licensed to the Apache Software Fou
snuyanzin commented on code in PR #25834:
URL: https://github.com/apache/flink/pull/25834#discussion_r1957356578
##
flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/ddl/SqlAlterModelSet.java:
##
@@ -0,0 +1,73 @@
+/*
+ * Licensed to the Apache Software Found
snuyanzin commented on code in PR #25834:
URL: https://github.com/apache/flink/pull/25834#discussion_r1957355248
##
flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/ddl/SqlAlterModelReset.java:
##
@@ -0,0 +1,76 @@
+/*
+ * Licensed to the Apache Software Fou
snuyanzin commented on code in PR #25834:
URL: https://github.com/apache/flink/pull/25834#discussion_r1957355248
##
flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/ddl/SqlAlterModelReset.java:
##
@@ -0,0 +1,76 @@
+/*
+ * Licensed to the Apache Software Fou
snuyanzin commented on code in PR #25834:
URL: https://github.com/apache/flink/pull/25834#discussion_r1957354921
##
flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/ddl/SqlAlterModelRename.java:
##
@@ -0,0 +1,67 @@
+/*
+ * Licensed to the Apache Software Fo
snuyanzin commented on code in PR #25834:
URL: https://github.com/apache/flink/pull/25834#discussion_r1957354159
##
flink-table/flink-sql-parser/src/main/java/org/apache/flink/sql/parser/ddl/SqlAlterModelRename.java:
##
@@ -0,0 +1,67 @@
+/*
+ * Licensed to the Apache Software Fo
[
https://issues.apache.org/jira/browse/FLINK-37311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17927526#comment-17927526
]
Gabor Somogyi commented on FLINK-37311:
---
I would vote on clean solution, sooner or
snuyanzin commented on code in PR #25897:
URL: https://github.com/apache/flink/pull/25897#discussion_r1957352108
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/utils/DateTimeUtils.java:
##
@@ -1290,6 +1353,24 @@ private static long floor(long a, long b) {
snuyanzin commented on code in PR #25897:
URL: https://github.com/apache/flink/pull/25897#discussion_r1957351774
##
flink-table/flink-table-common/src/main/java/org/apache/flink/table/utils/DateTimeUtils.java:
##
@@ -1299,6 +1380,39 @@ private static long ceil(long a, long b) {
[
https://issues.apache.org/jira/browse/FLINK-37311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17927524#comment-17927524
]
Jinkun Liu edited comment on FLINK-37311 at 2/16/25 3:23 PM:
-
snuyanzin commented on PR #25897:
URL: https://github.com/apache/flink/pull/25897#issuecomment-2661478306
`TimestampData` is annotated with `@PublicEvolving`
https://github.com/apache/flink/blob/4efbc9138782f07ee35c71456759187e613617b6/flink-table/flink-table-common/src/main/java/org/apac
[
https://issues.apache.org/jira/browse/FLINK-37311?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17927524#comment-17927524
]
Jinkun Liu commented on FLINK-37311:
Hi [~gaborgsomogyi]
I encountered same
[
https://issues.apache.org/jira/browse/FLINK-35725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17927516#comment-17927516
]
Jim Hughes commented on FLINK-35725:
Hi [~jkk123] yes! I have assigned the task to
[
https://issues.apache.org/jira/browse/FLINK-35725?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jim Hughes reassigned FLINK-35725:
--
Assignee: Jinkun Liu
> Translate new DISTRIBUTED BY documentation into Chinese
>
[
https://issues.apache.org/jira/browse/FLINK-37248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17927491#comment-17927491
]
911432 commented on FLINK-37248:
[~kunni] [~Zhanghao Chen]
The location of the document
[
https://issues.apache.org/jira/browse/FLINK-35725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17927486#comment-17927486
]
Jinkun Liu commented on FLINK-35725:
Hi [~jhughes] ,
I’d be happy to assist
[
https://issues.apache.org/jira/browse/FLINK-37332?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lee SeungMin updated FLINK-37332:
-
Description:
Now, support any columns as chunk key column (postgres, orcale, db2, sqlserver)
gi
[
https://issues.apache.org/jira/browse/FLINK-37332?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-37332:
---
Labels: pull-request-available (was: )
> Support any columns as chunk key column (postgres,
SML0127 opened a new pull request, #3922:
URL: https://github.com/apache/flink-cdc/pull/3922
MySQL CDC connector supports this feature from flink cdc v3.2
Now, other connectors that support incremental snapshot allow any columns as
chunk key column
apache jira: https://issues.apach
60 matches
Mail list logo
