[
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
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
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
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
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
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 edited comment on FLINK-37311 at 2/16/25 3:23 PM:
-
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_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_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_r1957366433
##
flink-table/flink-table-planner/src/main/java/org/apache/flink/table/planner/operations/converters/SqlAlterModelSetConverter.java:
##
@@ -0,0 +1,105 @@
+/*
+ * Lic
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
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
[
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
[
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-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:comment-tabpanel&focusedCommentId=17927597#comment-17927597
]
Weijie Guo commented on FLINK-37194:
master(2.1) via 20d5eb0a8cc9be84a3375e2968564b1
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-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"
>
[
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-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-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-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
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-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"
[
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
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
[
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,
[
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
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 @@
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 @@
[
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
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
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`
[
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-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"
> ---
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
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 @@
+/*
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-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
>
[
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-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
[
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
[
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
[
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
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) {
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) {
[
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-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-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 #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
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_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_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
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
60 matches
Mail list logo
