davidradl commented on code in PR #25810:
URL: https://github.com/apache/flink/pull/25810#discussion_r1894119512
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/TableEnvironment.java:
##
@@ -1026,20 +1026,86 @@ void createTemporarySystemFunction(
yiyutian1 commented on code in PR #25763:
URL: https://github.com/apache/flink/pull/25763#discussion_r1894119140
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/Expressions.java:
##
@@ -366,6 +366,61 @@ public static ApiExpression toTimestampLtz(Obje
afedulov commented on PR #25813:
URL: https://github.com/apache/flink/pull/25813#issuecomment-2557293147
@piotrp thanks for the contribution. Please consider that usage of Mockito
in Flink is generally discouraged:
https://flink.apache.org/how-to-contribute/code-style-and-quality-common/
yiyutian1 commented on code in PR #25763:
URL: https://github.com/apache/flink/pull/25763#discussion_r1894092145
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/TimeFunctionsITCase.java:
##
@@ -804,4 +813,163 @@ private Stream floorTestC
yiyutian1 commented on code in PR #25763:
URL: https://github.com/apache/flink/pull/25763#discussion_r1894106052
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ToTimestampLtzFunction.java:
##
@@ -0,0 +1,139 @@
+/*
+ * Licensed to
yiyutian1 commented on code in PR #25763:
URL: https://github.com/apache/flink/pull/25763#discussion_r1894092145
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/TimeFunctionsITCase.java:
##
@@ -804,4 +813,163 @@ private Stream floorTestC
davidradl commented on code in PR #25810:
URL: https://github.com/apache/flink/pull/25810#discussion_r1894119512
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/TableEnvironment.java:
##
@@ -1026,20 +1026,86 @@ void createTemporarySystemFunction(
davidradl commented on code in PR #25810:
URL: https://github.com/apache/flink/pull/25810#discussion_r1894119512
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/TableEnvironment.java:
##
@@ -1026,20 +1026,86 @@ void createTemporarySystemFunction(
afedulov commented on code in PR #25813:
URL: https://github.com/apache/flink/pull/25813#discussion_r1894125426
##
flink-core/pom.xml:
##
@@ -180,6 +180,13 @@ under the License.
test
+
Review Comment:
Mockito is inten
hanyuzheng7 commented on code in PR #25763:
URL: https://github.com/apache/flink/pull/25763#discussion_r1894127361
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ToTimestampLtzFunction.java:
##
@@ -0,0 +1,139 @@
+/*
+ * Licensed
davidradl commented on code in PR #25810:
URL: https://github.com/apache/flink/pull/25810#discussion_r1894119512
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/TableEnvironment.java:
##
@@ -1026,20 +1026,86 @@ void createTemporarySystemFunction(
yiyutian1 commented on code in PR #25763:
URL: https://github.com/apache/flink/pull/25763#discussion_r1894146265
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ToTimestampLtzFunction.java:
##
@@ -0,0 +1,139 @@
+/*
+ * Licensed to
yiyutian1 commented on code in PR #25763:
URL: https://github.com/apache/flink/pull/25763#discussion_r1894146265
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ToTimestampLtzFunction.java:
##
@@ -0,0 +1,139 @@
+/*
+ * Licensed to
yiyutian1 commented on code in PR #25763:
URL: https://github.com/apache/flink/pull/25763#discussion_r1894166214
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ToTimestampLtzFunction.java:
##
@@ -0,0 +1,139 @@
+/*
+ * Licensed to
yiyutian1 commented on code in PR #25763:
URL: https://github.com/apache/flink/pull/25763#discussion_r1894166214
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ToTimestampLtzFunction.java:
##
@@ -0,0 +1,139 @@
+/*
+ * Licensed to
yiyutian1 commented on code in PR #25763:
URL: https://github.com/apache/flink/pull/25763#discussion_r1894166214
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ToTimestampLtzFunction.java:
##
@@ -0,0 +1,139 @@
+/*
+ * Licensed to
yiyutian1 commented on code in PR #25763:
URL: https://github.com/apache/flink/pull/25763#discussion_r1894166214
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ToTimestampLtzFunction.java:
##
@@ -0,0 +1,139 @@
+/*
+ * Licensed to
afedulov opened a new pull request, #25833:
URL: https://github.com/apache/flink/pull/25833
Unmodified backport of https://github.com/apache/flink/pull/23439 to 1.20
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
afedulov commented on PR #25833:
URL: https://github.com/apache/flink/pull/25833#issuecomment-2557385736
@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.
flinkbot commented on PR #25833:
URL: https://github.com/apache/flink/pull/25833#issuecomment-2557386028
## CI report:
* c8f3c26629996819cea131ef8cf11526e6b98369 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
yiyutian1 commented on code in PR #25763:
URL: https://github.com/apache/flink/pull/25763#discussion_r1894092145
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/TimeFunctionsITCase.java:
##
@@ -804,4 +813,163 @@ private Stream floorTestC
[
https://issues.apache.org/jira/browse/FLINK-36931?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Leonard Xu reassigned FLINK-36931:
--
Assignee: Wenkai Qi
> FlinkCDC YAML supports synchronizing the full amount of data of the ent
snuyanzin commented on code in PR #25763:
URL: https://github.com/apache/flink/pull/25763#discussion_r1894130094
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ToTimestampLtzFunction.java:
##
@@ -0,0 +1,139 @@
+/*
+ * Licensed to
snuyanzin commented on code in PR #25763:
URL: https://github.com/apache/flink/pull/25763#discussion_r1894130094
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ToTimestampLtzFunction.java:
##
@@ -0,0 +1,139 @@
+/*
+ * Licensed to
davidradl commented on code in PR #25810:
URL: https://github.com/apache/flink/pull/25810#discussion_r1894138335
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/CatalogManager.java:
##
@@ -1297,30 +1303,42 @@ public void dropMaterializedTable(
davidradl commented on code in PR #25810:
URL: https://github.com/apache/flink/pull/25810#discussion_r1894138335
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/CatalogManager.java:
##
@@ -1297,30 +1303,42 @@ public void dropMaterializedTable(
yiyutian1 commented on code in PR #25763:
URL: https://github.com/apache/flink/pull/25763#discussion_r1894140247
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/TimeFunctionsITCase.java:
##
@@ -804,4 +813,163 @@ private Stream floorTestC
davidradl commented on code in PR #25763:
URL: https://github.com/apache/flink/pull/25763#discussion_r1894143500
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ToTimestampLtzFunction.java:
##
@@ -0,0 +1,139 @@
+/*
+ * Licensed to
yiyutian1 commented on code in PR #25763:
URL: https://github.com/apache/flink/pull/25763#discussion_r1894146265
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ToTimestampLtzFunction.java:
##
@@ -0,0 +1,139 @@
+/*
+ * Licensed to
snuyanzin commented on code in PR #25763:
URL: https://github.com/apache/flink/pull/25763#discussion_r1894179515
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ToTimestampLtzFunction.java:
##
@@ -0,0 +1,139 @@
+/*
+ * Licensed to
snuyanzin commented on code in PR #25763:
URL: https://github.com/apache/flink/pull/25763#discussion_r1894179515
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ToTimestampLtzFunction.java:
##
@@ -0,0 +1,139 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-36946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rui Fan reassigned FLINK-36946:
---
Assignee: tartarus
> optimize sink operator name truncate
>
>
[
https://issues.apache.org/jira/browse/FLINK-36945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yohei Yoshimuta updated FLINK-36945:
Description:
[The Vitess schema migration
tool|https://vitess.io/docs/user-guides/schema-
[
https://issues.apache.org/jira/browse/FLINK-36920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17907357#comment-17907357
]
Gyula Fora commented on FLINK-36920:
Makes sense ! But I agree that cutting a new re
mehdid93 commented on PR #25794:
URL: https://github.com/apache/flink/pull/25794#issuecomment-2556704958
Hey Robert and David and sorry for the late response.
Yes the issue is due to the old version of Ubuntu image used in the build CI
I've backported the PRs made by @zentol and @simpleja
[
https://issues.apache.org/jira/browse/FLINK-36942?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17907333#comment-17907333
]
Zakelly Lan commented on FLINK-36942:
-
[~au_miner] Thanks for your contribution! The
Yohei Yoshimuta created FLINK-36945:
---
Summary: MySQL CDC internal schema representation becomes out of
sync with the real database schema when restarting a job
Key: FLINK-36945
URL: https://issues.apache.org/jir
[
https://issues.apache.org/jira/browse/FLINK-36944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zakelly Lan updated FLINK-36944:
Summary: Introduce 'enableAsycState' in KeyedStream interfaces (was:
Introduce 'enableAsycState'
Zakelly opened a new pull request, #25831:
URL: https://github.com/apache/flink/pull/25831
## What is the purpose of the change
As first part of FLIP-488, this PR introduces `enableAsycState` in
KeyedStream and its related interface classes. Also it provides a basic
implementation of
[
https://issues.apache.org/jira/browse/FLINK-36944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36944:
---
Labels: pull-request-available (was: )
> Introduce 'enableAsycState' in KeyedStream interfa
Tartarus0zm opened a new pull request, #25832:
URL: https://github.com/apache/flink/pull/25832
## What is the purpose of the change
Avoid truncation of the Writer/Committer keyword.
## Brief change log
- add MetricUtil#truncateOperatorName to optimize Operator name
[
https://issues.apache.org/jira/browse/FLINK-36946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36946:
---
Labels: pull-request-available (was: )
> optimize sink operator name truncate
> ---
Zakelly merged PR #25824:
URL: https://github.com/apache/flink/pull/25824
--
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-36938?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17907367#comment-17907367
]
Zakelly Lan commented on FLINK-36938:
-
Merge 7fa4f78 into master
> Provide hooks be
[
https://issues.apache.org/jira/browse/FLINK-36938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zakelly Lan resolved FLINK-36938.
-
Fix Version/s: 2.0.0
Resolution: Fixed
> Provide hooks before and after the watermark pro
tartarus created FLINK-36946:
Summary: optimize sink operator name truncate
Key: FLINK-36946
URL: https://issues.apache.org/jira/browse/FLINK-36946
Project: Flink
Issue Type: Improvement
flinkbot commented on PR #25832:
URL: https://github.com/apache/flink/pull/25832#issuecomment-2556895215
## CI report:
* cee66261ba96fb8c49b4da0f74abc7c33c05b146 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-36946?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17907370#comment-17907370
]
tartarus commented on FLINK-36946:
--
[~fanrui] Hi, if you're free, please take a look,
davidradl commented on code in PR #25828:
URL: https://github.com/apache/flink/pull/25828#discussion_r1893949065
##
docs/data/sql_functions.yml:
##
@@ -642,7 +642,10 @@ temporal:
description: Returns TRUE if two time intervals defined by (timepoint1,
temporal1) and (timepo
snuyanzin commented on code in PR #25763:
URL: https://github.com/apache/flink/pull/25763#discussion_r1893951451
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ToTimestampLtzFunction.java:
##
@@ -0,0 +1,139 @@
+/*
+ * Licensed to
snuyanzin commented on code in PR #25763:
URL: https://github.com/apache/flink/pull/25763#discussion_r1893952530
##
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/functions/TimeFunctionsITCase.java:
##
@@ -804,4 +813,163 @@ private Stream floorTestC
[
https://issues.apache.org/jira/browse/FLINK-36770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36770:
---
Labels: pull-request-available (was: )
> Support Request Timeout for AWS sinks
> --
vahmed-hamdy opened a new pull request, #186:
URL: https://github.com/apache/flink-connector-aws/pull/186
## Purpose of the change
- Move `submitRequestEntries` implementation for AWS sinks to use
`ResultHandler`
- Bump flink version to 1.20
- Adapt pipelines
nictownsend commented on code in PR #25828:
URL: https://github.com/apache/flink/pull/25828#discussion_r1893958758
##
docs/data/sql_functions.yml:
##
@@ -642,7 +642,10 @@ temporal:
description: Returns TRUE if two time intervals defined by (timepoint1,
temporal1) and (time
davidradl commented on code in PR #25828:
URL: https://github.com/apache/flink/pull/25828#discussion_r1893959599
##
flink-python/pyflink/table/expressions.py:
##
@@ -350,14 +350,19 @@ def temporal_overlaps(left_time_point,
def date_format(timestamp, format) -> Expression:
davidradl commented on code in PR #25828:
URL: https://github.com/apache/flink/pull/25828#discussion_r1893960744
##
flink-python/pyflink/table/expressions.py:
##
@@ -350,14 +350,19 @@ def temporal_overlaps(left_time_point,
def date_format(timestamp, format) -> Expression:
[
https://issues.apache.org/jira/browse/FLINK-36923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ferenc Csaky updated FLINK-36923:
-
Affects Version/s: (was: hbase-4.1.0)
> Bump flink-connector-hbase to Flink 1.20
> -
yiyutian1 commented on code in PR #25763:
URL: https://github.com/apache/flink/pull/25763#discussion_r1894201016
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ToTimestampLtzFunction.java:
##
@@ -0,0 +1,139 @@
+/*
+ * Licensed to
yiyutian1 commented on code in PR #25763:
URL: https://github.com/apache/flink/pull/25763#discussion_r1894146265
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ToTimestampLtzFunction.java:
##
@@ -0,0 +1,139 @@
+/*
+ * Licensed to
[
https://issues.apache.org/jira/browse/FLINK-36923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ferenc Csaky updated FLINK-36923:
-
Fix Version/s: hbase-4.1.0
> Bump flink-connector-hbase to Flink 1.20
>
yiyutian1 commented on code in PR #25763:
URL: https://github.com/apache/flink/pull/25763#discussion_r1894146265
##
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/functions/scalar/ToTimestampLtzFunction.java:
##
@@ -0,0 +1,139 @@
+/*
+ * Licensed to
ferenc-csaky commented on PR #54:
URL:
https://github.com/apache/flink-connector-hbase/pull/54#issuecomment-2557428849
Hi, thanks for your contribution! I am planning to try to include at least
JDK 17 (and possibly 21) support for the next release, which will require to
bump HBase version
afedulov commented on code in PR #25656:
URL: https://github.com/apache/flink/pull/25656#discussion_r1894239482
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/TableEnvironmentImpl.java:
##
@@ -1029,6 +1029,11 @@ private TableResultInternal
[
https://issues.apache.org/jira/browse/FLINK-36940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17907300#comment-17907300
]
Gyula Fora commented on FLINK-36940:
Good question , I don’t remember right now . Fo
[
https://issues.apache.org/jira/browse/FLINK-36940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17907300#comment-17907300
]
Gyula Fora edited comment on FLINK-36940 at 12/20/24 8:40 AM:
[
https://issues.apache.org/jira/browse/FLINK-35921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wang Qilong closed FLINK-35921.
---
Resolution: Fixed
> Flink SQL physical operator replacement support
> --
Wang Qilong created FLINK-36942:
---
Summary: Unable to trigger onEventTime() when using the async
state API in RowTimestamportOperator
Key: FLINK-36942
URL: https://issues.apache.org/jira/browse/FLINK-36942
[
https://issues.apache.org/jira/browse/FLINK-36942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wang Qilong updated FLINK-36942:
Description:
When I use the async state API in RowTimeSortOperator and inherit it from
AbstractAs
davidradl commented on code in PR #25810:
URL: https://github.com/apache/flink/pull/25810#discussion_r1893692402
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/TableEnvironmentImpl.java:
##
@@ -649,6 +649,13 @@ public boolean dropTemporaryT
[
https://issues.apache.org/jira/browse/FLINK-36716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17907318#comment-17907318
]
Mehdi commented on FLINK-36716:
---
I'm going to for the PRs done to the branch 1.20 for 1.20
[
https://issues.apache.org/jira/browse/FLINK-36716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17907318#comment-17907318
]
Mehdi edited comment on FLINK-36716 at 12/20/24 9:39 AM:
-
I'm go
[
https://issues.apache.org/jira/browse/FLINK-36716?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17907318#comment-17907318
]
Mehdi edited comment on FLINK-36716 at 12/20/24 9:39 AM:
-
I'm go
snuyanzin commented on code in PR #25810:
URL: https://github.com/apache/flink/pull/25810#discussion_r1893703612
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/TableEnvironmentImpl.java:
##
@@ -649,6 +649,13 @@ public boolean dropTemporaryT
yiyutian1 opened a new pull request, #25828:
URL: https://github.com/apache/flink/pull/25828
## 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-36941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-36941:
---
Labels: pull-request-available (was: )
> Fix Doc for DATE_FORMAT
> ---
Zakelly Lan created FLINK-36943:
---
Summary: FLIP-488: Expose Async State Processing and New State
APIs in Datastream(V1) APIs
Key: FLINK-36943
URL: https://issues.apache.org/jira/browse/FLINK-36943
Proje
yuchen-ecnu commented on code in PR #25798:
URL: https://github.com/apache/flink/pull/25798#discussion_r1893709324
##
flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/job/JobDetailsInfo.java:
##
@@ -79,6 +79,10 @@ public class JobDetailsInfo implements Response
flinkbot commented on PR #25828:
URL: https://github.com/apache/flink/pull/25828#issuecomment-2556636543
## CI report:
* 5a9ea558b896c515f962554f0a5b33e7fda015dd UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
yuchen-ecnu commented on code in PR #25798:
URL: https://github.com/apache/flink/pull/25798#discussion_r1893709533
##
flink-runtime/src/main/java/org/apache/flink/streaming/api/graph/AdaptiveGraphManager.java:
##
@@ -291,6 +299,8 @@ private List
createJobVerticesAndUpdateGraph(
davidradl commented on code in PR #25810:
URL: https://github.com/apache/flink/pull/25810#discussion_r1893692402
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/TableEnvironmentImpl.java:
##
@@ -649,6 +649,13 @@ public boolean dropTemporaryT
Zakelly Lan created FLINK-36944:
---
Summary: Introduce 'enableAsycState' in DataStream v1 interfaces
Key: FLINK-36944
URL: https://issues.apache.org/jira/browse/FLINK-36944
Project: Flink
Issue T
[
https://issues.apache.org/jira/browse/FLINK-36943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zakelly Lan updated FLINK-36943:
Component/s: API / DataStream
Runtime / Async State Processing
> FLIP-488: Expose
mehdid93 opened a new pull request, #25829:
URL: https://github.com/apache/flink/pull/25829
## What is the purpose of the change
This PR backport the changes done of the PR made by @simplejason
(https://github.com/apache/flink/pull/25713) in master for version 1.20.X to be
used in de
yuxiqian commented on code in PR #3801:
URL: https://github.com/apache/flink-cdc/pull/3801#discussion_r1893623717
##
flink-cdc-runtime/src/main/java/org/apache/flink/cdc/runtime/operators/schema/distributed/SchemaCoordinator.java:
##
@@ -0,0 +1,437 @@
+/*
+ * Licensed to the Apa
snuyanzin commented on code in PR #25810:
URL: https://github.com/apache/flink/pull/25810#discussion_r1893604056
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/TableEnvironment.java:
##
@@ -1030,6 +1030,17 @@ void createTemporarySystemFunction(
davidradl commented on PR #25769:
URL: https://github.com/apache/flink/pull/25769#issuecomment-2556549160
@rmetzger as discussed at the Chi meeting are you ok to merge this? @donPain
can you raise a separate issue to track the variable replacement improvement
idea please.
--
This is an
[
https://issues.apache.org/jira/browse/FLINK-36942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wang Qilong updated FLINK-36942:
Description:
When I use the async state API in RowTimeSortOperator and inherit it from
AbstractAs
[
https://issues.apache.org/jira/browse/FLINK-36942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wang Qilong updated FLINK-36942:
Description:
When I use the async state API in RowTimeSortOperator and inherit it from
AbstractAs
mehdid93 opened a new pull request, #25827:
URL: https://github.com/apache/flink/pull/25827
## What is the purpose of the change
This PR backport the changes done of the PR made by @zentol
(https://github.com/apache/flink/pull/25708) in master for version 1.20.X to be
used in depende
davidradl commented on code in PR #25810:
URL: https://github.com/apache/flink/pull/25810#discussion_r1893679664
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/TableEnvironment.java:
##
@@ -1040,6 +1066,32 @@ void createTemporarySystemFunction(
davidradl commented on code in PR #25810:
URL: https://github.com/apache/flink/pull/25810#discussion_r1893681601
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/TableEnvironment.java:
##
@@ -1040,6 +1066,32 @@ void createTemporarySystemFunction(
flinkbot commented on PR #25827:
URL: https://github.com/apache/flink/pull/25827#issuecomment-2556600135
## CI report:
* 565408f120180d245b935b09165a43bac4731bd7 UNKNOWN
Bot commands
The @flinkbot bot supports the following commands:
- `@flinkbot run azure`
[
https://issues.apache.org/jira/browse/FLINK-36942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wang Qilong updated FLINK-36942:
Description:
When I use the async state API in RowTimeSortOperator and inherit it from
AbstractAs
twalthr commented on code in PR #25810:
URL: https://github.com/apache/flink/pull/25810#discussion_r1893677952
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/TableEnvironment.java:
##
@@ -1040,6 +1066,32 @@ void createTemporarySystemFunction(
[
https://issues.apache.org/jira/browse/FLINK-36942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Wang Qilong updated FLINK-36942:
Description:
When I use the async state API in RowTimeSortOperator and inherit it from
AbstractAs
davidradl commented on code in PR #25810:
URL: https://github.com/apache/flink/pull/25810#discussion_r1893685759
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/TableEnvironment.java:
##
@@ -1030,6 +1030,32 @@ void createTemporarySystemFunction(
davidradl commented on code in PR #25810:
URL: https://github.com/apache/flink/pull/25810#discussion_r1893689041
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/TableEnvironment.java:
##
@@ -1040,6 +1066,32 @@ void createTemporarySystemFunction(
davidradl commented on code in PR #25810:
URL: https://github.com/apache/flink/pull/25810#discussion_r1893681174
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/TableEnvironment.java:
##
@@ -1040,6 +1066,32 @@ void createTemporarySystemFunction(
snuyanzin commented on code in PR #25810:
URL: https://github.com/apache/flink/pull/25810#discussion_r1893690187
##
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/TableEnvironment.java:
##
@@ -1030,6 +1030,32 @@ void createTemporarySystemFunction(
snuyanzin commented on PR #25828:
URL: https://github.com/apache/flink/pull/25828#issuecomment-2556669198
fyi: it can not be both `[hotfix]` and marked with jira issue.
So please change commit message with something like `[FLINK-36941][docs] ...`
--
This is an automated message from the
1 - 100 of 196 matches
Mail list logo
